Spring Integration 5 Java DSL实现HeaderExistsRouter路由需求

针对你需要根据指定消息头是否存在来双向路由的需求，这里提供几个实用的Java DSL实现方案：

方案一：直接自定义路由逻辑（最简洁） #

利用Spring Integration DSL的route()方法，直接传入lambda表达式判断消息头是否存在，返回对应通道名称。这种方式无需额外类，适合简单的双向路由场景：

@Bean
public IntegrationFlow headerPresenceRouterFlow() {
    return IntegrationFlow.from("input-channel")
            .route(message -> 
                message.getHeaders().containsKey("your-target-header") 
                    ? "chan-a" 
                    : "error-channel"
            )
            .get();
}

核心是通过Message.getHeaders().containsKey()直接判断目标头是否存在，返回对应的通道标识符，框架会自动解析为对应的MessageChannel。

方案二：自定义路由器类（适合复用场景） #

如果需要在多个流程中复用这个路由逻辑，可以自定义一个继承AbstractMessageRouter的路由器类，模仿HeaderExistsRouter的逻辑，然后在DSL中引用：

// 自定义路由器
public class HeaderExistsRouter extends AbstractMessageRouter {
    private final String targetHeaderName;

    public HeaderExistsRouter(String targetHeaderName) {
        this.targetHeaderName = targetHeaderName;
    }

    @Override
    protected Collection<MessageChannel> determineTargetChannels(Message<?> message) {
        MessageChannel targetChannel;
        if (message.getHeaders().containsKey(this.targetHeaderName)) {
            targetChannel = getChannelResolver().resolveDestination("chan-a");
        } else {
            targetChannel = getChannelResolver().resolveDestination("error-channel");
        }
        return Collections.singleton(targetChannel);
    }
}

// 在IntegrationFlow中使用自定义路由器
@Bean
public IntegrationFlow reusableHeaderRouterFlow() {
    return IntegrationFlow.from("input-channel")
            .router(new HeaderExistsRouter("your-target-header"))
            .get();
}

这种方式将路由逻辑封装为独立组件，便于在多个集成流程中复用，符合面向对象的设计思想。

方案三：借助HeaderValueRouter结合默认通道（有局限性） #

虽然HeaderValueRouter主要用于根据头值路由，但可以通过设置默认通道实现近似效果，不过需要注意局限性：

@Bean
public IntegrationFlow headerValueRouterWithFallbackFlow() {
    return IntegrationFlow.from("input-channel")
            .route(HeaderValueRouter.class, routerSpec ->
                    routerSpec.headerName("your-target-header")
                            .channelMapping("*", "chan-a") // 匹配任意非null的头值
                            .defaultOutputChannel("error-channel") // 头不存在或值为null时走这里
            )
            .get();
}

注意：该方案仅当头存在且值不为null时才会路由到chan-a，如果头存在但值为null，会被视为不匹配，走默认的error-channel。如果你的场景允许头存在但值为null时也路由到chan-a，这个方案不适用，建议选择前两种。

内容的提问来源于stack exchange，提问作者hotmeatballsoup