0

我使用“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();

传输.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 连接，请分享。

4

1 回答 1

0

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

于 2021-06-26T06:29:21.140 回答