添加correlationData时HiveMQ Cloud出现MQTT5消息丢失问题

问题原因 #

导致该问题的核心原因和MQTT协议版本兼容性、Broker配置相关，具体如下：

• 订阅端协议版本不匹配：correlationData是MQTT 5.0版本新增的特有属性，HiveMQ Broker默认不会将携带MQTT 5特有属性的消息推送给使用MQTT 3.x版本连接的订阅端。你用到的HiveMQ官方WebSocket测试工具默认使用MQTT 3.1.1协议建立连接，自研订阅端如果也没有明确指定MQTT 5版本，就会出现消息发送成功但订阅端收不到的情况。
• Broker属性转换开关未开启：如果你的业务场景需要兼容MQTT 3.x的订阅端，需要手动开启HiveMQ Broker的MQTT 5属性向下转换配置，默认该配置是关闭的，Broker会直接丢弃无法向下兼容的消息。
• 属性大小超限：HiveMQ Cloud对单条消息的所有属性总大小有限制，免费版限制为1KB，如果correlationData的长度过大，超过了Broker限制，消息会被静默丢弃。

解决方案 #

1. 所有订阅端连接HiveMQ Cloud时，明确指定使用MQTT 5.0版本协议，不要使用默认的3.1.1版本。如果使用HiveMQ官方WebSocket测试工具，在连接前手动将协议版本切换为MQTT 5即可正常看到携带correlationData的消息。
2. 如果必须兼容MQTT 3.x订阅端，在HiveMQ Broker配置中开启mqtt5-property-down-conversion开关，开启后Broker会将MQTT 5特有属性放到消息用户属性中透传给3.x客户端，你需要在3.x订阅端额外解析用户属性获取correlationData。
3. 测试阶段先使用短字符串作为correlationData值验证功能，排除大小超限问题。

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