如何在 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.
我是 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.