如何使用MQTT正确订阅ActiveMQ Artemis指定队列？

核心原因 #

ActiveMQ Artemis的MQTT默认行为是：当客户端订阅主题（对应Artemis的address）时，会自动创建一个客户端专属的非持久队列（格式为deviceID.address），用来接收该address的消息，这是贴合MQTT规范中“每个订阅者独立消费”的实现逻辑。但如果要复用已预先创建的持久队列，需要使用Artemis专属的MQTT扩展语法。

正确订阅语法 #

要直接绑定到已存在的队列，需在MQTT订阅主题中添加queue://前缀，格式如下：

queue://<目标队列名称>

以你场景中的test队列为例，订阅主题应写为：

queue://test

验证与注意事项 #

• 先确认Artemis中已存在关联address为test的队列test，可通过Artemis控制台或artemis queue stat命令核查。
• 使用上述语法订阅后，代理会直接将客户端绑定到已有的test队列，不会生成新的临时队列。
• 该语法是ActiveMQ Artemis对MQTT的扩展，仅适用于Artemis代理，其他MQTT代理可能不兼容。
• 如果指定的队列不存在，默认配置下Artemis会返回订阅失败，不会自动创建队列，需提前确保队列已创建。

内容的提问来源于stack exchange，提问作者Tomáš Lazar