从后端使用 MQTT over Websockets 连接到 AWS IoT答案

【问题标题】：Connecting to AWS IoT using MQTT over Websockets from the backend从后端使用 MQTT over Websockets 连接到 AWS IoT
【发布时间】：2018-06-14 14:38:27
【问题描述】：

我正在尝试从服务器端连接到 AWS IoT。我不想通过浏览器客户端连接到 AWS IoT。

为了提供更多上下文，我模拟了一个设备（目前只是一个浏览器客户端），它接受输入并通过 Websockets 将其发送到我的服务器。从那里，我想获取该输入，并通过 MQTT 通过 websockets 将其发送到 AWS IoT（或其他方式）。

由于我的设备被限制为只能通过 Websockets 上的另一个协议进行通信，我的客户端不可能直接通过 websockets 进行 MQTT。

把它想象成一个协议转换器，或者只是将接收到的消息从一个套接字隧道化，然后交给另一个。

（客户端）----通过ws发送消息---->（服务器）----使用MQTT发送消息--->（AWS IOT）

我希望这是有道理的。我已经成功运行了很多示例（我的第一个 sn-p 连接到 test.mosquitto.org），并且有 mqttjs 和 AWS IoT sdk。在这个阶段，我只是在努力让连接在我想要使用它的上下文中正常工作。

任何建议或意见将不胜感激。

我的第一个代码 sn-p 是我目前正在尝试的（以及我认为最可行的）

var options = {
    clientId : 1,
    endpoint: 'xxxxxxxxxx.iot.xxxxxxxxxx.amazonaws.com',
    accessKey: 'xxxxxxxxxx',
    secretKey: 'xxxxxxxxxxxxxxxxxxxx',
    regionName: 'xxxxxxxxxx',
    debug: true
};


var client = _mqtt.connect('ws://xxxxxxxxxx.iot.xxxxxxxxxx.com', options);
//var client  = _mqtt.connect('mqtt://test.mosquitto.org');

client.on('connect', function () {
    console.log("MQTT connected");
    client.subscribe('testing')
    client.publish('testing', 'Hello mqtt2')
})

client.on('message', function (topic, message) {
    // message is Buffer
    console.log(message.toString())
    client.end()
})

这是我其他失败的尝试之一。至少这个提供了一个错误。

var device = awsIot.device({
    keyPath: './certs/xxxxxxxxxx-private.pem.key',
    certPath: './certs/xxxxxxxxxx-certificate.pem.crt',
    caPath: './certs/root-CA.crt',
    clientId: 1,
    debug: true,
    host: 'xxxxxxxxxx.iot.xxxxxxxxxx.amazonaws.com'
});

//
// Device is an instance returned by mqtt.Client(), see mqtt.js for full
// documentation.
//
device
    .on('connect', function() {
        console.log('connect');
        device.subscribe('topic_1');
        device.publish('topic_2', JSON.stringify({ test_data: 1}));
    });

device
    .on('message', function(topic, payload) {
        console.log('message', topic, payload.toString());
    });

这是输出/错误

{ keyPath: './certs/xxxxxxxxxx-private.pem.key',
  certPath: './certs/xxxxxxxxxx-certificate.pem.crt',
  caPath: './certs/root-CA.crt',
  clientId: 1,
  debug: true,
  host: 'xxxxxxxxxx.iot.xxxxxxxxxx.amazonaws.com',
  keepalive: 300,
  username: '?SDK=JavaScript&Version=2.2.0',
  reconnectPeriod: 1000,
  fastDisconnectDetection: true,
  resubscribe: false,
  protocol: 'mqtts',
  port: 8883,
  key: <Buffer 2d 2d 2d 2d 2d 42 45 47 49 4e 20 52 53 41 20 50 52 49 56 41 54 45 20 4b 45 59 2d 2d 2d 2d 2d 0a 4d 49 49 45 70 41 49 42 41 41 4b 43 41 51 45 41 32 42 ... >,
  cert: <Buffer 2d 2d 2d 2d 2d 42 45 47 49 4e 20 43 45 52 54 49 46 49 43 41 54 45 2d 2d 2d 2d 2d 0a 4d 49 49 44 57 54 43 43 41 6b 47 67 41 77 49 42 41 67 49 55 53 33 ... >,
  ca: <Buffer 2d 2d 2d 2d 2d 42 45 47 49 4e 20 43 45 52 54 49 46 49 43 41 54 45 2d 2d 2d 2d 2d 0d 0a 4d 49 49 45 30 7a 43 43 41 37 75 67 41 77 49 42 41 67 49 51 47 ... >,
  requestCert: true,
  rejectUnauthorized: true }
attempting new mqtt connection...
net.js:617
    throw new TypeError('invalid data');
    ^

TypeError: invalid data
    at TLSSocket.Socket.write (net.js:617:11)

【问题讨论】：

为什么服务器必须使用websockets，为什么不能使用native MQTT？
在这个用例中，服务器的客户端必须使用 websockets。服务器到物联网（使用 MQTT）不必这样做。除非我误解了什么，否则我认为我的第二个代码 sn-p 使用的是本机 MQTT（我也无法正常工作）

标签： javascript websocket mqtt aws-iot aws-sdk-ios

【解决方案1】：

找到问题了！

我得到了第一个提议的代码 sn-p 工作：

clientId 未封装在引号中
我没有向 AWS IoT 控制台上的现有事物添加策略

我仍然对我的第二次尝试是否可能感到好奇，所以如果您有任何建议，请提供见解。

【讨论】：