spring集成以并发方式处理消息

Question

我正在尝试使用spring integration设置我的应用程序，作为一名新手，需要以下用例的建议-

有一个队列，来自另一个应用程序的消息将被推送到该队列。我的应用程序使用队列中的消息，进行一些数据处理，然后将其推送到另一个出站队列。目标是以并发方式处理消息。

根据我的理解，我们可以有两种方法-

1.使用#轮询器

<int:service-activator ref="messageProcessor" method="process" input-channel="incomingChannel">
    <int:poller fixed-rate="100" task-executor="executor" />
<int:service-activator/>
<task:executor id="executor" pool-size="10"/>

2.使用#调度器

<int:channel id="incomingChannel">
    <int:dispatcher task-executor="executor"/>
</int:channel>
<int:service-activator ref="messageProcessor" method="process" input-channel="incomingChannel" />

<task:executor id="executor" pool-size="10"/>

从基于轮询器的配置来看，池中似乎有多个可用线程，可以同时获取消息和处理消息。这里的担忧是-

i）轮询器将不必要地在后台运行（资源命中）。

ii）即使消息在信道上，也会根据固定速率浪费毫秒（因为轮询器将在每100秒后获取消息）。

基于调度器的配置似乎是消息驱动的，可能非常适合我的用例。如果我错了，请纠正我，在这种情况下，线程只负责将消息分派给订阅者。

如果是那样的话-

是否需要与通道关联多个服务激活器？

有没有办法动态附加相同服务激活器配置的多个实例？

建议我什么是处理这个问题的最佳方法。谢谢

Answer 1

（i） 投票非常轻量级；即使使用固定速率0，线程也会在通道中阻塞1秒（默认情况下-接收超时）；我甚至怀疑你会测量空闲轮询器使用的cpu。

（ii）参见（i）-减少轮询间隔将缓解任何等待时间。

在任何情况下，如果您谈论的是JMS，您可能都不想使用这两种方法——如果您希望出站发送参与与入站消息相同的事务（即，只有在发送成功时才提交删除），则不得将其转移到另一个线程——如果您这样做，此时将立即执行消息删除。

相反，使用消息驱动的通道适配器，并使用其并发设置来增加线程数量；然后在整个过程中使用直接通道。