Spring Integration异步Http出站调用
Spring Integration是一个基于Spring框架的集成解决方案，它提供了一种简单且灵活的方式来构建企业级应用程序。Spring Integration异步Http出站调用是指在Spring Integration中使用异步方式进行Http请求的出站调用。
异步Http出站调用的优势在于可以提高系统的并发能力和响应速度。通过将Http请求发送到外部系统并立即返回，系统可以继续处理其他任务，而不需要等待外部系统的响应。当外部系统的响应返回时，可以通过回调函数或消息通知的方式进行处理。
异步Http出站调用在以下场景中非常适用：
- 高并发场景：当系统需要处理大量的并发请求时，使用异步方式可以提高系统的吞吐量和响应速度。
- 外部系统响应时间较长：当外部系统的响应时间较长时，使用异步方式可以避免系统的阻塞，提高系统的性能和稳定性。
- 异步通知：当需要向外部系统发送通知或回调时，使用异步方式可以提高系统的灵活性和可扩展性。
在Spring Integration中，可以使用Http Outbound Gateway来实现异步Http出站调用。Http Outbound Gateway是一个出站网关，它负责将消息发送到外部系统，并处理外部系统的响应。可以通过配置Http Outbound Gateway的异步属性为true来启用异步方式。
腾讯云提供了一系列与Spring Integration异步Http出站调用相关的产品和服务，包括：
- 云服务器（CVM）：提供可扩展的计算资源，用于部署Spring Integration应用程序。
- 云数据库MySQL版（CDB）：提供可靠的数据库服务，用于存储和管理应用程序的数据。
- 云函数（SCF）：提供事件驱动的无服务器计算服务，用于处理异步通知和回调。
- 云监控（Cloud Monitor）：提供实时监控和告警功能，用于监控Spring Integration应用程序的性能和可用性。
更多关于腾讯云产品和服务的详细信息，请访问腾讯云官方网站：https://cloud.tencent.com/
相关·内容
1回答
我有一个下面的spring集成xml，我在其中发送一条消息到队列，该消息最终被消费并显示在控制台上，但是现在我想定制它，比如说那些被消费的消息最终应该被写入(换句话说，那些消息需要被记录)在一个文本文件中，该文本文件应该保存在我的文件夹的C: drive中，文件的名称是messageslog.txt
请告诉我如何在spring集成本身中添加这样的功能来获得这个功能。我已经知道在spring集成中像文件出站通道适配器这样的东西会有所帮助。
下面是我的spring集成xml
<?xml version="1.0" encoding="UTF-8"?>
&
浏览 2提问于2015-04-01得票数 0
1回答
在成功之前抛出异常
、、、、
这是我的骡子流：
HTTP => Logger => SOAP (CXF) =>直到JAVA => 记录器
春天：
<spring:beans>
<spring:bean id="propertyConfigurer"
class="org.springframework.beans.factory.config.PropertyPlaceholderConfigurer">
<spring:property name="locations">
浏览 2提问于2015-06-01得票数 0
回答已采纳
从教程中了解spring集成的基础知识，并尝试实现一个小的考试结果流程。在下面的代码中，为input-channel="exam"调用了服务激活器，并且在同一服务激活器上设置的输出通道是output-channel="result"，但它从未被调用，因此<int:outbound-channel-adapter>也从未被调用。
<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns:xsi="http://www.w3.org/2001/XMLS
浏览 7提问于2021-07-31得票数 0
1回答
在计票器从DB获取数据后，我将调用外部服务。在从该服务获得响应后，我想在一个单独的线程中调用另一个系统。这意味着，在得到响应后，我的计票程序应该再进行一次记录，并且send.In加法调用其他系统应该并行地工作。
为此，我使用了一个直接通道来接收来自DB的数据。使用服务激活器向外部服务发送请求。响应被传递给一个执行者channel.can，请告诉我下面的配置对于这个场景是否正确？
为了清晰起见，我共享poller.xml
<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http
浏览 1提问于2015-11-26得票数 0
回答已采纳
2回答
如何使用spring集成将文件从一个位置复制到另一个位置。在我的例子中，我希望将war外部的文件复制到war内部。下面是我正在考虑的代码片段：
<?xml version="1.0" encoding="UTF-8"?>
<beans:beans xmlns:beans="http://www.springframework.org/schema/beans"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
浏览 1提问于2011-02-04得票数 0
我在我的项目中使用。我试图在另一个配置文件中导入配置文件。主要配置文件代码是：
<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
xmlns:int-xml="http://www.springframework.org/schema/integration/xml"
xmlns:int="http://www.springframework.o
浏览 3提问于2014-09-11得票数 0
回答已采纳
1回答
无法发送UDP消息的响应
、、、、
我正试图通过以下方式发送信息：
netcat -u localhost 11111abcd
我只需要客户端得到答案:好的，它得到消息，然后尝试用OK回答。但是它会无限地将其写入应用程序日志：
消息: GenericMessage [payload=byte2，payload=byte2 ip_address=127.0.0.1，id=8db6aa3b-b56b-6dce-9554-c7b0ce050142，ip_port=49489，ip_hostname=127.0.0.1，timestamp=1494442285767}]
消息有效负载:确定
配置：
<?xml versio
浏览 2提问于2017-05-10得票数 0
回答已采纳
我正在使用spring集成tcp进行高容量集成，并且我只在一个连接上发送请求和接收数百万以上的数据，并且两个接收消息之间的时间不到100毫秒。 下面是我的context xml，我使用的是TCPOutboundGateway。 <?xml version="1.0" encoding="UTF-8"?>
<beans
xmlns:int="http://www.springframework.org/schema/integration"
xmlns:int-ip="http://www.springframe
浏览 84提问于2020-09-07得票数 0
回答已采纳
我正在尝试配置Spring Integration来连接我的应用程序。流程如下。
一些Http请求客户端-> Spring Integration(我从事的工作) ->一些Http响应服务器
//Create Channel
DirectChannel directChannel = new DirectChannel();
directChannel.setComponentName("SampleChannel");
directChannel.setFailover(false);
//Create Inbound
IntegrationFlows.from
浏览 3提问于2020-06-30得票数 0
我有一个xml的spring集成路径，它将进行web服务调用(多部分/格式数据)，并需要以JSON格式返回响应。问题是，我找不到任何有响应的多部分请求的好示例SI路由。任何帮助都是非常感谢的。
<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:cont
浏览 3提问于2015-09-01得票数 1
回答已采纳
1回答
我使用Spring Integration - HTTP Adaptor。
现在，我想让它成为HTTPS。请告诉我如何实现它。
浏览 2提问于2012-03-04得票数 0
我是新来的春天集成和弹簧引导。而且，我的用例是轮询JMS队列中的消息，并使用来自JMS队列的消息有效负载XML调用另一个web服务。XML有效负载包含SOAP信封、主体和SAML头。
我可以使用SOAP工具使用XML有效负载访问web服务。
这是我的spring集成配置文件。
====================================================
<beans:beans xmlns="http://www.springframework.org/schema/integration"
xmlns:xsi="http://
浏览 3提问于2017-08-23得票数 0
回答已采纳
1回答
嗨，我正在尝试构建一个Spring引导应用程序，并使用spring集成。
应用程序1: Publisher
Jms Message -> Broker ->queue1
应用程序2:订阅者和发行者
Broker->queue1->Transform->HTTP CALL->HTTP Response->JMS Message->Broker->queue2
Publisher Flow
@Configuration
public class EchoFlowOutBound {
@Autowired
private Con
浏览 0提问于2018-07-27得票数 1
回答已采纳
我已经开发了一个通过教程编写的代码，其中我将从特定位置轮询文件并进一步处理它们。为了轮询的目的，我使用了Spring的入站和出站通道适配器，因此我的bean.xml如下所示：
<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-insta
浏览 1提问于2017-02-10得票数 0
我的情况如下。目前，在我的应用程序中，使用了一个商业库来接受输入，以某种专有的方式序列化它，然后通过TCP将其发送到服务器。正如我在检查TCP流量时看到的那样，某些输入数据，让我们称其为“调用密钥”，是“未加密的”(即，我可以获取发送到服务器的字节序列，并在其中找到“调用密钥”)。
我需要修改如下:拦截TCP流量，查看call key是否为key A，然后将输入发送到server A。如果call key是key B，则需要将其发送到server B。
我正在考虑使用Spring Integration来实现这个目的，尽管我对此了解不多(我只运行了一些示例项目)。
也就是说，我想用一个输入端点
浏览 18提问于2017-02-23得票数 0
回答已采纳
我想使用Spring集成调用webservice，然后得到json响应到FTP，webservice需要json有效负载，我想使用webservice出站网关来满足我的请求，但是我得到了以下异常；似乎SimpleWebServiceOut界网关的默认处理程序不支持json格式的有效负载，我如何克服这个问题并正确地传递JASON有效负载？
Warning: org.apache.xerces.parsers.SAXParser: http://javax.xml.XMLConstants/property/accessExternalDTD
Warning: org.apache.xerce
浏览 0提问于2017-08-21得票数 0
回答已采纳
我正在用下面的usecase开发一个关于Spring集成的POC。
从远程JMS队列订阅输入消息(A)
将输入消息(A)转换为(B)
使用(B)调用远程with服务并接收响应
我的spring config xml有以下内容
<int-ws:outbound-gateway id="marshallingGateway" request-channel="mdmIntInputChannel" reply-channel="mdmIntOutputChannel"
uri="ws-endpoi
浏览 2提问于2017-03-28得票数 0
回答已采纳
我能够使用Rabbit编写一个java程序，执行以下操作：
客户端通过具有关联Id的兔MQ交换/队列发送消息(例如UUID - "348a07f5-8342-45ed-b40b-d44bfd9c4dde")。
服务器接收消息。
服务器通过兔子MQ交换/队列发送响应消息，其相关Id为“348a07f5-8342-45 Id b40b-d44bfd9c4dde”。
客户端仅在与1相同的线程中接收相关消息。
下面是使用兔子API的Send.java和Recv.java。我需要帮助转换此示例使用Spring集成，特别是步骤4中的接收部分。我正在寻找类似于接收方法
浏览 1提问于2014-05-05得票数 1
回答已采纳
2回答
从/到JSON异常
、、、、
我在使用。
在项目内部，我只想处理对象
对于MQ (兔子)，我希望消息的有效载荷可以从java对象自动转换为JSON格式的(这在将来是灵活的)。
但是当运行应用程序时，会抛出异常..。
因此，输出通道配置是：
output:
destination: response
contentType: application/json
输出和模型代码类似于：
/** Source method*/
@Bean
@ServiceActivator(outputChannel=Sink.OUTPUT)
public Mess
浏览 0提问于2016-11-29得票数 0
我有一个系统，我正在寻找翻新与弹簧集成后端。
在这个系统中的一些模式中，可以看到使用多个请求和略微不同的参数访问相同的web服务和/或HTTP服务器(我两者都有)。然后将结果聚合在一起并呈现给用户
我让它成功地在同步模式下工作，在同步模式下，请求通过Gateway进入，被“拆分”成包含每个调用的键值的消息(使用A调用，使用B调用，使用XYZ调用)。然后，每条消息都转到HTTP出站网关，进行调用，然后返回。然后将结果聚合在一起，并通过Gateway传回。
我正在为异步进行这些HTTP调用而苦苦挣扎。当前的系统使用Futures在单独的线程中进行每个调用。我想要一个类似的图案。
我认为我需要做的是
浏览 2提问于2012-12-22得票数 3
回答已采纳
2回答
我的要求是将一个大文件(包含数百万条记录)拆分为100 K记录文件，并将它们分发到3个文件夹中。我使用Java来拆分文件，并使用spring集成来分发它们。在此过程中，将文件分发到文件夹需要很长时间。添加了下面的配置文件。弹簧集成桥的使用是正确的还是有任何优化的方法？我需要增强这段代码，以便将来将文件读写到s3桶而不是本地目录。s3入站/出站适配器是否支持同样的用途？
<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/
浏览 2提问于2017-02-07得票数 0
回答已采纳
我们希望在运行时将会话工厂委托给spring sftp入站通道适配器。为此，我们进行了以下配置。
我们已经看过了spring-sftp集成文档，但是我们不确定如何通过java设置会话工厂属性值。您能建议我们如何使用委托会话工厂来委托spring sftp入站通道适配器中的会话工厂运行时吗？
XML配置
<beans>
<bean id="defaultSftpSessionFactoryOne" class="org.springframework.integration.sftp.session.DefaultSftpSessionFactory&#
浏览 4提问于2016-01-20得票数 2
我有一个应用程序，它使用Solace作为消息代理。应用程序正在工作--消息在队列上接收，然后正确放置在主题上--但是当创建消息时，将引发以下错误消息。我想弄清楚为什么会发生这种事。
03:31:12.479 [taskExecutor-8] WARN o.s.i.jms.DefaultJmsHeaderMapper - failed to map Message header 'JMS_Solace_TopicSequenceNumber' to JMS property
java.lang.IllegalArgumentException: Property SOLACE_
浏览 3提问于2013-10-06得票数 0
我有一个SpringBatch作业，它通过RabbitMQ执行远程分块--基本上，有两个应用程序主程序和工作程序，每个应用程序都是一个春启动应用程序。以下是主配置：
@Bean
public DirectChannel requestsToWorkers() {
return new DirectChannel();
}
@Bean
public IntegrationFlow outboundFlow() {
return IntegrationFlows
.from(requestsToWorkers())
.handle(
浏览 1提问于2019-02-20得票数 0
回答已采纳
如何通过Spring Integration使用服务器发送的事件？我知道Spring通过Webflux支持SSE，但是如何将传入的Flux转换为单独的消息实例？并可能将这些代码封装到某个Spring-Integration-Lifecycle感知组件中(MessageProducerSupport?)
WebClient client = WebClient.create("http://myhost:8080/sse");
ParameterizedTypeReference<ServerSentEvent<String>> type
= new P
浏览 6提问于2021-11-26得票数 1
我正在测试，我遇到了以下问题。
我的SI ver-1.0.4
为了更容易理解，我正在粘贴以下内容：
fileCopyDemo-text.xml
<file:inbound-channel-adapter id="filesIn"
directory="file:${java.io.tmpdir}/spring-integration-samples/input" filename-pattern=".*\.xml">
<integrati
浏览 1提问于2013-01-05得票数 2
回答已采纳
我有以下几点：
[inbound channel adapter] -> ... -> foo -> [outbound channel adapter] -> bar
我如何编写我的spring集成应用程序，以便foo可以使用一个额外的对象，该对象不是[outbound channel adapter]要消费的消息的一部分，这样bar就可以得到它？
我的应用程序基本上是从AWS SQS接收消息(使用spring-integration-aws)，执行一些过滤/转换，然后将消息发布到Apache Kafka (使用spring-integration-kafka)，并且
浏览 54提问于2018-12-15得票数 1
回答已采纳
1回答
在搜索了实现它的不同方法后，我被卡住了。我正在寻找的是用Spring Integration实现这个示例()。我找到了这个有趣的帖子()，但没有帮到我需要的东西。我的案例是这样一个系统:客户端调用"convertSendAndReceive“方法，服务器(基于Spring Integration)将响应。
谢谢
浏览 32提问于2018-01-26得票数 0
我正在尝试使用Spring Integration 5.3.2设置SFTP出站网关，但我真的不明白出了什么问题。 下面是我的网关和会话工厂定义： <int-sftp:outbound-gateway
id="myGateway"
request-channel="inputChannel"
reply-channel="outputChannel"
session-factory="mySessionFactory"
remote-directory="${sftp.base-path}"
浏览 16提问于2020-10-02得票数 0
1回答
弹簧启动与弹簧集成。问题
、、、、
我有一个SpringBoot应用程序。我有一个专用的服务器，在这里我将通过HTTP请求读取数据。我为模块配置了http-outbound config.xml文件。当我运行以下代码时，所有内容都是精细
http-outbound-config.xml
<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
xmlns:xsi="http://www.w3.org/2001/XM
浏览 2提问于2020-12-02得票数 0
回答已采纳
这是I need current easy to follow instructions for configuring spring integration kafka from XML的后续问题 Spring-integration-kafka在过去的几次迭代中发展了很多，许多旧的例子不再起作用。 特别是，这个从spring-batch世界到spring集成世界的bean将不会实例化，因为KafkaTemplate类没有实现MessagingTemplate。当前推荐的完成此集成的方式是什么？ <bean id="partitionHandler" class=&#
浏览 57提问于2019-03-21得票数 0
回答已采纳
1回答
我有一个流，它从目录读取csv文件，拆分行，然后处理每一行并从每一行提取2个对象。然后将这两个对象发送到两个独立的int-mongodb:outbound-channel-adapter。在处理和保存所有行之后，我希望删除传入的文件。我看过使用事务管理器对入站适配器执行此操作的示例，但没有使用出站适配器。有办法这样做吗？
我的配置如下所示：
<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans
浏览 2提问于2015-06-11得票数 2
回答已采纳
1回答
我是春季integration.So的新手，如果我问的是一些普通的东西，请原谅我。我确实有一个简单的用例。我已经配置了ftp入站通道适配器如下。使用它，我可以在本地目录中提取远程检查文件。I.E.D:/出站。现在，我想轮询本地目录，即i.e.D:/Outbound，以添加进一步的业务逻辑。即根据检查文件状态从远程下载原始文件，并将相关的检查文件移动到其他目录位置。我该怎么做？任何示例快速代码或参考指南/链接将不胜感激。
<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="ht
浏览 4提问于2015-12-02得票数 3
回答已采纳
我有一个将byte[]有效负载转换为MyClass有效负载的处理器：
@Slf4j
@EnableBinding(Processor.class)
public class MyDecoder {
@ServiceActivator(inputChannel = Processor.INPUT, outputChannel = Processor.OUTPUT)
public MyClass decode(final byte[] payload) {
MyClass decoded = doStuff(payload);
if (decode
浏览 123提问于2017-01-21得票数 2
回答已采纳
我正在尝试使用Spring Integration和一个HTTP出站网关来组合一个非常简单的http POST示例。
我需要能够发送带有一些POST参数的HTTP POST消息，就像使用curl一样
$ curl -d 'fName=Fred&sName=Bloggs' http://localhost
如果我向接口方法发送一个简单的String作为参数，我就可以让它工作(没有POST参数)，但我需要发送一个pojo，其中pojo的每个属性都会变成一个POST参数。
我有以下SI配置：
<?xml version="1.0" encoding=&#
浏览 0提问于2015-05-28得票数 2
回答已采纳
我正在开发Spring Integration来调用SOAP服务。无论如何，我能够通过出站网关调用SOAP服务，并且我正在接收响应。但是现在我需要调用一个安全的SOAP服务。如何使用Spring Integration调用它。在这个问题上，有人能帮我吗？提前谢谢你。
浏览 0提问于2014-12-24得票数 0
2回答
用于记录出站Http请求的
、、、、
我查看了2014年关于使用Spring记录HTTP请求/答复的帖子：
为此，我尝试了这个AOP配置：
<aop:config >
<aop:aspect id="myAspect" ref="inboundOutboundHttpLogging">
<aop:pointcut id="handleRequestMessageMethod"
expression="execution(* org.springframework.integra
浏览 17提问于2022-09-06得票数 0
回答已采纳
我正在尝试使用Kafka作为中间件来实现远程分区，并获得异常。就从这个主题开始，开始只在master上工作，一旦master完成后面临问题将在worker端代码上工作。
下面是异常的堆栈跟踪
2020-10-16 00:27:48.640 INFO 13716 --- [ main] o.a.kafka.common.utils.AppInfoParser : Kafka version: 2.5.0
2020-10-16 00:27:48.641 INFO 13716 --- [ main] o.a.kafka.common.utils.A
浏览 0提问于2020-10-16得票数 0
当我使用Mule中的soap组件调用soap服务时。消息属性上下文丢失。我知道可以使用Mule -她的组件--但不能确定它的用法。下面你会发现我的测试骡子代码
<spring:beans>
<spring:bean id="myWebServiceImpl" class="com.xxx.xxx.service.MyWebServiceImpl">
</spring:bean>
</spring:beans>
<custom-transformer class="com.xxx.xxx.serv
浏览 1提问于2014-02-27得票数 0
回答已采纳
使用中描述的相同设置，我无法从后端API获得响应，目标是通过HTTP上传文件并将其存储在MongoDB中，必要时通过带有特定http头的get调用检索文件(这很有效)。
服务激活器中的方法返回相同的请求消息.将返回类型从文档更改为包含有效负载中的文档的消息，但它不会产生不同的行为，基本上文件保存在MongoDB中( http调用成功了)，但是没有将响应发送到前端。
另一方面，使用纯XML，我不知道如何从UploadedMultiPartFile中提取文件并将其转发到后端API (请参阅下面的另一个设置)。
public Document uploadFile(Message inMessage
浏览 1提问于2014-08-11得票数 0
回答已采纳
1回答
我知道如何使用以下配置从SFTP位置读取和写入spring-integration-sftp：
<bean id="sftpSessionFactory"
class="org.springframework.integration.sftp.session.DefaultSftpSessionFactory"
p:host="${host}"
p:port="${port}"
p:user="${username}"
p:password="${passwor
浏览 6提问于2016-03-11得票数 0
回答已采纳
1回答
我尝试使用Spring集成作为一个简单的中介器。我们有一个We应用程序驻留在intranet上，无法从外部访问。现在，我想通过DMZ中的一个中介者公开这个应用程序。这仅仅意味着所有像*这样的url都应该转发到*。理论上非常简单，但似乎Spring integration (HttpRequestExecutingMessageHandler)中处理传出http请求的组件需要一个明确的URI，即没有通配符匹配。这可以通过Spring集成来实现吗？
浏览 2提问于2015-07-14得票数 1
我正在尝试将下面的spring集成示例转换为Java版本。
我们需要稍微修改这个项目的版本才能在生产环境中工作。我的问题是，在启动应用程序时，我一直会得到以下异常。
org.springframework.beans.factory.BeanCreationException: Error creating bean with name 'httpInboundGateway' defined in org.springframework.platform.proxy.TunnelApplication: Bean instantiation via factory metho
浏览 3提问于2017-02-06得票数 0
回答已采纳
spring集成，在出站网关中想要使用URL作为动态的，例如
<bean id="requestValues" class="com.src.model.RequestValues"/>
<int-http:outbound-gateway
request-channel="reqChannel" url="${UrlValue}"
http-method="${reqmethod}" expected-resp
浏览 4提问于2017-10-03得票数 2
回答已采纳
我想把我的xml配置转换成Java类配置，但是我找不到解决方案。例如，我的一段配置：
<file:inbound-channel-adapter id="filesIn" directory="file:${java.io.tmpdir}/spring-integration-samples/input"
filename-regex="^.*\.(xml|json)$" >
<int:poller id="poller" fixed-delay
浏览 5提问于2017-07-17得票数 2
回答已采纳
我希望使用hystrix命令将对出站网关的调用包装在我的集成应用程序中，类似于Spring引导应用程序中的可用方式。
<int-http:outbound-gateway id="outbound.gateway"
request-channel="get.request.channel" url="http://localhost:9090/profileapplication"
http-method="GET" charset='UTF-8' reply-channel="rep
浏览 1提问于2018-04-12得票数 1
我尝试搜索tcp入站适配器的spring集成集群，但找不到解决方案。有人可以在集群spring-integration tcp入站适配器和这里寻找负载平衡方面提供帮助吗？
浏览 15提问于2016-09-19得票数 1
回答已采纳
1回答
我需要从所有目录中获取所有文件，并且我想在command = "mget"中使用command = "mget"(当然是带有过滤器)。
样本代码
<beans xmlns="http://www.springframework.org/schema/beans"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:int="http://www.springframework.org/schema/integration"
x
浏览 0提问于2015-12-16得票数 1
回答已采纳
尝试将消息发布到spring bean的init-method中的通道时，出现'Dispatcher has no subscribers‘错误。请看下面的示例：
applicationContext.xml
<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance
浏览 0提问于2012-06-21得票数 5
回答已采纳
我是Spring集成的新手。
我们有一个REST应用程序，它接收的消息太多(每分钟6000条消息)，超出了数据库的处理能力。因此，我希望将请求速率限制为每15秒500条消息(每分钟2000条)。我使用队列通道来实现这一点。
过了一段时间，应用程序正在创建30,000+ Java线程。此外，队列通道容纳的消息比队列容量中提到的更多。
如何减少线程数，限制队列中的消息数量？
集成上下文xml：
<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springfram
浏览 0提问于2018-06-26得票数 0
云服务器
ICP备案
对象存储
即时通信 IM
实时音视频
腾讯云开发者
