MQTT Client實現(xiàn)消息推送功能的方法詳解

更新時間：2023年05月31日 09:05:30 作者：蒙奇·D·伊麗莎白

這篇文章主要介紹了MQTT Client實現(xiàn)消息推送功能的方法,結(jié)合實例形式詳細分析了MQTT Client實現(xiàn)消息推送的基本原理、實現(xiàn)方法與相關操作注意事項,需要的朋友可以參考下

一、MQTT

二、MQTT C Client實戰(zhàn)

了解更多可以閱讀《MQTT C Client for Posix and Windows》一文，下面根據(jù)官網(wǎng)資料，摘錄了幾個C語言實現(xiàn)MQTT的小DEMO。

MQTT使用起來也十分容易，基本上就那四五個函數(shù)：MQTTClient_create（創(chuàng)建客戶端）、MQTTClient_connect（連接服務端）、MQTTClient_publishMessage（客戶端->服務端發(fā)送消息）、MQTTClient_subscribe（客戶端訂閱某個主題）等等。其中，很多異步回調(diào)函數(shù)，需要自己去實現(xiàn)，如，

MQTTAsync_setCallbacks(mqtt->_client, mqtt->_client, connlost, msgarrvd, NULL);

MQTTAsync_setCallbacks中，

connlost函數(shù)指針，是當MQTT意外斷開鏈接時會回調(diào)的函數(shù)，由自己實現(xiàn)；
msgarrvd函數(shù)指針，是當服務器有消息推送回來時，客戶端在此處接受服務端消息內(nèi)容。

另外，就是一些函數(shù)執(zhí)行是否成功的回調(diào)函數(shù)，C語言封裝回調(diào)之后，就是這么寫法，看起來有些變扭。有興趣的可以看《淺談C/C++回調(diào)函數(shù)（Callback）& 函數(shù)指針》文章，再了解以下回調(diào)函數(shù)。

mqtt->_conn_opts.onSuccess = onConnect;
mqtt->_conn_opts.onFailure = onConnectFailure;

最后，不得不說的就是，MQTT有些發(fā)送或者是訂閱的內(nèi)容時（某些函數(shù)中），在編程最好將參數(shù)中傳進來的值在內(nèi)存中拷貝一份再操作，筆者當時開發(fā)時，就是因為這樣的問題，折騰了較長時間，后來在wireshark中發(fā)現(xiàn)數(shù)據(jù)包中根本沒有內(nèi)容，才知道是由于函數(shù)參數(shù)是指針形式，直接在異步中使用可能會發(fā)生一些未知的錯誤。

參考文檔：

https://yq.aliyun.com/articles/521549?spm=5176.10695662.1996646101.searchclickresult.39f82372vfl8ed

三、MQTT client for Node.js

Installation

#You can install it as dependency with npm.
$?#?save?into?package.json?dependencies?with?-S?
$?npm?install?aliyun-iot-mqtt?-S

Usage

Aliyun IoT Hub mqtt client with authrozied by productKey & deviceName & deviceSecret.

GET Data

const?Mqtt?=?require('aliyun-iot-mqtt');
const?client?=?Mqtt.getAliyunIotMqttClient({
????productKey:?"",
????deviceName:?"",
????deviceSecret:?"",
????regionId:?"cn-shanghai",
????keepalive:120?//?mqtt?options
});
client.on('connect',?function()?{
????console.log("connect")
})
client.end(function?(){
????console.log("end")
})

TLS mqtts

aliyun_iot_root.cer

var?trustedCA?=?fs.readFileSync(path.join(__dirname,?'/aliyun_iot_root.cer'))
var?options?=?{
????productKey:?"",
????deviceName:?"",
????deviceSecret:?"",
????regionId:?"cn-shanghai",
????protocol:?'mqtts',
????ca:?trustedCA,
????keepalive:120?//?mqtt?options
};

Subscribe Topic

client.subscribe(topic)

Publish Message

client.publish(topic,?'Hello?mqtt')
client.publish(topic,?'Hello?mqtt',?{?qos:?1?})

Receive Message

client.on('message',?function(topic,?message)?{
????console.log(topic+","?+?message.toString())
})

補充：nodejs發(fā)送訂閱mqtt完整示例：

var mqtt = require('mqtt');
var opt={
    port:1883
}
var client=mqtt.connect('tcp://10.66.28.51',opt);
client.on('connect',function(){
    console.log("mqtt已連接");
    // client.publish('wks/cim/ASPY/#','需要發(fā)送的信息');
    client.subscribe('wks/cim/ASPY/#')
})
client.on('message',function(topic,msg){
    console.log('收到'+topic+"訊息："+msg.toString());
})

參考文檔：

https://www.npmjs.com/package/aliyun-iot-mqtt

您可能感興趣的文章: