Spring集成：动态切换路由

Question

基于spring集成的转换器使用来自一个系统的消息，检查、转换并将其发送到另一个系统。

如果目标系统关闭，我们将停止入站适配器，但也希望在本地保留或转发当前“正在运行”的转换消息。为此，只需将消息从正常输出通道动态地重新路由到某个“备份”通道。

在文档中，我只找到了根据消息头路由消息的选项（因此，在流程之前的某个步骤中，一旦targer系统不可用，我将不得不动态添加这些消息），或者基于有效负载类型，这不是我真正的情况。动态添加一些标头，然后在管道中过滤掉它，或者在反/序列化期间，对我来说似乎仍然不是最好的方法。我更希望能够打开一个开关（在某些内部事件上），然后将这些“飞行中”的消息重新路由到“备份”通道。

什么是实现这一目标的最佳SI方法？谢谢！

Answer 1

路由器不仅可以基于有效负载类型或某些标头。您确实可以调用一个通用的POJO方法来返回一个通道、它的名称或一些映射的路由密钥。该POJO方法确实可以检查一些内部系统状态并生成这个或那个路由密钥。

所以，你可能在路由器配置中有这样的东西：

.route(myRouter())

其中您的myRouter是这样的：

@Bean
MyRouter myRouter() {
   return;
}

它的内部代码可能是这样的：

public class MyRouter {


    @Autowired
    private SystemState systemState;

    String route(Object payload) {
       return this.systemState.isActive() ? "successChannel" : "backupChannel";
    }
}

同样可以通过简单的lambda定义实现：

 .<Object, Boolean>route(p -> systemState().isActive(),
                  m -> m.channelMapping(true, "sucessChannel")
                         .channelMapping(false, "backupChannel"))

也...

private final AtomicBoolean switcher = new AtomicBoolean();

@Bean
public IntegrationFlow flow() {
    return IntegrationFlows.from(() -> "foo", e -> e.poller(Pollers.fixedDelay(Duration.ofSeconds(5))))
            .route(s -> switcher.get() ? "foo" : "bar")
            .get();
}