使用 JMS 生产者发送的消息未在同一 SpringBoot 应用程序的 MQTT 接收器中收到

Question

我刚开始使用 ActiveMQ Artemis，并在我的机器上安装了 Artemis 2.17.0。创建了 JMS 和 MQTT 发布者和接收者都存在的 SpringBoot 测试应用程序。还创建了小型 RestController，因此我可以使用 JMS 和 MQTT 生产者发送消息。接收器非常简单，只需创建一条日志消息到控制台即可。现在，当我使用 MQTT 生产者创建消息时，JMS 和 MQTT 接收者都会获取消息并将其记录到控制台。但是当我使用 JMS 生产者发送消息时，消息仅在 JMS 接收器中接收，控制台中没有 MQTT 消息。试了几次。实施没问题，我认为 MQTT 生产者示例运行良好。以这种方式在 Artemis 中的协议之间路由消息是否有任何限制？或者会是什么问题？

关于 JMS 实现的代码信息：https://dmarko.tcl-digitrade.com/post/2021/activemq-artemis-spring-boot/
关于 MQTT 实现的代码信息：https://dmarko.tcl-digitrade.com/post/2021/activemq-artemis-mqtt/

Answer 1

Apache ActiveMQ Artemis 具有灵活的 addressing model，支持点对点和发布-订阅模式。默认情况下，Spring Boot 创建一个配置为点对点传输的 JmsTemplate，而 MQTT 使用发布-订阅模式，因此 JMS 和 MQTT 接收器使用不同的消息传递模式，这会导致您的问题。

通过 Boot 的 application.properties 为发布-订阅模式集 spring.jms.pub-sub-domain=true 配置 JmsTemplate 或将 JmsTemplate pubSubDomain 设置为 true，即：

jmsTemplate.setPubSubDomain(true);

通过 Boot 的 application.properties 为发布-订阅模式集 spring.jms.pub-sub-domain=true 配置 JmsListener 或将 JmsListenerContainerFactory pubSubDomain 设置为 true，即：

@Bean
public JmsListenerContainerFactory<?> topicConnectionFactory(ConnectionFactory connectionFactory, DefaultJmsListenerContainerFactoryConfigurer configurer) {
    DefaultJmsListenerContainerFactory factory = new DefaultJmsListenerContainerFactory();
    configurer.configure(factory, connectionFactory);
    factory.setPubSubDomain(true);
    return factory;
}

@JmsListener(destination = "${prices.mqtt.east}", containerFactory = "topicConnectionFactory")
public void receiveFromTopic(String message) {
    ...
}

使用 JMS 生产者发送的消息未在同一 SpringBoot 应用程序的 MQTT 接收器中收到

Message sent using JMS producer is not received in MQTT receiver in the same SpringBoot app

spring-boot

activemq-artemis