Spring Integration 5.x Java DSL：基于Header的Filter路由实现问询

你的核心问题是没正确利用Filter组件的通道配置能力：默认filter会让返回true的消息继续沿当前流传递，返回false的消息直接静默丢弃，不会自动发往死信队列。以下是针对需求的完整配置方案：

1. 先定义所需通道Bean #

// 目标水果消息通道
@Bean
public MessageChannel fruitChannel() {
    return new DirectChannel();
}

// 死信/丢弃通道
@Bean
public MessageChannel deadLetterChannel() {
    return new DirectChannel();
}

2. 修正IntegrationFlow配置 #

方式一：通过outputChannel直接路由符合条件的消息 #

这种方式会把通过过滤的消息直接发送到fruit-channel，当前流到此终止：

@Bean
public IntegrationFlow fruitFlow(FruitFilter fruitFilter,
                                 MessageChannel fruitChannel,
                                 MessageChannel deadLetterChannel) {
    return IntegrationFlows.from(ingressChannel())
            .filter(fruitFilter, config -> config
                    // 符合条件（返回true）的消息发送到fruitChannel
                    .outputChannel(fruitChannel)
                    // 不符合条件（返回false）的消息发送到死信通道
                    .discardChannel(deadLetterChannel))
            .get();
}

方式二：让符合条件的消息继续走当前流后续节点 #

如果需要在过滤后对消息做更多处理，可以不配置outputChannel，而是在filter之后添加后续逻辑：

@Bean
public IntegrationFlow fruitFlow(FruitFilter fruitFilter,
                                 MessageChannel deadLetterChannel) {
    return IntegrationFlows.from(ingressChannel())
            .filter(fruitFilter, config -> config
                    .discardChannel(deadLetterChannel))
            // 过滤通过的消息发送到fruit-channel
            .channel("fruit-channel")
            // 这里可以继续添加其他处理逻辑，比如转换、持久化等
            .get();
}

3. 自定义Filter类的优化（可选） #

你的FruitFilter类是正确的，也可以去掉@Filter注解，直接用方法引用简化写法：

public class FruitFilter {
    public boolean fruitsOnly(Message<?> message) {
        return message.getHeaders().containsKey("fruit");
    }
}

// 在Flow中使用方法引用
.filter(fruitFilter::fruitsOnly, config -> ...)

4. 死信消息的后续处理（可选） #

如果需要对死信通道的消息做日志记录或其他处理，可以给死信通道单独配置一个Flow：

@Bean
public IntegrationFlow deadLetterProcessingFlow(MessageChannel deadLetterChannel) {
    return IntegrationFlows.from(deadLetterChannel)
            .handle(message -> {
                // 示例：打印死信消息详情
                System.err.println("丢弃的消息：" + message.getPayload() + "，Headers：" + message.getHeaders());
            })
            .get();
}

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