设备接入 IOTDA-Node.js SDK接入示例:代码示例

时间：2024-07-30 14:22:53

设备接入 IOTDA

代码示例

在本地计算机创建一个JavaScript文件(例：HwIotAmqpClient.js)，保存以下示例代码到文件中。参考AMQP客户端接入说明修改相关连接参数。

const container = require('rhea');
//获取当前时间戳
var timestamp = Math.round(new Date());

//建立连接。
var connection = container.connect({
     //接入 域名 ，请参考这里。
     'host': '${UUCID}.iot-amqps.cn-north-4.myhuaweicloud.com',
     'port': 5671,
     'transport': 'tls',
     'reconnect': true,
     'idle_time_out': 8000,
     //userName组装方法，请参考这里。
      'username': 'accessKey=${yourAccessKey}|timestamp=' + timestamp + '|instanceId=${instanceId}',
     //accessCode，请参考这里。
     'password': '${yourAccessCode}',
     'saslMechannisms': 'PLAIN',
     'rejectUnauthorized': false,
     'hostname': 'default',
});

//创建Receiver连接。 队列名，可以使用默认队列DefaultQueue
var receiver = connection.open_receiver('${yourQueue}');

//接收云端推送消息的回调函数。
container.on('message', function (context) {
     var msg = context.message;
     var content = msg.body;
     console.log(content);
     //发送ACK，注意不要在回调函数有耗时逻辑。
     context.delivery.accept();
 });