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

Question

我刚开始使用ActiveMQ Artemis，并在我的机器上安装了Artemis2.17.0。创建了SpringBoot测试应用程序，其中存在JMS和MQTT发布者和接收者。还创建了小的RestController，这样我就可以使用JMS和MQTT生成器发送消息。接收器非常简单，只需创建一条日志消息到控制台。现在，当我使用MQTT生产者创建消息时，JMS和MQTT接收器都将消息获取并记录到控制台。但是当我使用JMS producer发送消息时，消息只在JMS receiver中接收，而在控制台中没有MQTT消息。试了好几次。实现是ok的，我认为作为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具有灵活的寻址模型，支持点对点和发布订阅模式。默认情况下，Spring Boot创建一个配置为点对点传输的JmsTemplate，而MQTT使用发布-订阅模式，因此JMS和MQTT接收器使用不同的消息传递模式，这就造成了问题。

要通过引导的application.properties为发布-订阅模式设置spring.jms.pub-sub-domain=true配置JmsTemplate，或者将JmsTemplatepubsubdomain设置为true，即：

jmsTemplate.setPubSubDomain(true);

要配置发布-订阅模式的JmsListener，通过引导的application.properties设置spring.jms.pub-sub-domain=true或将JmsListenerContainerFactorypubsubdomain设置为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) {
    ...
}