如何在 spring:jms 应用程序中使用 mqtt 协议接收发布在主题上的消息?

How to receive message published on a topic using mqtt protocol in spring:jms application?

我是 activemq 的新手。

我有一个发布者,它使用 mqtt 协议向主题发布消息。现在我想使用 Spring + JMS 编写一个订阅者,它将监听关于该主题的消息。

我有以下问题:

1) 如果我使用 tcp 编写订阅者,我可以有相同的主题 protocol.I 意思是说,发布者将使用 MQTT 发布主题,订阅者将使用 TCP 代理收听该主题 URL.

2) 如果以上不可能,那么我如何使用 spring + jms 编写一个订阅者来监听和接收使用 mqtt 在该主题上发布的消息?

提前致谢。

你试过吗?是的,它的工作原理与您预期的差不多。如果您尝试使用 JMS (OpenWire) 读取 MQTT 消息,则会将其转换为 JMS。

来自web site

Message transformations

MQTT messages are transformed into an JMS ByteMessage. Conversely, the body of any JMS Message is converted to a byte buffer to be the payload of an MQTT message.