Spring Boot自动配置：同名IntegrationFlow Bean的Fallback实现问题

问题概述 #

基于Spring Boot 3.4.x的应用，通过Spring Integration对接JMS，系统中存在上百个IntegrationFlow Bean，需按名称通过@Autowired注入。针对myOutgoingFlow Bean，需实现以下逻辑：

• 当不存在ConnectionFactory Bean 或 未配置my.destination属性时，创建一个NoOp降级Bean（仅记录消息，用于测试Mock）
• 当上述条件都满足时，创建正常的JMS发送集成流Bean

此前尝试的两种方案均触发Bean重复定义错误：

1. 单配置类中用@Order+@Conditional系列注解定义同名Bean
2. 拆分静态内部类结合@AutoConfiguration的before/after机制配置
   问题核心是两个Bean的条件未实现互斥，导致Spring认为两个Bean都满足创建条件。

解决方案：基于Spring标准@Conditional的互斥配置 #

方式一：自定义互斥条件类 #

通过实现Spring的Condition接口，定义两个完全互斥的条件，确保同一时间只有一个Bean被创建。

1. 定义条件类

// 正常JMS流的匹配条件：存在ConnectionFactory且配置了my.destination
public class NormalJmsFlowCondition implements Condition {
    @Override
    public boolean matches(ConditionContext context, AnnotatedTypeMetadata metadata) {
        boolean hasConnectionFactory = context.getBeanFactory().containsBean(ConnectionFactory.class.getName());
        boolean hasDestinationProp = context.getEnvironment().containsProperty("my.destination");
        return hasConnectionFactory && hasDestinationProp;
    }
}

// NoOp流的匹配条件：不满足正常JMS流的条件
public class NoOpFlowCondition implements Condition {
    @Override
    public boolean matches(ConditionContext context, AnnotatedTypeMetadata metadata) {
        return !new NormalJmsFlowCondition().matches(context, metadata);
    }
}

2. 配置类中定义同名互斥Bean

@Configuration
public class JmsIntegrationConfig {

    // 正常JMS发送流Bean
    @Bean("myOutgoingFlow")
    @Conditional(NormalJmsFlowCondition.class)
    public IntegrationFlow normalJmsOutgoingFlow(ConnectionFactory connectionFactory,
                                                 @Value("${my.destination}") String destination) {
        return IntegrationFlows.from("myOutgoingChannel")
                .handle(Jms.outboundAdapter(connectionFactory)
                        .destination(destination))
                .get();
    }

    // NoOp降级流Bean
    @Bean("myOutgoingFlow")
    @Conditional(NoOpFlowCondition.class)
    public IntegrationFlow noOpOutgoingFlow() {
        return IntegrationFlows.from("myOutgoingChannel")
                .handle(message -> {
                    // 仅记录消息，无实际JMS发送操作
                    System.out.println("NoOp flow received message: " + message.getPayload());
                })
                .get();
    }
}

方式二：使用Spring Boot组合条件注解（更简洁） #

利用Spring Boot提供的@ConditionalOnBean、@ConditionalOnProperty和@ConditionalOnMissingBean实现互斥，无需自定义条件类：

@Configuration
public class JmsIntegrationConfig {

    // 正常JMS发送流：仅当存在ConnectionFactory且配置了my.destination时创建
    @Bean("myOutgoingFlow")
    @ConditionalOnBean(ConnectionFactory.class)
    @ConditionalOnProperty(name = "my.destination")
    public IntegrationFlow normalJmsOutgoingFlow(ConnectionFactory connectionFactory,
                                                 @Value("${my.destination}") String destination) {
        return IntegrationFlows.from("myOutgoingChannel")
                .handle(Jms.outboundAdapter(connectionFactory)
                        .destination(destination))
                .get();
    }

    // NoOp降级流：仅当正常流Bean未被创建时才创建
    @Bean("myOutgoingFlow")
    @ConditionalOnMissingBean(name = "myOutgoingFlow")
    public IntegrationFlow noOpOutgoingFlow() {
        return IntegrationFlows.from("myOutgoingChannel")
                .handle(message -> {
                    System.out.println("NoOp flow received message: " + message.getPayload());
                })
                .get();
    }
}

关键注意事项 #

• 两个Bean必须使用相同的名称myOutgoingFlow，这样@ConditionalOnMissingBean(name = "myOutgoingFlow")才能准确判断正常流是否已创建
• 避免依赖@Order：@Order仅控制Bean的创建顺序，不影响条件匹配逻辑，无法解决重复定义问题
• 两种方式均属于Spring标准特性，无需额外依赖，也不会创建多余Bean

内容的提问来源于stack exchange，提问作者usr-local-ΕΨΗΕΛΩΝ