aws-iot-device-sdk Thing Shadow 断开设备答案

【问题标题】：aws-iot-device-sdk Thing Shadow disconnecting deviceaws-iot-device-sdk Thing Shadow 断开设备
【发布时间】：2021-09-01 22:12:55
【问题描述】：

我使用“aws-iot-device-sdk”为 AWS IoT 编写了代码。我能够创建设备并发布。设备不会在两者之间断开连接。（独立）我还能够创建影子设备并正确发布、订阅（独立）。

但是，当我连接 2 时，设备不断断开并重新连接。

我已搜索但找不到任何解决方案。

下面是我写的代码。请指教我做错了什么

index.js

const fs = require('fs');

const Constants = require('./constants');
const Transmission = require('./transmission');
const ThingShadow = require('./thingShadow');

execute = () => {
  ThingShadow.shadowing();
  Transmission.transmit();
}

execute();

thingShadow.js

const awsIot = require('aws-iot-device-sdk');
const Constants = require('./constants');
const utils = require('./utils');

var thingShadows;

shadowing = () => {
    thingShadows = awsIot.thingShadow({
        keyPath: Constants.ACTUAL_KEY_PATH,
        certPath: Constants.ACTUAL_CERT_PATH,
        caPath: Constants.CA_PATH,
        clientId: Constants.THING_NAME,
        host: Constants.HOST
    });

    thingShadows.on('connect', function () {
        thingShadows.register(Constants.THING_NAME);
    });

    thingShadows.on('status',
        function (thingName, stat, clientToken, stateObject) {
            console.log('received ' + stat + ' on ' + thingName + ': ' +
                JSON.stringify(stateObject));
        });

    thingShadows.on('delta',
        function (thingName, stateObject) {
            console.log(`Delta received `);
        });

    thingShadows.on('timeout',
        function (thingName, clientToken) {
            console.log('received timeout ' + ' on ' + operation + ': ' +
                clientToken);
        });
}

module.exports = {
    shadowing
}

// shadowing();

transmission.js

const awsIot = require('aws-iot-device-sdk');
const Constants = require('./constants');
const utils = require('./utils');

let data = {
    "records":{
       "key1":"value1",
       "key2":"value2",
       "key3":"value3"
    }
 };

 let device;
 transmit = () => {
    // create device
    device = awsIot.device({
        keyPath: Constants.ACTUAL_KEY_PATH,
        certPath: Constants.ACTUAL_CERT_PATH,
        caPath: Constants.CA_PATH,
        clientId: Constants.THING_NAME,
        host: Constants.HOST
    });

    device.on('connect', function () {
        console.log('Connected to AWS');
        callPublisher();
    });

    device.on('error', function(err) {
        console.log(error);
    });

    device.on('message', function (topic, payload) {
        console.log(`Topic : ${topic}`);
        console.log(`Payload : ${payload}`);
        if (topic === `MyTopic`) {
            device.publish(`MyTopic`, JSON.stringify(data));
        } else {
            console.log('Something else');
        }
    });

    device
      .on('close', function() {
         console.log('close');
   });
   device
      .on('reconnect', function() {
         console.log('reconnect');
      });
   device
      .on('offline', function() {
         console.log('offline');
      });
   device
      .on('error', function(error) {
         console.log('error', error);
      });
}

callPublisher = () => {
    data.records.key1 = 10;
    data.records.key2 = 20;
    device.publish(`MyTopic`, JSON.stringify(data));
    console.log(`Data sent : ${JSON.stringify(data)}`);
}

module.exports = {
    transmit
}
// transmit();

下面是程序的输出

Connected to AWS
offline
close
reconnect
Data sent : {"records":{"key1":"10","key2":"20","key3":"value3"}}

如果有人有连接 mqtt.js 和 nodejs 的链接/代码，请分享。

【问题讨论】：

如果设备不断断开并重新连接，则可能有 2 个问题。 1. 设备证书绑定的安全策略可能有误。 2.会有DUPLICATE_CLIENT_ID。请将您的设备政策添加到问题中

标签： node.js amazon-web-services aws-iot aws-iot-core

【解决方案1】：

感谢@MehmetaliSaraç。问题是由于创建了具有相同客户端 ID 的对象和影子。这导致重复客户端 ID 问题导致其中一个对象断开连接。我制作了一个对象和阴影都使用的单例对象。问题已解决。

【讨论】：