Spring Integration DSL 中的路由

Question

我正在使用以下 IntegrationFlow 表单，其中我通过以下方式通过标头值过滤我的主题消息：

IntegrationFlows.from ( 
Jms.messageDrivenChannelAdapter (  Jms.container(factory, connection)
.messageSelector("X-HEADER = 'X_VALUE'")
.get() 
)
.get()
)
.handle(XMessageHandler)
.get();

..或其中之一

IntegrationFlows.from ( 
Jms.messageDrivenChannelAdapter (  Jms.container(factory, connection)
.get() 
)
.get()
)
.filter(Message.class, filterByHeaderPropertySelector(X_HEADER, X_VALUE)
.handle(XMessageHandler)
.get();

但是现在，一种新的预期流类型加入了主题，因此鉴别器标头具有新的值 Y。因此，filter(Message.class, filterByHeaderPropertySelector(Y_HEADER, Y_VALUE)一个新的过滤器，目标为YMessageHandler.

我的问题是，我怎样才能以最小的影响重用基础设施。最好将过滤器与路由一起使用，但route操作似乎不是以相同的方式内联的。也许有更简单/明显的方法？

另外，我应该为每个消息选择器复制适配器吗？将消息选择器放在容器设置中或将其作为集成流的一部分有什么区别。是否有任何性能影响，或者集成构建器是否巧妙地对其进行了优化？我的意思是，很可能将选择器放在流上并不能避免解析消息等，而在容器的定义上，它只是从头开始过滤它。解决这个问题的最佳方法是什么？

Answer 1

当然，最好的解决方案是容器上的选择器。这样，消息过滤就在代理上完成。

无论如何，您还必须查看Router，并查阅当前值的标题以选择合适的下游通道。

过滤器是一种二进制路由器，但无论如何最好使用路由器实现逻辑：https://github.com/spring-projects/spring-integration-java-dsl/wiki/Spring-Integration-Java-DSL-Reference#routers

更新

子流映射示例：

.<Integer, Boolean>route(p -> p % 2 == 0, m -> m
.subFlowMapping(true, sf -> sf.<Integer>handle((p, h) -> p * 2))
.subFlowMapping(false, sf -> sf.<Integer>handle((p, h) -> p * 3)))