Spring Integration Flow条件路由：自定义MethodInvokingRouter Bean

针对你通过MQTT接收智能家居设备消息，希望基于payload.header.mac字段、无需逐个配置映射的路由需求，下面是将MethodInvokingRouter定义为独立Bean的实现方案：

1. 封装路由逻辑到业务Bean #

先创建一个包含路由规则的Bean，把mac列表和判断逻辑封装进去，便于维护和扩展：

@Component
public class DeviceRoutingService {

    // 可从配置文件注入，或动态维护该列表
    private final List<String> sensorMacList = Arrays.asList("macA", "macB", "macC");

    /**
     * 路由方法：根据消息中的mac字段判断目标通道
     */
    public String routeDeviceMessage(Message<?> message) {
        // 从消息payload中提取mac字段（根据实际payload结构调整类型）
        YourPayloadType payload = (YourPayloadType) message.getPayload();
        String deviceMac = payload.getHeader().getMac();

        // 判断mac是否属于传感器设备，路由到对应通道
        if (sensorMacList.contains(deviceMac)) {
            return "controlsChannel";
        }
        // 其他设备路由到默认通道或指定通道
        return "defaultChannel";
    }
}

2. 定义MethodInvokingRouter Bean #

将上面的业务Bean和路由方法关联到MethodInvokingRouter：

@Bean
public MethodInvokingRouter deviceRouter(DeviceRoutingService routingService) {
    MethodInvokingRouter router = new MethodInvokingRouter();
    // 指定路由逻辑所在的Bean和方法名
    router.setTargetObject(routingService);
    router.setTargetMethod("routeDeviceMessage");
    // 可选：设置默认输出通道（方法返回null或未匹配时使用）
    router.setDefaultOutputChannelName("fallbackChannel");
    return router;
}

3. 在IntegrationFlow中使用该Router #

在消息流配置中直接引用这个Router Bean：

@Bean
public IntegrationFlow mqttMessageFlow(MqttPahoMessageDrivenChannelAdapter mqttAdapter,
                                       MethodInvokingRouter deviceRouter) {
    return IntegrationFlows.from(mqttAdapter)
            // 可选：添加payload转换等前置处理步骤
            .route(deviceRouter)
            .get();
}

方案说明 #

• 路由逻辑从配置代码剥离到独立业务Bean，结构更清晰，后续修改mac列表或调整规则更便捷；
• mac列表可通过@Value从配置文件加载，或动态从数据库/配置中心读取，比硬编码的setChannelMapping更灵活；
• MethodInvokingRouter会自动调用指定方法，根据返回的通道名完成路由，完全无需逐个配置映射条目。

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