您可以有两个实现类，如 KafkaMessageProducer 以及 ActvieMQMessageProducer . 内部 application.properties 你可以这样做 messaging.type=kafka 或者 messaging.type=activemq 它将指定应用程序应选择哪个消息传递通信。
配置类：

@Configuration
public class MessagingConfiguration {

    @Bean
    @ConditionalOnProperty(name = "messaging.type", havingValue = "kafka")
    public MessageProducer messageProducer() {
        return new KafkaMessageProducer();
    }

    @Bean
    @ConditionalOnProperty(name = "messaging.type", havingValue = "activemq")
    public MessageProducer messageProducer() {
        return new ActvieMQMessageProducer();
    }
}

如果您想在同一个应用程序中使用这两种消息传递类型（例如，一个服务类将使用kafka，而另一个类将使用activemq），那么创建两个bean（如上所述，但是 @Qualifier 而且没有 @ConditionalOnProperty ). 在每个需要消息生产者的服务上，用 @Qualifier 您需要哪种实现

@Configuration
public class MessagingConfiguration {

    @Bean
    @Qualifier("kafkaMessageProducer")
    public MessageProducer messageProducer() {
        return new KafkaMessageProducer();
    }

    @Bean
    @Qualifier("actvieMQMessageProducer")
    public MessageProducer messageProducer() {
        return new ActvieMQMessageProducer();
    }

    @Bean
    public YourService messageProducer(@Qualifier("kafkaMessageProducer") MessageProducer messageProducer) {
        return new YourServiceImpl(messageProducer);
    }
}