Kafka 和 ActiveMQ 的通用消息代理接口

Question

我想设计一个接口，用于在 Spring Boot 微服务之间简单地发送和接收消息。任何服务都应该能够自动连接接口并使用发送/接收方法。这些方法的实现应该取决于 application.props 文件是要使用 kafka 还是 activemq。我无法想出一个干净的设计。我在想是否可以为它创建一个自定义注释。无论我有什么春季靴子经验，我都无法想象这样的设计。骨架看起来像下面的东西，但我无法看到如何将其实现为正确的代码：bean、在 kafka/activemq 特定注释和方法之间切换等等。

服务：

@自动连线 MessageProducer 消息生产者

@自动连线 MessageReceiver 消息接收者

MessageProducer [接口] public void sendMessage(destination, payload)

MessageReceiver [接口] public void receiveMessage(source, payload)

Answer 1

您可以有两个实现类，例如 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);
    }
}