生产者/消费者上下文中的 MQTT

Question

我们使用 ActiveMQ 进行消息队列与 openwire 传输。在这种情况下，将有一个生产者和一个消费者注册一个消息侦听器。我们听说过 MQTT 协议及其在 activeMQ 中的支持。但我只看到了发布者/订阅者语义的示例，订阅者需要显式调用接收方法来获取发布的消息。我可以将 mqtt 与生产者/消费者环境一起使用吗？请给个样品..

Answer 1

MQTT 协议基于发布/订阅模型，它没有内置于协议中的排队语义。如果您需要队列，那么您需要坚持使用 openwire 客户端或使用支持主题和队列的基于 STOMP 的客户端。