nodejs AMQP服務端訂閱的實現

constcontainer=require('rhea');
constcrypto=require('crypto');
//創建Connection。
varconnection=container.connect({
//接入域名，請參見AMQP客戶端接入說明文檔。
'host':'11112560*******.iot-amqp.cn-shanghai.aliyuncs.com',
'port':5671,
'transport':'tls',
'reconnect':true,
'idle_time_out':60000,
//userName組裝方法，請參見AMQP客戶端接入說明文檔。其中的iotInstanceId，企業版實例請填寫實例ID，公共實例直接刪除${YourIotInstanceId}。
'username':'4444444444|authMode=aksign,signMethod=hmacsha1,timestamp=1573489088171,authId=LTAIVne33sFywOG8,iotInstanceId=,consumerGroupId=DEFAULT_GROUP|', 
//計算簽名，password組裝方法，請參見AMQP客戶端接入說明文檔。
'password':hmacSha1('9ViU8**********', 'authId=LTAIVne33sFywOG8&timestamp=1573489088171'),
});
//創建Receiver Link。
varreceiver=connection.open_receiver();
//接收雲端推送消息的回調函數。
container.on('message', function(context) {
varmsg=context.message;
varmessageId=msg.message_id;
vartopic=msg.application_properties.topic;
varcontent=Buffer.from(msg.body.content).toString();
// 輸出內容。
console.log(content);
//發送ACK，注意不要在回調函數有耗時邏輯。
context.delivery.accept();
});
//計算password簽名。
functionhmacSha1(key, context) {
returnBuffer.from(crypto.createHmac('sha1', key).update(context).digest())
.toString('base64');
}