使用AWSIotMqttClient实现MQTT3共享订阅无消息接收问题排查

你遇到的问题根源在于AWS IoT Device SDK Java 1.3.11版本对MQTT 3.1.1共享订阅的主题匹配逻辑存在缺陷：

• 当订阅$share/commandGroup/commandTopic/demo时，AWS IoT Core会将发送到commandTopic/demo的消息转发给共享组内的客户端，但转发的消息主题仍为原始的commandTopic/demo
• 旧版SDK的订阅匹配逻辑是严格按照你传入的带$share前缀的完整订阅主题字符串来匹配收到的消息主题，两者不匹配，因此SDK判定这是“意外消息”，不会触发你注册的回调，仅输出警告。

方案1：自定义全局消息监听器，手动处理主题匹配 #

绕过SDK默认的订阅匹配逻辑，直接监听所有消息，手动判断消息主题是否属于共享订阅的目标原始主题，再执行对应业务逻辑：

public void subscribeShared() throws AWSIotException {
    // 记录共享订阅对应的原始主题
    final String originalTopic = "commandTopic/demo";
    // 向Broker发送共享订阅请求
    awsIotMqttClient.subscribe("$share/commandGroup/" + originalTopic, AWSIotQos.QOS0, null);
    
    // 注册全局消息监听器，处理所有收到的消息
    awsIotMqttClient.addMessageListener((topic, payload, qos, retained) -> {
        if (originalTopic.equals(topic)) {
            // 执行你的业务逻辑
            System.out.println("hello world (shared subscription)");
        }
    });
}

注意：subscribe方法第三个参数传null，避免SDK绑定默认回调，所有消息统一由全局监听器处理。

方案2：升级SDK版本（若生产环境允许） #

虽然你无法升级到MQTT5，但AWS IoT Device SDK Java 1.4.x及以上版本修复了MQTT3下共享订阅的主题匹配问题，SDK会自动处理$share前缀订阅与原始消息主题的匹配逻辑。如果生产环境允许升级SDK，可尝试将依赖更新到较新的1.4.x版本（例如1.4.20）：

<dependency>
    <groupId>com.amazonaws</groupId>
    <artifactId>aws-iot-device-sdk-java</artifactId>
    <version>1.4.20</version>
</dependency>

升级后，直接用原有订阅代码格式替换为共享订阅主题，即可正常触发回调。

额外检查项 #

• 确认AWS IoT Core策略已授权客户端拥有$share/commandGroup/commandTopic/demo主题的iot:Subscribe权限
• 确保共享组内的客户端没有重复订阅逻辑，避免消息被其他客户端抢占（共享订阅的负载均衡由AWS IoT Core自动处理）

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