外部Bean注入冲突解决方案

面试速记

针对导入框架的bean注入冲突问题，在导入框架都需用时(无用直接移除了)分情况处理:

1. 如果优先指定某一个，采用显式定义Bean+@Primary
2. 如果需要灵活选择，可以使用@Conditional搭配配置文件切换
3. 如果只是框架bean冲突，那么在启动类上通过exclude排除类加载

项目中可能会用到很多消息队列（kafaka、rabbitmq、rocketmq....）好多种，然后根据自动装配然后去选择一个类型进行注入，但是如果出现自动装配的类有冲突怎么办?比如多个ConnectionFactory被创建

本篇与之前写的bean注入冲突的情况还是有所不同，之前是项目中自定义的bean冲突，处理起来三个注解就可以轻松解决，针对外部bean注入冲突的情况，需要考虑更复杂高效的处理

总体方案对比

场景推荐方案

需要灵活切换消息队列	@Conditional + 配置开关 或 Profile 隔离
多个消息队列需共存但互不干扰	显式定义 Bean + @Primary
框架自动配置类冲突	排除自动配置类（exclude）

使用 @Conditional 注解动态控制

通过条件注解（如 @ConditionalOnProperty、@ConditionalOnClass）按需激活某个消息队列的配置：

@Configuration
public class MessageQueueConfig {
    
    // 只有当配置中指定了 rabbitmq.enabled=true 时，才创建 RabbitMQ 的 ConnectionFactory
    @Bean
    @ConditionalOnProperty(name = "rabbitmq.enabled"， havingValue = "true")
    public ConnectionFactory rabbitConnectionFactory() {
        return new CachingConnectionFactory();
    }

    // 同理，Kafka 的配置
    @Bean
    @ConditionalOnProperty(name = "kafka.enabled"， havingValue = "true")
    public KafkaTemplate<String， String> kafkaTemplate() {
        return new KafkaTemplate<>(...);
    }
}

• 在 application.properties 中通过开关控制：

  # 启用 RabbitMQ，关闭 Kafka
  rabbitmq.enabled=true
  kafka.enabled=false
  

显式定义主 Bean（覆盖自动配置）

如果自动配置的 Bean 冲突，可以手动定义自己的 Bean，并添加 @Primary 注解，明确告诉 Spring 优先使用该 Bean：

@Bean
@Primary  // 标记为优先使用的 Bean
public ConnectionFactory myRabbitConnectionFactory() {
    return new CachingConnectionFactory("localhost");
}

手动排除自动配置类

• 如果必须同时保留多个消息队列依赖，但只启用其中一个，可以通过以下方式排除冲突的自动配置类：

  • 方式一：在 application.properties 中排除：

    spring.autoconfigure.exclude= \
      org.springframework.boot.autoconfigure.kafka.KafkaAutoConfiguration， \
      org.springframework.boot.autoconfigure.rocketmq.RocketMQAutoConfiguration
    

  • 方式二：在启动类上排除：

    @SpringBootApplication(exclude = {
        KafkaAutoConfiguration.class，
        RocketMQAutoConfiguration.class
    })
    public class MyApplication { ... }