快捷導(dǎo)航

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

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

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

一、MQTT

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

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

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

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

MQTTAsync_setCallbacks中，

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

另外，就是一些函數(shù)執(zhí)行是否成功的回調(diào)函數(shù)，C語(yǔ)言封裝回調(diào)之后，就是這么寫法，看起來(lái)有些變扭。有興趣的可以看《淺談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ù)中），在編程最好將參數(shù)中傳進(jìn)來(lái)的值在內(nèi)存中拷貝一份再操作，筆者當(dāng)時(shí)開發(fā)時(shí)，就是因?yàn)檫@樣的問題，折騰了較長(zhǎng)時(shí)間，后來(lái)在wireshark中發(fā)現(xiàn)數(shù)據(jù)包中根本沒有內(nèi)容，才知道是由于函數(shù)參數(shù)是指針形式，直接在異步中使用可能會(huì)發(fā)生一些未知的錯(cuò)誤。

參考文檔：

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())
})

補(bǔ)充：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

您可能感興趣的文章: