动态实例化Spring集成流

Question

我有一个Spring集成流项目，它公开了一个Rest网关，在接收到Rest POST请求后，它会执行一些较小的逻辑。基于一些有效载荷参数，我想动态激活另一个Spring集成流，并将消息路由到该流中的指定通道，我可以在基于有效载荷的主流中发现该通道。子流将把响应消息放在主流中定义的指定通道中。

我如何才能实现这一点。

Answer 1

请参阅动态ftp示例，该示例使用自定义路由器来实例化子流并路由到新流的通道。

另请参阅我对这个问题的回答及其对类似机制的后续介绍，这次使用java配置进行入站邮件适配器。

Answer 2

从版本1.2开始，Spring Integration Java DSL为运行时流注册提供了API：

@Autowired
private IntegrationFlowContext context;
...

IntegrationFlow myFlow = f -> f
            .<String, String>transform(String::toUpperCase)
            .transform("Hello, "::concat);

String flowId = this.context.register(myFlow);
MessagingTemplate messagingTemplate = this.context.messagingTemplateFor(flowId);

assertEquals("Hello, SPRING",
            messagingTemplate.convertSendAndReceive("spring", String.class));

this.context.remove(flowId);

因此，根据您的逻辑，您可以构建和执行一个或另一个流。

围绕该API，您甚至可以构建一些缓存，不要多次注册相同的流，而是在第一次注册后重用。