设备接入 IoTDA设备接入 IoTDA

更新时间:2021/07/21 GMT+08:00
分享

Node.js SDK接入示例

本文介绍使用Node.js语言的AMQP SDK接入华为云物联网平台,接收服务端订阅消息的示例。

开发环境

本示例所使用的开发环境为Node.js 8.0.0及以上版本。

下载SDK

Node.js版本AMQP SDK,推荐使用rhea。请访问rhea下载库和查看使用说明。

添加依赖

在package.json中添加以下依赖。

"dependencies": {
    "rhea": "^1.0.12"
 }

代码示例

您可以单击此处获取Node.js SDK接入示例,Demo中涉及的参数说明,请参考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 + '|',
     //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();
 });
分享:

    相关文档

    相关产品