Spring Integration 消息路由器详解

⚠️ 注意：本教程已将所有 Java 示例转换为 Kotlin 实现，优先使用注解配置方式，符合现代 Spring 最佳实践。

消息路由器核心概念

什么是消息路由器？

消息路由器是 Spring Integration 中的企业集成模式，它根据预定义规则将消息分发到不同的通道。就像邮局分拣员根据地址将邮件分发到不同区域一样，路由器根据消息内容或属性决定消息流向。

路由器类型概览

Spring Integration 提供以下专用路由器：

路由器类型	功能描述	适用场景
HeaderValueRouter	根据消息头值路由	需要基于消息元数据（如优先级、类型）分发
PayloadTypeRouter	根据消息负载类型路由	处理多种数据类型时自动分发
ExceptionTypeRouter	根据异常类型路由	错误处理场景
RecipientListRouter	向多个接收者发送消息	广播或并行处理场景
XPathRouter	使用 XPath 表达式路由 XML 消息	XML 处理流水线

基础路由实现

1. Lambda 表达式路由

@Bean
fun routeFlowByLambda(): IntegrationFlow {
    return IntegrationFlow.from("routerInput")
        .route<Int, Boolean>({ p -> p % 2 == 0 }) { spec ->
            spec.suffix("Channel")
                .channelMapping(true, "even")
                .channelMapping(false, "odd")
        }
        .get()
}

代码解析：

1. route<Int, Boolean>：指定输入负载类型为 Int，路由结果为 Boolean
2. { p -> p % 2 == 0 }：Lambda 路由逻辑，判断数字奇偶
3. suffix("Channel")：自动添加 "Channel" 后缀到映射键
4. channelMapping()：将布尔结果映射到具体通道

实际应用场景

电商订单处理系统：

• 偶数订单号 → 快速处理通道
• 奇数订单号 → 标准处理通道

2. SpEL 表达式路由

@Bean
fun routeFlowByExpression(): IntegrationFlow {
    return IntegrationFlow.from("routerInput")
        .route("headers['destChannel']")  
        .get()
}

代码关键点：

• 使用 SpEL 表达式 headers['destChannel'] 动态获取路由目标
• 表达式结果直接作为通道名称

动态路由技巧

可在消息头中设置 destChannel 实现动态路由决策：

messageBuilder.setHeader("destChannel", "priorityChannel")

高级路由模式

收件人列表路由 (Recipient List)

@Bean
fun recipientListFlow(): IntegrationFlow {
    return IntegrationFlow.from("recipientListInput")
        .transform<String, String> { p -> p.replaceFirst("Payload", "") }
        .routeToRecipients { spec ->
            spec.recipient("thing1-channel", "'thing1' == payload")
                .recipientMessageSelector("thing2-channel") { message ->
                    message.headers.containsKey("recipient") && 
                    message.headers["recipient"] as Boolean
                }
                .recipientFlow("'thing1' == payload or 'thing2' == payload or 'thing3' == payload") { flow ->
                    flow.transform<String, String>(String::toUpperCase)
                        .channel { c -> c.queue("recipientListSubFlow1Result") }
                }
                .recipientFlow({ p -> p.startsWith("thing3") }) { flow ->
                    flow.transform { p -> "Hello $p" }
                        .channel { c -> c.queue("recipientListSubFlow2Result") }
                }
                .defaultOutputToParentFlow()  
        }
        .get()
}

核心功能解析：

1. 多条件路由：同时支持 SpEL 表达式和 Lambda 谓词
2. 子流程路由：使用 recipientFlow 将消息路由到完整子流程
3. 默认输出：defaultOutputToParentFlow() 处理未匹配消息

实际业务场景示例 (点击展开)

物流分发中心模型：

最佳实践与常见问题

路由设计原则

1. 保持路由逻辑简单 → 复杂逻辑应委托给服务
2. 优先使用消息头路由 → 避免解析负载带来的性能开销
3. 设置默认通道 → 使用 defaultOutputChannel 处理意外消息

常见错误排查

路由死锁问题

当路由指向自身时会导致消息循环：

.route("headers['channel']")
// 错误：可能返回当前通道名称

✅ 解决方案：添加循环检测或使用独立路由键

类型转换异常

使用 PayloadTypeRouter 时未注册类型转换器会导致：

.routeByPayload {
    mapping<Int>("intChannel")
    mapping<String>("stringChannel")
}
// 缺少自定义类型处理

✅ 解决方案：为自定义类型实现 Converter

性能优化技巧

@Bean
fun optimizedRouter(): IntegrationFlow {
    return IntegrationFlow.from("inputChannel")
        .route<Message<*>>({ message -> 
            // 缓存路由决策结果
            message.headers.computeIfAbsent("routed") { 
                determineRoute(message) 
            }
        }, { spec ->
            spec.resolutionRequired(false)  
               .defaultOutputChannel("defaultChannel")
        })
        .get()
}

关键优化点：

• resolutionRequired(false)：允许无匹配时使用默认通道
• 使用 computeIfAbsent 缓存路由决策
• 避免在路由逻辑中进行耗时操作

路由模式对比

简单路由

@Bean
fun simpleRouter(): IntegrationFlow {
    return IntegrationFlow.from("input")
        .route<Int>({ payload -> 
            if (payload > 100) "large" else "small"
        })
        .get()
}
// 优点：配置简单直接
// 缺点：逻辑复杂时难以维护

注解路由

@Router(inputChannel = "inputChannel")
fun routeByPayload(payload: Any): String {
    return when (payload) {
        is String -> "stringChannel"
        is Number -> "numberChannel"
        else -> "defaultChannel"
    }
}
// 优点：强类型安全
// 缺点：需要单独配置类

DSL路由

@Bean
fun dslRouter(): IntegrationFlow {
    return IntegrationFlow.from("input")
        .routeByPayload<Any> {
            mapping<String>("stringProcessing")
            mapping<Int>("numberProcessing")
            defaultOutputChannel("unknownTypeChannel")
        }
        .get()
}
// 优点：声明式配置，类型安全
// 推荐：现代Spring最佳实践

总结与进阶学习

✅ 核心要点总结：

1. 路由器是消息流中的决策点
2. Kotlin DSL 提供类型安全的配置方式
3. 收件人列表支持复杂分发场景
4. 总是设置默认通道处理边界情况

⚡️ 进阶主题推荐：

• 动态路由器注册
• 路由策略外部化配置
• 分布式环境下的路由一致性
• 路由器性能监控指标

"路由器是集成流程的交通警察，确保每条消息都能高效到达正确目的地。" - Spring Integration 设计哲学

👉 接下来学习：消息过滤器 | 通道适配器