本文介绍使用Node.js语言的AMQP SDK接入阿里云物联网平台,接收服务端订阅消息的示例。
前提条件
已获取消费组ID,并订阅Topic消息。
准备开发环境
支持使用的开发环境为Node.js 8.0.0及以上版本。
下载安装SDK
Node.js版本AMQP SDK,推荐使用rhea。请访问rhea下载库和查看使用说明。
本文示例使用命令npm install rhea
,下载rhea库。
代码示例
- 在Windows系统或Linux系统下载并安装Node.js。本文以Windows 10(64位)系统为例,下载安装包node-v14.15.1-x64.msi。
- 安装成功后,打开CMD窗口,通过以下命令查看node版本。
node --version
- 在本地计算机创建一个JavaScript文件(例如amqp.js),用来存放Node.js示例代码。
示例代码如下,按照以下表格中的参数说明,修改代码中的参数值。
const container = require('rhea');
const crypto = require('crypto');
//创建Connection。
var connection = container.connect({
//接入域名,请参见AMQP客户端接入说明文档。
'host': '${YourHost}',
'port': 5671,
'transport':'tls',
'reconnect':true,
'idle_time_out':60000,
//userName组装方法,请参见AMQP客户端接入说明文档。
'username':'${YourClientId}|authMode=aksign,signMethod=hmacsha1,timestamp=1573489088171,authId=${YourAccessKeyId},iotInstanceId=${YourIotInstanceId},consumerGroupId=${YourConsumerGroupId}|',
//计算签名,password组装方法,请参见AMQP客户端接入说明文档。
'password': hmacSha1('${YourAccessKeySecret}', 'authId=${YourAccessKeyId}×tamp=1573489088171'),
});
//创建Receiver Link。
var receiver = connection.open_receiver();
//接收云端推送消息的回调函数。
container.on('message', function (context) {
var msg = context.message;
var messageId = msg.message_id;
var topic = msg.application_properties.topic;
var content = Buffer.from(msg.body.content).toString();
// 输出内容。
console.log(content);
//发送ACK,注意不要在回调函数有耗时逻辑。
context.delivery.accept();
});
//计算password签名。
function hmacSha1(key, context) {
return Buffer.from(crypto.createHmac('sha1', key).update(context).digest())
.toString('base64');
}
参数 |
示例 |
说明 |
host |
198426864******.iot-amqp.cn-shanghai.aliyuncs.com |
AMQP接入域名。
${YourHost} 对应的AMQP接入域名信息,请参见查看实例终端节点。
|
username |
'test |authMode=aksign,signMethod=hmacsha1,timestamp=1573489088171,authId=LTAI4GFGQvKuq***,iotInstanceId=,consumerGroupId=DEFAULT_GROUP|' |
接入物联网平台的身份认证信息。其中:
${YourClientId} :替换为客户端ID,可自定义,长度不可超过64个字符。建议使用您的AMQP客户端所在服务器UUID、MAC地址、IP等唯一标识。
AMQP客户端接入并启动成功后,登录物联网平台控制台,在对应实例的页签,单击消费组对应的查看,消费组详情页面将显示该参数,方便您识别区分不同的客户端。
${YourAccessKeyId} 、${YourAccessKeySecret} :替换为您物联网平台的AccessKey ID和AccessKey Secret。
登录物联网平台控制台,将鼠标移至账号头像上,然后单击AccessKey管理,获取AccessKey ID和AccessKey Secret。
说明 如果使用RAM用户,您需授予该RAM用户管理物联网平台的权限(AliyunIOTFullAccess),否则将连接失败。授权方法请参见 授权RAM用户访问物联网平台。
${YourIotInstanceId} :替换为实例ID。
您可登录物联网平台控制台,在实例概览找到对应的实例,查看实例ID。
注意 若没有实例概览或ID,直接删除${YourIotInstanceId}即可。
${YourConsumerGroupId} :替换为消费组ID。
登录物联网平台控制台,在对应实例的查看您的消费组ID。
|
password |
hmacSha1('iMS8ZhCDd***', 'authId=LTAI4GFGQ***×tamp=1573489088171') |
- 打开CMD窗口,使用cd命令找到amqp.js文件所在路径,在该路径下使用npm命令下载rhea库。下载后,项目文件如下图所示。
npm install rhea

- 在CMD窗口输入如下命令,运行amqp.js代码,启动AMQP客户端服务器。