Spring Integration 5.x Java DSL复杂逻辑MessageChannel路由实现求助

问题分析 #

你之前继承AbstractMappingMessageRouter的方向不对，这个抽象类是用于通道键-通道实例的映射场景（比如根据消息头值匹配预定义的通道名称），它的getChannelKeys方法需要返回的是通道的标识（如名称字符串），而非直接返回MessageChannel实例，所以你的实现不符合该类的设计意图。

正确实现方案 #

方案一：继承AbstractMessageRouter（推荐，适合复杂逻辑封装） #

AbstractMessageRouter是更基础的路由器抽象类，允许你直接返回目标MessageChannel集合，完全贴合你通过业务逻辑直接确定通道的需求。

自定义路由器类

import org.springframework.integration.router.AbstractMessageRouter;
import org.springframework.messaging.Message;
import org.springframework.messaging.MessageChannel;
import java.util.Collections;
import java.util.Collection;

public class MyLogicRouter extends AbstractMessageRouter {

    private final MyLogicRouterService routerService;

    // 通过构造注入业务服务
    public MyLogicRouter(MyLogicRouterService routerService) {
        this.routerService = routerService;
    }

    @Override
    protected Collection<MessageChannel> determineTargetChannels(Message<?> message) {
        // 调用业务逻辑确定目标通道
        MessageChannel targetChannel = routerService.determineChannel(message);
        // 单播场景返回单元素集合；多播则返回包含多个通道的集合
        return Collections.singletonList(targetChannel);
    }
}

Java DSL配置

import org.springframework.context.annotation.Bean;
import org.springframework.integration.dsl.IntegrationFlow;
import org.springframework.integration.dsl.IntegrationFlows;

@Configuration
public class IntegrationConfig {

    @Bean
    public IntegrationFlow routingFlow(MyLogicRouterService routerService) {
        return IntegrationFlows.from("inputChannel") // 输入通道
                .route(new MyLogicRouter(routerService)) // 配置自定义路由器
                .get();
    }

    @Bean
    public MyLogicRouterService routerService() {
        return new MyLogicRouterService();
    }
}

方案二：直接使用Java DSL Lambda表达式（简洁，适合轻量逻辑） #

如果你的路由逻辑不需要封装为独立类，可以直接在DSL中用Lambda实现，无需自定义路由器：

@Bean
public IntegrationFlow routingFlow(MyLogicRouterService routerService) {
    return IntegrationFlows.from("inputChannel")
            .route(message -> {
                // 在这里编写路由逻辑，或调用业务服务获取通道
                return routerService.determineChannel(message);
            })
            .get();
}

Lambda表达式支持返回以下类型：

• MessageChannel实例
• 通道名称字符串（框架会自动解析为对应通道）
• 上述类型的集合（支持多播）

补充说明 #

• 若你的MyLogicRouterService需要获取通道实例，可通过ChannelResolver（Spring自动注入）来解析通道名称，示例：

  @Autowired
  private ChannelResolver channelResolver;
  
  public MessageChannel determineChannel(Message<?> message) {
      // 根据消息头/负载确定通道名称
      String channelName = getChannelNameFromMessage(message);
      return channelResolver.resolveDestination(channelName);
  }
  

• 多播场景：只需在determineTargetChannels中返回包含多个MessageChannel的集合即可，框架会自动将消息发送到所有目标通道。

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