ActiveMQ Classic v5.17.1无法创建持久订阅的原因及实现方法

你已经满足了MQTT持久订阅的基础要求：cleanSession=false（对应--no-clean参数）、固定clientId、订阅QoS≥1，但ActiveMQ Classic对MQTT持久订阅有额外的配置要求，这正是你遗漏的关键。

具体遗漏点及解决方法 #

1. 未开启ActiveMQ MQTT适配器的持久消息支持 #

ActiveMQ Classic默认的MQTT连接器配置未启用持久订阅支持，需要显式添加配置参数：

• 打开ActiveMQ配置文件conf/activemq.xml，找到<transportConnectors>节点下的MQTT连接器配置
• 在uri中追加allowDurableMessages="true"参数，修改后的配置示例：

  <transportConnector name="mqtt" uri="mqtt://0.0.0.0:1883?allowDurableMessages=true&amp;maxInflight=100" />
  

• 重启ActiveMQ服务生效：sudo systemctl restart activemq

2. 残留客户端连接干扰持久订阅创建 #

如果之前使用clientId=DAVE的客户端未正常断开，会导致新的持久订阅无法正确生成：

• 先在ActiveMQ控制台的「Connections」页面，找到并断开所有DAVE相关的连接
• 重新执行订阅命令：

  mqtt sub -t mytopic -q 1 --no-clean -i DAVE
  

• 此时再查看控制台的「Subscriptions」页面，该订阅会被标记为持久（Durable）类型

3. 混淆Retain消息与离线持久消息的作用 #

你发布的消息带有retain=true，但Retain消息仅用于给新订阅的客户端推送最新的一条消息，不会保存客户端离线期间的所有消息。要验证持久订阅的离线消息能力：

1. 保持订阅客户端在线，发布一条QoS1的消息
2. 断开订阅客户端
3. 再发布一条新的QoS1消息到mytopic
4. 用相同clientId和--no-clean参数重新连接订阅，此时应该能收到断开期间发布的那条消息

额外注意事项 #

• 确保ActiveMQ的持久化存储（默认是KahaDB）正常工作，检查data/kahadb目录是否有读写权限、无文件损坏
• MQTT 3.1.1中，持久订阅与clientId强绑定，同一clientId只能存在一个持久订阅会话，避免重复创建产生冲突

内容的提问来源于stack exchange，提问作者djna