Node.js SDK接入示例

更新时间：2024-07-30 GMT+08:00

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

开发环境

本示例所使用的开发环境为Node.js 8.0.0及以上版本。请前往Node.js官网下载。安装成功之后可以通过以下命令查看node版本。

node --version

如果能够查询到node版本，且版本高于8.0.0则代表安装成功。

代码示例

在本地计算机创建一个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();
 });