Spring Integration Header Value Router默认通道配置异常求助

看起来你遇到的是Spring Integration HeaderValueRouter默认通道未按预期生效的问题，我来帮你梳理下原因和解决办法：

核心问题根源 #

HeaderValueRouter继承自AbstractMappingMessageRouter，在Spring Integration 5.0.x版本中，这个抽象类的resolutionRequired属性默认值为true。这就导致了：

• 当header值存在，但没有匹配到你配置的channelMapping时，路由器不会直接走默认通道，而是会尝试把header的值当作Bean名称，去Spring容器中查找对应的MessageChannel。
• 如果找不到这个名称的Channel Bean，就会抛出你看到的DestinationResolutionException，而非降级到默认通道处理。

另外我还注意到代码里有个变量名不一致的小问题：你注入的是defaultRouterChannel，但设置默认通道时写的是defaultRouteChannel，这会导致默认通道本身无法被正确引用，即使逻辑正确也会出问题。

修正后的完整代码 #

下面是调整后的代码，解决了上述两个问题：

@Autowired 
@Qualifier("defaultRouterChannel") 
MessageChannel defaultRouterChannel; // PubSub channel

@Bean 
public IntegrationFlow amqpFlow() { 
    return IntegrationFlows 
        .from("rabbitMqChannel") 
        .transform(Transformers.fromJson(Agreement.class)) 
        .route(router()) 
        .get(); 
} 

public HeaderValueRouter router() { 
    HeaderValueRouter router = new HeaderValueRouter(AGREEMENT_HEADER); 
    router.setDefaultOutputChannel(defaultRouterChannel); // 修正变量名，确保引用一致
    router.setChannelMapping("ENROLL", "enrollChannel"); 
    router.setChannelMapping("ENLIST", "enlistChannel"); 
    router.setResolutionRequired(false); // 关键配置：关闭名称解析要求
    return router; 
} 

@Bean 
public IntegrationFlow defaultRoute() { 
    return IntegrationFlows 
        .from(defaultRouterChannel) 
        .log() 
        .get(); 
} 

关键配置说明 #

• router.setResolutionRequired(false)：这个配置告诉路由器，当找不到对应的channel mapping时，不要尝试将header值解析为Channel Bean名称，直接使用我们配置的默认通道处理消息。
• 变量名修正：确保defaultRouterChannel的引用完全一致，避免因变量名错误导致默认通道无法正常注入。

验证效果 #

现在当你发送带有无效header值（比如"LOCAL"）的消息时，路由器会直接将消息路由到defaultRouterChannel，执行你配置的log()逻辑，而不会再抛出异常。

内容的提问来源于stack exchange，提问作者Jose Carlos Canova