Step By Step
配置服务端订阅
1、创建消费组
2、创建订阅
参数获取
3、ConsumerGroupId获取位置
4、AccessKeyId、AccessKeySecret及Uid获取
参考地址:阿里云常见参数获取位置
5、iotInstanceId 独享实例需要指定,公共实例配置为空即可。
6、ClientId可以任意指定,例如设置为:tarodemo。
7、Host: ${uid}.iot-amqp.${regionId}.aliyuncs.com
例如:184*.iot-amqp.cn-shanghai.aliyuncs.com
SDK 安装
npm install rhea
Code Sample
const container = require('rhea');
const crypto = require('crypto');
//建立连接。
var connection = container.connect({
//接入域名,请参见AMQP客户端接入说明文档。
'host': '18482************.iot-amqp.cn-shanghai.aliyuncs.com',
'port': 5671,
'transport':'tls',
'reconnect':true,
'idle_time_out':60000,
//userName组装方法,请参见AMQP客户端接入说明文档。其中的iotInstanceId,购买的实例请填写实例ID,公共实例请填空字符串""。
//'username':'${YourClientId}|authMode=aksign,signMethod=hmacsha1,timestamp=1573489088171,authId=${YourAccessKeyId},iotInstanceId=${YourIotInstanceId},consumerGroupId=${YourConsumerGroupId}|',
'username':'tarodemo|authMode=aksign,signMethod=hmacsha1,timestamp=1573489088171,authId=LTAIOZZgYXPsMbDA,iotInstanceId=,consumerGroupId=R45CIUGUE3LJie1uaFjI000100|',
//计算签名,password组装方法,请参见AMQP客户端接入说明文档。
//'password': hmacSha1('${YourAccessKeySecret}', 'authId=${YourAccessKeyId}&timestamp=1573489088171'),
'password': hmacSha1('v7C***********', 'authId=**********&timestamp=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');
}
测试效果
参考链接
Step By Step
配置服务端订阅
1、创建消费组
2、创建订阅
参数获取
3、ConsumerGroupId获取位置
4、AccessKeyId、AccessKeySecret及Uid获取
参考地址:阿里云常见参数获取位置
5、iotInstanceId 独享实例需要指定,公共实例配置为空即可。
6、ClientId可以任意指定,例如设置为:tarodemo。
7、Host: ${uid}.iot-amqp.${regionId}.aliyuncs.com
例如:184*.iot-amqp.cn-shanghai.aliyuncs.com
SDK 安装
npm install rhea
Code Sample
const container = require('rhea');
const crypto = require('crypto');
//建立连接。
var connection = container.connect({
//接入域名,请参见AMQP客户端接入说明文档。
'host': '18482************.iot-amqp.cn-shanghai.aliyuncs.com',
'port': 5671,
'transport':'tls',
'reconnect':true,
'idle_time_out':60000,
//userName组装方法,请参见AMQP客户端接入说明文档。其中的iotInstanceId,购买的实例请填写实例ID,公共实例请填空字符串""。
//'username':'${YourClientId}|authMode=aksign,signMethod=hmacsha1,timestamp=1573489088171,authId=${YourAccessKeyId},iotInstanceId=${YourIotInstanceId},consumerGroupId=${YourConsumerGroupId}|',
'username':'tarodemo|authMode=aksign,signMethod=hmacsha1,timestamp=1573489088171,authId=LTAIOZZgYXPsMbDA,iotInstanceId=,consumerGroupId=R45CIUGUE3LJie1uaFjI000100|',
//计算签名,password组装方法,请参见AMQP客户端接入说明文档。
//'password': hmacSha1('${YourAccessKeySecret}', 'authId=${YourAccessKeyId}&timestamp=1573489088171'),
'password': hmacSha1('v7C***********', 'authId=**********&timestamp=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');
}