java - Spring集成-recipientlistrouter-并行处理

Question

如何在 spring-integration 中与收件人列表路由器实现并行处理。

我的目标是路由器必须基于内容，并像多播一样将消息发送到并行处理的各个 channel 。我尝试使用camel-spring-integration在Camel中进行多播，但无法将其配置为基于内容

如果有什么办法请帮忙

谢谢

Answer 1

如果我理解问题正确，您只需使用发布订阅 channel 作为路由器的输出 channel 即可。路由器会根据内容将消息定向到正确的 pubsub channel ，然后订阅该 channel 的所有处理程序将并行执行，假设输出 channel 任务执行器配置为具有多个线程。

<int:publish-subscribe-channel id="channel1" task-executor="someExecutor"/>
<int:publish-subscribe-channel id="channel2" task-executor="someExecutor"/>

<int:recipient-list-router id="customRouter" input-channel="routingChannel">
    <int:recipient channel="channel1" selector-expression="payload.equals('foo')"/>   
    <int:recipient channel="channel2" selector-expression="headers.containsKey('bar')"/>
</int:recipient-list-router>

上述收件人列表路由器配置复制自 Spring Integration 引用手册的 5.1 节。