Spring Integration -用于SQS消息的异步服务激活器
Spring Integration是一个用于构建企业级集成解决方案的开源框架。它提供了一种简单而强大的方式来实现不同系统之间的消息传递和通信。在云计算领域中，Spring Integration可以用于激活SQS（Simple Queue Service）消息的异步服务。
SQS是亚马逊AWS提供的一种完全托管的消息队列服务，它可以在分布式系统中传递、存储和接收消息。通过使用Spring Integration的异步服务激活器，我们可以轻松地将SQS与我们的应用程序集成起来。
Spring Integration提供了SQS消息的异步服务激活器，它可以监听SQS队列中的消息，并在接收到消息时触发相应的服务。这使得我们可以实现基于消息的异步处理，提高系统的可伸缩性和可靠性。
优势：
- 异步处理：通过使用Spring Integration的异步服务激活器，我们可以实现基于消息的异步处理，提高系统的性能和响应能力。
- 可靠性：SQS作为一种托管的消息队列服务，具有高可用性和可靠性，可以确保消息的可靠传递。
- 简化集成：Spring Integration提供了丰富的集成组件和模式，可以简化与SQS的集成过程，减少开发工作量。
应用场景：
- 异步任务处理：可以将耗时的任务放入SQS队列中，通过异步服务激活器进行处理，提高系统的并发能力。
- 解耦系统：通过将不同系统之间的通信通过SQS消息队列进行解耦，提高系统的灵活性和可维护性。
- 弹性扩展：通过将消息队列与自动伸缩功能结合使用，可以实现系统的弹性扩展，根据负载情况自动增加或减少实例数量。
推荐的腾讯云相关产品： 腾讯云提供了一系列与消息队列相关的产品，可以与Spring Integration进行集成，实现异步消息处理的需求。以下是一些推荐的腾讯云产品：
- 云消息队列 CMQ（Cloud Message Queue）：腾讯云提供的高可用、高可靠的消息队列服务，可以与Spring Integration进行集成。官方链接：https://cloud.tencent.com/product/cmq
- 弹性消息队列 TDMQ（Tencent Distributed Message Queue）：腾讯云提供的分布式消息队列服务，具有高吞吐量和低延迟的特点，适用于大规模的消息处理场景。官方链接：https://cloud.tencent.com/product/tdmq
通过使用腾讯云的消息队列产品，结合Spring Integration的异步服务激活器，可以构建高性能、可靠的消息处理系统。
相关·内容
我有以下几点：
[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
回答已采纳
我有许多SQS队列，我必须附加workers来使用和处理消息(使用spring integration flow)。我最初的想法是有一个spring boot应用程序，每个SQS队列(spring integration aws)有一个通道。
这就像1 SQS -> 1 Channel -> 1 Flow
然而，这可能会涉及到maintainability、deployment、memory问题，我们将无法独立地扩展每个工作人员。听起来像monolith of workers。另一种选择是为每个spring cloud function类型创建一个worker，并将它们部署为lam
浏览 0提问于2020-11-24得票数 0
回答已采纳
我正在寻找一个Spring应用程序的工作示例，该应用程序使用Spring Integration + Amazon SQS服务接收和发送消息到队列。
浏览 23提问于2019-03-29得票数 2
回答已采纳
1回答
我想实现spring-integration-aws来使用SQS发送和接收消息。我正在查看本地堆栈，并想知道春季团队的推荐。
对于SQS入站和出站适配器的春季集成流的本地设置，我应该使用哪个工具/api？
此外，在春季集成样本中还会有AWS的例子吗？我正在寻找一个xml配置示例，它从凭据中读取aws配置，并通过出站适配器发送和接收消息。
浏览 5提问于2020-08-16得票数 1
回答已采纳
我正在使用Artemis ActiveMQ来处理我的应用程序的内部异步进程。
所有的连接逻辑都由Spring Integration处理。
我在artemis服务器上遇到了磁盘空间不足的情况。这导致artmeis服务器在没有任何警告的情况下阻止了我的消息生成器(除了artemis服务器日志中的警告)。但是，它可以是任何其他阻塞场景。
应用程序继续生成消息，而没有意识到消息没有写入队列。
如何才能通知我的应用程序(生产者)关于这样的基础设施问题，这样我就可以抛出异常或记录错误，这将在我的应用程序端可见。
浏览 4提问于2018-04-25得票数 1
我是春季集成的新手，目前还在测试我的集成流程。我的流量看起来就像这样。
format.Convert 从TCP通道适配器收到一些数据，在XML 中将其发送到JSON。将JSON消息发送到amazon .。
XML文件是：
<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instanc
浏览 3提问于2021-09-13得票数 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回答
我在试着理解这两者之间的区别？
这实际上是Spring Integration中的两个不同的元素/构建块吗？路由器与消息端点有何不同？消息路由器是由消息通道和消息端点组成的吗？
请各位专家分享您对此的看法？
浏览 3提问于2021-01-11得票数 0
目前，我有一个工作的spring集成项目，它将消息发送到ActiveMQ的队列的一个实例。在处理程序为JMSSendingMessageHandler.java的情况下，它使用serviceActivator作为端点。模型如下所示：
客户端->请求通道->Service Activator(Endpoint)。
但是现在我想要向多个ActiveMQ实例发送消息，这些实例将在配置文件中进行配置。在spring Integration中，没有现成的解决方案可用。
我的需求示意图如下：
我需要找出，如何在运行时创建多个服务激活器。
浏览 1提问于2017-03-03得票数 1
1回答
Spring异常
、、、
我使用出站通道适配器将有效负载发布到SQS。我遇到了一些依赖问题。我得到了例外：
Exception in thread "main" org.springframework.beans.factory.BeanCreationException: Error creating bean with name 'org.springframework.integration.aws.outbound.SqsMessageHandler#0': Bean instantiation via constructor failed; nested exception i
浏览 3提问于2018-01-05得票数 0
回答已采纳
我正在尝试启动一个spring-int-aws流，该流正在写入SQS队列，但是上下文不会加载。
Error starting ApplicationContext. To display the auto-configuration report
re-run your application with 'debug' enabled.
2016-10-03 14:10:51.848 ERROR 3741 --- [ main]
o.s.boot.SpringApplication : Application start
浏览 0提问于2016-10-04得票数 1
我正在发送有关主题的消息，并且可以使用kafka控制台和Java消费者代码使用main方法读取相同的消息。但是消息并没有从使用者配置xml中读取。请帮助解决这个问题。我正在使用消息int-kafka:消息驱动-通道适配器。春季-卡夫卡1.3.0版
<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
xmlns:xsi="http://ww
浏览 2提问于2015-12-26得票数 1
回答已采纳
是spring-integration-aws项目。它们提供了有关入站Channle适配器的示例：
@SpringBootApplication
public static class MyConfiguration {
@Autowired
private AmazonSQSAsync amazonSqs;
@Bean
public PollableChannel inputChannel() {
return new QueueChannel();
}
@Bean
public MessageProducer s
浏览 3提问于2017-05-02得票数 3
回答已采纳
需要帮助
我需要创建多个并行执行的sqs队列使用者，但我不知道如何使用实现这一点
我有以下的架构
包含200 k消息的Amazon队列
一个包含5个EC2实例的Amazon堆栈，每个带有tomcat服务器的实例都运行一个Spring引导应用程序，其中包含一个Spring流，它使用SQS -消息驱动-通道适配器()来使用sqs的消息。
并将消息发布到具有1秒平均响应的REST服务(我无法修改REST服务，但可以并行发送消息)。
SQS队列->堆栈(5个tomcat实例) -> Rest服务
约束 Amazon允许客户机按请求读取最多10条消息的批处理消息，但我可以让多个客户端并行地使
浏览 0提问于2018-04-12得票数 3
2回答
我有一个基于EC2的REST web服务，它通过SQS连接到一组工作者实例。我希望用代替当前的设置，保留(暂时) SQS作为代理。
然而，我不确定我对芹菜如何运作的想法是相当准确的。按照文章中似乎隐含的模式，我的理解是，我可以将来自API的消息排队到SQS，然后这些消息将由芹菜工人及时处理。然而，我发现的例子(几乎没有一个涉及使用SQS作为代理)似乎表明芹菜本身就是排队的。因此，芹菜就像队列的“包装器”，用于提交和处理任务。它既是制片人又是消费者，对吗？如果是这样的话，这对我来说是个大问题，因为我不使用Python。工作人员自己将使用execl()来运行实际任务，但是如何处理从API服务器向队
浏览 4提问于2014-01-08得票数 3
2回答
在spring集成中，我尝试创建一个具有自定义范围的Direct消息通道，如下所示
...
<int:channel id="myChannel" scope="validCustomScope" />
<int:service-activator ref="validSericeReference_WithSameValidCustomScope" method="handleMessage" input-channel="myChannel"/>
...
但是，我遇到了一
浏览 2提问于2014-03-15得票数 3
2回答
我已经使用入站通道适配器实现了一个轮询器，代码工作得很好，但是它抛出了这个我无法解决的特殊异常
11:43:27.664 [main] DEBUG o.s.i.u.MessagingMethodInvokerHelper - Method [public void com.ms.aps.fsmessaging.alert.QueryServiceActivator.getMessageProcessStatus(byte[],com.ms.aps.fsmessaging.alert.types.MessageType,java.lang.String) throws java.lang.Exc
浏览 1提问于2013-02-15得票数 0
我有一个运行Spring Integration inbound-channel-adapter的Grails webapp，它被配置为接收电子邮件，并且有一个处理消息的服务激活器。此服务激活器根据业务规则提取电子邮件的各个部分，然后需要更新Grails域对象并将这些更改保存到数据库中。
Spring Integration服务激活器代码片段：
HashMap<String, Serializable> params = new HashMap<String, Serializable>();
params.put("notification", not
浏览 0提问于2012-08-14得票数 0
回答已采纳
1回答
希望这是一个简单的问题--有人有幸将Spring Integration与Amazon SQS结合使用吗？我参与了这个项目..。
..。但几个小时后，我所能得到的是以下错误：-
src-resolve: Cannot resolve the name 'integration:channelAdapterType' to a(n) 'type definition' component.
注意:我使用的是Spring和Spring集成的以下版本...
<spring.version>3.2.1.RELEASE</spring.version&
浏览 4提问于2013-12-21得票数 2
1回答
修复了任务执行器的延迟
、、、、
我的项目有一个-spring集成固定延迟轮询器(5分钟)其获得一串记录-将其发送到拆分器，拆分器将记录拆分并在输出通道将它们发送到池大小为2的任务执行器路由器通道，并且发送每个记录以便在服务激活器处进一步处理并在聚合器处接收。流程运行得很好。
然而，固定延迟是将先前的执行时间视为将记录提交给任务执行器的时间，而不是所有记录处理完成并在聚合器通道接收到的时间。
如何让轮询器在所有记录处理完成后等待5分钟，而不是在拆分器通道上等待5分钟？
配置：
使用spring集成2.2.0.RELEASE和spring 3.1.1.RELEASE版本
<integration:channel id=&#
浏览 6提问于2015-06-06得票数 1
1回答
我使用Amazon SQS作为消息队列。我正在研究如何在Tomcat中设置一个使用消息的Spring消费者。然而，我环顾四周，似乎说要部署Spring Message Driven Bean来消费Tomcat中队列中的消息，我需要TomcatEE / Tomcat + ActiveMQ。
同时，我还回顾了下面的SQS-Spring驱动程序，不知道它是否有很多用处。
有人能告诉我完成上述任务需要做些什么吗？
浏览 1提问于2014-05-05得票数 2
我有一个int-aws:sqs-message-driven-channel-adapter，如果设置errorChannel，下游的异常就会出现。
但是，当我不设置errorChannel时，异常不会被记录。它不属于预期的errorChannel。有没有办法，这样的异常至少会被记录下来？是否存在可以简单记录此类错误的默认errorlogger？
更新
按照注释发布XML和DSL配置。在持久化层中通过为error上的@NotBlank字段设置null来模拟ServiceObject。
<?xml version="1.0" encoding="UTF-8"
浏览 2提问于2021-04-21得票数 1
回答已采纳
当AWS SQS服务接收到消息时，我需要触发代理API。我看了几篇文章，发现API到SQS是可能的，但是没有找到任何与SQS触发API网关有关的东西。有人能指点一下吗。
浏览 2提问于2021-01-05得票数 4
回答已采纳
我正在使用amazon sqs队列异步使用消息。我已经开始使用amazon sqs JMS api的消息，所以我已经实现了MessageListener，一旦消息到达onMessage方法，我就开始做我的工作。由于amazon sqs是根据对服务器的请求进行收费的，因此我想将轮询间隔限制为1分钟，或者可能更长，因为我不需要立即发送消息。
我在那里，无论如何，我们可以在JMS中配置轮询间隔，或者我应该使用amazon sqs API来自己处理。
谢谢
浏览 1提问于2015-04-16得票数 4
我们在生产中有一个弹簧应用程序，它似乎是在泄漏线程。
当我做线程转储时，我看到下面的线程似乎在等待。下面是一个例子，但是有成千上万的例子
"SimpleAsyncTaskExecutor-1801" prio=10 tid=0x00007fa668413800 nid=0x376c waiting on condition [0x00007fa4fbaff000]
java.lang.Thread.State: WAITING (parking)
at sun.misc.Unsafe.park(Native Method)
- pa
浏览 5提问于2014-09-05得票数 1
回答已采纳
我有一个Node.js项目，它使用AWS (消息队列)上的消息。我希望在同一个项目中设置多个使用者，以跟上队列中的消息，而不必创建另一个Node.js实例。是否可以用类似于光纤或其他框架的东西来实现这一点呢？我基本上是想让接收消息的动作变成多线程(竞争消费者模式)。
下面是一个例子：
var AWS = require('aws-sdk'),
nconf = require('nconf'),
SQS_URL = process.env.SQS_SERVICES_EVENTS;
AWS.config.update({accessKeyId: n
浏览 2提问于2015-05-01得票数 1
回答已采纳
1回答
在计票器从DB获取数据后，我将调用外部服务。在从该服务获得响应后，我想在一个单独的线程中调用另一个系统。这意味着，在得到响应后，我的计票程序应该再进行一次记录，并且send.In加法调用其他系统应该并行地工作。
为此，我使用了一个直接通道来接收来自DB的数据。使用服务激活器向外部服务发送请求。响应被传递给一个执行者channel.can，请告诉我下面的配置对于这个场景是否正确？
为了清晰起见，我共享poller.xml
<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http
浏览 1提问于2015-11-26得票数 0
回答已采纳
1回答
我需要复制/复制Sftp服务器中的远程文件，复制时也要重命名，我看到中不支持在Sftp中复制远程文件，所以我唯一可用的选项是将GET文件放入本地文件，然后将再次放置到Sftp并删除本地文件，我已经成功实现了目标，但问题是，有一个来自org.springframework.core.log.LogAccessor:的日志打印，我不知道它是从哪里来的。
有助于复制远程文件的代码：
@Bean
public IntegrationFlow copyRemoteFile() {
return IntegrationFlows.from("integration.channel.cop
浏览 10提问于2021-02-16得票数 1
1回答
有人在使用Vaadin @Push和Vaadin4Spring安全扩展吗？
下面是与我们的项目相关的Vaadin依赖关系：
compile 'com.vaadin:vaadin-client-compiled:7.5.8'
compile 'com.vaadin:vaadin-client:7.5.8'
compile 'com.vaadin:vaadin-themes:7.5.8'
compile 'com.vaadin:vaadin-server:7.5.8'
compile 'com.vaadin
浏览 8提问于2016-02-21得票数 1
回答已采纳
我需要从源目录中读取文件并按顺序(一个接一个)处理。
我有以下应用程序上下文配置，
<?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:int="http://www.springframework.org/schema/integrat
浏览 10提问于2017-02-21得票数 0
回答已采纳
2回答
我正在使用下面的配置来集成activemq和kafka。我收到了activemq的消息，并把它转发给了kafka。但是，我注意到消息正在从JMS队列中退出队列，但是消息不会传递给kafka。
<?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:j
浏览 1提问于2017-07-08得票数 1
回答已采纳
1回答
我是Spring集成的新手，也是堆栈溢出的新手。我正在寻找一些帮助了解Spring集成，因为它涉及到请求-应答模式。从网上阅读，我认为我应该使用服务激活器来启用这种类型的用例。
我正在使用JMS来帮助发送和接收基于XML的消息。我们的下划线实现是IBM。
我还使用Spring (版本1.3.6.RELEASE)，并尝试使用一种基于纯注释的配置方法(如果可能的话)。我已经搜索了网络，看到了一些例子，但到目前为止，我所能看到的任何东西都没有帮助我理解它们是如何结合在一起的。Spring文档非常优秀，但我仍然在努力解决如何将所有的部分集成在一起的问题。如果有什么东西我错过了，我会提前道歉。我把在这里
浏览 0提问于2016-07-20得票数 1
回答已采纳
Spring中SimpleMessageListenerContainer类的当前实现(1.0.0.RC2)似乎是在消息处理程序完成消息处理和方法调用返回之后自动删除消息。
在我们的应用程序中，我们需要能够处理消息并等待下游队列的异步确认，然后才能从SQS上游队列中删除消息。有点像
接收SQS ->进程msg ->将msg发布到RabbitMQ (线程在这里完成)
删除SQS <-我们的应用程序<- RabbitMQ msg成功Ack (异步)
当msg通过不同的线程异步返回时，我们需要手动删除SQS中的msg的选项。
理想情况下，SimpleMessageListen
浏览 0提问于2015-02-07得票数 5
我有一个关于spring-messaging (spring集成+ amqp)与RabbitMQ的问题。我有一个基于微服务架构的应用程序。一条服务发布消息，方式如下：
@EventListener(AfterCreationEvent.class)
@Publisher(channel = "messages")
public Message<Message> onCreateEntity(AfterCreationEvent<Message> event) {
if (isDisabled()) return null;
String
浏览 0提问于2017-04-09得票数 1
请参阅链接：
我正在做类似的配置，但不确定如何将行映射器与拆分器一起使用。
我正在尝试创建一个db-poller，并希望使用row-mapper在service-activator中接收传入的行，但消息无法到达那里。
这是我的配置。请给我建议。
我的配置：
<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans" xmlns:xsi="http://www.w3.org/2001/
浏览 2提问于2014-04-21得票数 0
我有一个lambda函数负责检查服务器状态。它需要在SQS接收到新消息时调用，并且不允许在SQS中更改任何内容。我尝试使用SQS Lambda触发器，但它会将消息推入更改了SQS队列的lambda函数=>。
我正在寻找解决这个问题的方法。我尝试使用CloudWatch来处理这个问题，但是我不知道这是否可行？当SQS收到新消息时，Cloudwatch如何触发Lambda函数？
提前谢谢。
浏览 2提问于2019-06-24得票数 0
我已经将lambda集成设置为SQS，它具有固定的保留并发性，以将请求传递到后端服务。我需要使用DLQ来跟踪和存储错误。
使用SQS的重驱动策略与lambda函数的DeadLetterConfig在行为上有什么不同？
当队列中有大量消息但具有有限的lambda并发性时，我对这种行为特别感兴趣。
浏览 0提问于2020-07-28得票数 1
回答已采纳
2回答
Spring集成-消费者手册确认
、、、、
我正在用Spring-AMQP支持Spring-Integration进行测试，下面是配置和测试：
<rabbit:connection-factory id="connectionFactory" />
<rabbit:queue name="durableQ"/>
<int:channel id="consumingChannel">
<int:queue capacity="2"/> <!-- Message get Acked as-soon-as filled
浏览 4提问于2014-01-10得票数 4
回答已采纳
流动：
使用发布子channelAggregate发布结果将Ingestion队列发布到Queue One和'Queue 2‘并行地从Ingestion队列发布到Queue One和Queue Two中的任何一个失败，将异常抛给SqsMessageDrivenAdapter以触发NO_REDRIVE行为。Ingestion-Dead-Letter队列重新驱动maxReceiveCount=3，该消息的发布将被DLQ发送到maxReceiveCount=3
在第4步之前，一切都按预期进行。但是，在步骤4中，如果不存在Queue One，则聚合器将完成，但异常不会抛出给SqsMessage
浏览 3提问于2021-06-04得票数 1
1回答
我正在编写一个应用程序，它使用lambda函数向spring引导应用程序发送请求，该应用程序将调用其他服务。我必须使用sqs (必需)。因此，sqs在lambda和spring之间。问题是我的spring应用程序如何知道sqs中是否有新消息。
我听说过长时间的集合，但我不知道这是否是我所需要的。
我需要设置一个永远打开长池的循环吗？
有效率吗？我的意思是，如果sqs中有10条消息，连接会被打开10次吗？
我发现这里使用here循环：
谢谢
浏览 0提问于2019-07-05得票数 1
回答已采纳
我使用的是Spring Integration 5.1.5 (使用spring-integration-amqp的RabbitMQ )，我在docs中读到Spring Integration支持project reactor类型(这里我指的是Mono、Flux等)。但是我不能让这个在ServiceActivator上工作。我尝试这样做： @ServiceActivator
public Mono<Void> myMethod(List<Message> messages) {
Mono<Void> result = myService.doServi
浏览 49提问于2019-05-27得票数 1
回答已采纳
1回答
在服务的入口点(从SQS轮询项的类)中有一个try/catch/finally块。
我希望捕捉服务中抛出的每一个异常并将其抛出，这样SQS就可以重新驱动它。
但是，这也会导致spring引导容器将堆栈跟踪打印到控制台，然后控制台将其记录到我的日志聚合器中。
我已经有了一个有意义的日志记录，它为每个使用MDC的日志消息添加了重要的元数据，因此我想在记录异常时使用它。
这是我的密码：
@SqsListener(value = "${src.queue.name}", deletionPolicy = SqsMessageDeletionPolicy.NO_REDRIVE)
publ
浏览 0提问于2022-02-05得票数 0
回答已采纳
我创建了一个新的示例，并将代码转移到客户端和服务器端。
完整的代码可以找到。
服务器端有3种版本。
服务器无Spring应用程序，使用Spring InboundGateway。
服务器-引导重用Spring RSocket自动配置，并通过ServerRSocketMessageHanlder创建ServerRSocketConnecter。
server-boot-messsagemapping不使用Spring，只使用Spring自动配置，以及@Controller和@MessageMapping。
有两个版本的客户端。
客户端，使用发送消息。
client-r
浏览 0提问于2020-02-29得票数 1
回答已采纳
1回答
我继承了一个包含许多组件的应用程序(而且我对Spring集成并不十分熟悉)。它是一个eCommerce应用程序，具有产品、股票、价格等方面的集成。
这个问题最常见于(大型) ProductFeed，它以几乎2000条单独的JMS消息进入系统，这些消息被分组(correlationId)，并在从Apache服务器检索后按正确的顺序重新排序。这样做是为了在其他对象之前将依赖对象保存到DB中。来自产品信息系统的出口结构的结果。但在价格等其他消息来源中也可以看到这一点。
我们有3个管理服务器/JVM，具有相同的spring配置。有一个问题，有时Product会在提要中2000条消息的1或2条消息之后随
浏览 7提问于2017-02-01得票数 0
在入站网关接收到字符串消息后，我使用发布-订阅通道将其并行发送到记录器以记录消息，并发送到转换器以转换消息。我希望这两个活动并行进行。
我的问题很简单- spring集成中的发布订阅通道是否并行地向其子用户发送消息？
下面是spring-integration-context.xml源代码中的代码片段。
<int:gateway id="gateway" service-interface="com.test.Gateway">
</int:gateway>
<int:publish-subscribe-channel id
浏览 1提问于2013-09-03得票数 3
我有一个现有的spring-boot服务(托管许多apis)，主类如下。
@SpringBootApplication
public class BusinessRules {
public static void main(String[] args) {
SpringApplication.run(BusinessRules.class, args);
}
}
作为一个新需求，我需要在同一服务内的不同线程中(通过无限循环)使用来自两个不同SQS队列的SQS消息。我可以简单地添加新的两个新线程使用ExecutorService。如下所示：
@SpringBo
浏览 60提问于2020-05-21得票数 0
我已经开发了一个通过教程编写的代码，其中我将从特定位置轮询文件并进一步处理它们。为了轮询的目的，我使用了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
我正在使用Spring Cloud SQS消息传递来监听指定的队列。因此使用@SqsListener注解如下：
@SqsListener(value = "${QUEUE}", deletionPolicy = SqsMessageDeletionPolicy.ALWAYS )
public void receive(@Headers Map<String, String> header, @Payload String message) {
try {
logger.logInfo("Message
浏览 35提问于2018-02-28得票数 3
我有一个基于的应用程序，该应用程序的一部分具有以下配置。
upgrade在4.3.10.RELEASE版本中运行良好，但现在我正试图将版本升级到5.1.5.RELEASE，并且应用程序无法从下面提到的例外开始。
我能够解决更改配置的问题，但我想知道为什么要更改这个配置。
在4.3.10中工作的旧配置：
@Bean
public IntegrationFlow mainFlow(@Qualifier("initChannel") PublishSubscribeChannel inboundChannel, TaskExecutor taskExecutor,
浏览 4提问于2020-09-21得票数 0
回答已采纳
我在这个网站上读到了另一个像这样的问题，但我不知道如何解决这个问题。
我的错误类似于前面的链接。
SimpleAsyncTaskExecutor-2327" - Thread t@2405
java.lang.Thread.State: WAITING
at sun.misc.Unsafe.park(Native Method)
- parking to wait for <7a224c1> (a java.util.concurrent.CountDownLatch$Sync)
at java.util.concurrent.locks.Lock
浏览 0提问于2019-03-14得票数 0
云服务器
ICP备案
实时音视频
对象存储
即时通信 IM
腾讯云开发者
