Android使用AWS Amplify接入Greengrass设备影子报已连接Mqtt异常如何解决

常见根因 #

• 重复触发connect调用：代码被生命周期函数（如onResume、配置变更重启Activity）多次执行，导致未完成首次连接就重复发起连接请求
• MQTT clientId冲突：你使用的uuidAsString如果不是每次初始化都生成唯一值，或上一次连接异常断开未通知服务端，服务端会认为同clientId的连接仍存活
• SDK内部状态未同步：之前的连接异常中断时，AWSIotMqttManager内部的连接状态没有更新为断开，调用connect时判定为已连接
• 多SDK冲突：如果同时启用了Amplify的IoT类插件，Amplify会在后台自动初始化MQTT连接，与你手动创建的AWSIotMqttManager产生冲突

修复步骤 #

1. 增加连接状态校验，调用connect前先判断当前状态，非断开状态先手动清理连接

// 初始化MqttManager后先清理历史状态
if (awsIotMqttManager.getConnectionStatus() != AWSIotMqttClientStatus.Disconnected) {
    awsIotMqttManager.disconnect();
}
// 再发起连接
try {
    awsIotMqttManager.connect(credentialsProvider, new AWSIotMqttClientStatusCallback() {
        @Override
        public void onStatusChanged(AWSIotMqttClientStatus status, Throwable throwable) {
            if (status == AWSIotMqttClientStatus.Connected) {
                awsIotMqttManager.subscribeToTopic("$aws/things/thing/shadow/update/documents", AWSIotMqttQos.QOS0, new AWSIotMqttNewMessageCallback() {
                    @Override
                    public void onMessageArrived(String topic, byte[] data) {
                        System.out.println("TOPIC: " + topic);
                        System.out.println(data);
                    }
                });
                String message = "{ \"state\": {\"desired\": {\"message\": \"Hello from ANDROID SDK\"} } }";
                awsIotMqttManager.publishString(message,"$aws/things/thing/shadow/update",AWSIotMqttQos.QOS0);
            }
        }
    });
} catch (Exception e) {
    Log.i("CHECK", e.toString());
}

2. 保证clientId唯一：每次初始化AWSIotMqttManager时生成全新的UUID作为clientId，避免同个账号下clientId重复

String clientId = UUID.randomUUID().toString();
AWSIotMqttManager awsIotMqttManager = new AWSIotMqttManager(clientId,"endpoint");

3. 排查重复调用：在connect调用处增加日志，确认代码仅被执行一次，避免生命周期或业务逻辑重复触发连接
4. 修复消息语法错误：你当前构造的上报影子的JSON末尾多了2个多余闭合括号，会导致消息发布失败，上述代码块中已同步修正
5. 如果你已经在使用Amplify框架，建议直接使用Amplify IoT的API操作设备影子，避免两套AWS SDK混用产生冲突

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