目錄
一、MQTT介紹
二、MQTT概念
? 2.1 訂閱(Subscribtion)
? 2.2?會話（Session）
? 2.3 主題名（Topic Name）
? ?2.4 主題篩選器（Topic Filter）
? ?2.5 消息訂閱
三、MQTT中的角色
3.1 客戶端
3.2 服務器
四、X86平臺安裝mosquitto
4.1 下載?mosquitto 服務器
4.2?下載 mosquitto 客戶端
4.3?mosquitto 命令
? ?4.3.1??mosquitto
? ?4.3.2??mosquitto_pub
? ?4.3.3??mosquitto_sub
五、軟件測試?
六、QT使用MQTT?
? ?6.1 MQTT初始化
? ? 6.1.1 源碼下載
? ? 6.2.1 將源碼添加到工程?
? ?6.3.1 添加頭文件路徑?
?6.4.1 編譯
? 6.5.1 mqtt初始化?
? 6.6.1mqtt信號與槽
? ?6.7.1 MQTT發(fā)布
?
一、MQTT介紹
? ? MQTT
（
Message Queuing Telemetry Transport
， 消 息 隊 列 遙 測 傳 輸 協(xié) 議 ）， 是 一 種 基于發(fā)布
/
訂 閱 publish/subscribe）模式的
"
輕量級
"
通訊協(xié)議，該協(xié)議構(gòu)建于
TCP/IP
協(xié)議上，由
IBM
在
1999
年發(fā)布。
MQTT
最大優(yōu)點在于，可以以極少的代碼和有限的帶寬，為連接遠程設備提供實時可靠的消息服務。作為一種低開銷、低帶寬占用的即時通訊協(xié)議，使其在物聯(lián)網(wǎng)、小型設備、移動應用等方面有較廣泛的應用。
MQTT
是一個基于客戶端
-
服務器的消息發(fā)布
/
訂閱傳輸協(xié)議。
MQTT
協(xié)議是輕量、簡單、開放和易于實現(xiàn)的，
? ?這些特點使它適用范圍非常廣泛。在很多情況下，包括受限的環(huán)境中，如：機器與機器（
M2M
）通信和物聯(lián)網(wǎng)（IoT
）。其在，通過衛(wèi)星鏈路通信傳感器、偶爾撥號的醫(yī)療設備、智能家居、及一些小型化設備中已廣泛使用。
二、MQTT概念
? 2.1 訂閱(Subscribtion)
? ?訂閱包含主題篩選器（
Topic Filter
）和最大服務質(zhì)量（
QoS
）。訂閱會與一個會話（
Session
）關(guān)聯(lián)。一個會話可以包含多個訂閱。每一個會話中的每個訂閱都有一個不同的主題篩選器。
? 2.2?會話（Session）
? ? 每個客戶端與服務器建立連接后就是一個會話，客戶端和服務器之間有狀態(tài)交互。會話存在于一個網(wǎng)絡之間,也可能在客戶端和服務器之間跨越多個連續(xù)的網(wǎng)絡連接。
? 2.3 主題名（Topic Name）
? ?連接到一個應用程序消息的標簽，該標簽與服務器的訂閱相匹配。服務器會將消息發(fā)送給訂閱所匹配標簽的每個客戶端。
? 需要注意的是，
MQTT
中消息主題按照層級命名，使用 ‘/’ 進行分割
? 此外，主題中可以使用通配符進行多個主題或多層級的訂閱，有兩種常見的通配符：
1.
單層通配符
+
：單層通配符只能匹配一層的主題，例如：
China/Beijing/+
，可以匹配的只有
Beijing
這個主 題下面一層的主題，例如 Xicheng, DongCheng, Xuanwu
等等。
2.
多層通配符
#
：顧名思義，多層通配符就是可以匹配多個層級的主題，例如：
China/#
，可以匹配到的主題可能有：China/Beijing/Dongcheng, China/Shanghai/PuDong
，等等。
? ?2.4 主題篩選器（Topic Filter）
一個對主題名通配符篩選器，在訂閱表達式中使用，表示訂閱所匹配到的多個主題。
? ?2.5 消息訂閱
消息訂閱者所具體接收的內(nèi)容。
三、MQTT中的角色
?1. Publisher 和 Subscriber 為客戶端，Broker 為服務器端，消息主題為消息類型，Broker 根據(jù) Topic 過濾消息，并將消息向客戶端推送。
2. MQTT
中用
QoS
表示服務質(zhì)量，
MQTT
協(xié)議中有三種服務質(zhì)量
(QoS)
：
? 1
）
QoS =0
，至多一次，可能會出現(xiàn)丟包的情況，使用在對實時性要求不高的情況，例如，將此服務質(zhì)量與通信環(huán)境傳感器數(shù)據(jù)一起使用。 對于是否丟失個別讀取或是否稍后立即發(fā)布新的讀取并不重要。
? 2
）
QoS =1,
至少一次，保證包會到達目的地，但是可能出現(xiàn)重包。
? 3
）
QoS =2,
剛好一次，保證包會到達目的地，且不會出現(xiàn)重包的現(xiàn)象。
3.1 客戶端
1. Publisher 和 Subscriber 都屬于客戶端。2. 發(fā)布應用消息給其它相關(guān)的客戶端。3. 訂閱以請求接受相關(guān)的應用消息。4. 取消訂閱以移除接受應用消息的請求。5. 從服務端斷開連接
3.2 服務器
1. 服務器端即所謂的 MQTT Broker 服務器。2. 接受來自客戶端的網(wǎng)絡連接。3. 接受客戶端發(fā)布的應用消息。4. 處理客戶端的訂閱和取消訂閱請求。5. 轉(zhuǎn)發(fā)應用消息給符合條件的已訂閱客戶端。6. MQTT 提供的公共服務器端（ Broker ）有：?1) test.mosquitto.org?2) broker.hivemq.com?3) iot.eclipse.org
?
四、X86平臺安裝mosquitto
4.1 下載?mosquitto 服務器
命令：
sudo apt-get install mosquitto4.2?下載 mosquitto 客戶端
sudo apt-get install mosquitto-clients4.3?mosquitto 命令
? ?4.3.1??mosquitto
啟動服務器的命令
,
在
Ubuntu
里已經(jīng)啟動了。
? ?4.3.2??mosquitto_pub
發(fā)布消息使用的命令
mosquitto_pub -h 192.168.0.137 -t "house" -m "500"
-h
是指定從哪個服務器發(fā)布
-t
是指定發(fā)布哪個主題
-m
是消息的內(nèi)容
? ?4.3.3??mosquitto_sub
訂閱消息使用的命令
mosquitto_sub -h 192.168.0.137 -t "house" -v
-h 是指定從哪個服務器訂閱；
-t
是指定訂閱哪個主題；
-v
的意思是收到消息打印出來
五、軟件測試?
windows
安裝
mqttfx-1.7.1-windows-x64.exe
測試軟件并打開
?
?
?
測試結(jié)果：
?
六、QT使用MQTT?
? ?6.1 MQTT初始化
? ? 6.1.1 源碼下載
https://github.com/emqx/qmqtt
使用這個庫
Qt
版本必須大于
5.3
，它有兩個版本
: master
和
release
版本
,
我們在此用
release
版本
?
? ? 6.2.1 將源碼添加到工程?
?
添加到network模塊
?
? ?
? ?6.3.1 添加頭文件路徑?
出錯：解決方法
?
?6.4.1 編譯
?
出錯
解決方法：
?
? 6.5.1 mqtt初始化?
QMQTT::Client *mqttClient ;
QString clientID;
qsrand(QTime(0,0,0).msecsTo(QTime::currentTime()));
clientID = "XYD-CXX"+QString::number(qrand()); //合成 mqtt id
//mqtt 初始化
mqttClient = new QMQTT::Client(ui->lEditServerIP->text(), 1883);
mqttClient->setClientId(clientID); //ClientId 不能重復，不然會覆蓋之前連接的人的
//mqttClient->setUsername("user"); //服務器賬號密碼，不需要則不用
//mqttClient->setPassword("password");
mqttClient->connect();? 6.6.1mqtt信號與槽
//mqtt 連接成功
connect(mqttClient,SIGNAL(connected()),this,SLOT(doProcessMqttConnected()));
//mqtt 退出成功
connect(mqttClient,SIGNAL(disconnected()),this,SLOT(doProcessMqttDisconnected()));
//mqtt 訂閱成功
connect(mqttClient,SIGNAL(subscribed(QString)),this,SLOT(doProcessMqttSubscribe(QSt
ring)));
//mqtt 訂閱到消息
connect(mqttClient,SIGNAL(received(QMQTT::Message)),this,SLOT(doProcessMqttReceived
(QMQTT::Message)));? ?6.7.1 MQTT發(fā)布
if(mqttIsConnected)
{
QMQTT::Message msg;
msg.setTopic(ui->lEditPub->text()); //發(fā)布的主題
//發(fā)布的內(nèi)容,QString 轉(zhuǎn) QByteArray
msg.setPayload(ui->lEditPubPayload->text().toLatin1());
mqttClient->publish(msg);
}? ?訂閱成功的槽函數(shù)：一般不用這個文章來源：http://www.zghlxwxcb.cn/news/detail-542136.html
void MqttForm::doProcessMqttSubscribe(QString topic)
{
//qDebug()<< topic + "is Subscribe";
}收到信息的槽函數(shù)：文章來源地址http://www.zghlxwxcb.cn/news/detail-542136.html
void MqttForm::doProcessMqttReceived(QMQTT::Message msg)
{
qDebug() << "topic:" + msg.topic();
qDebug() << "payload:" + msg.payload();
}到了這里，關(guān)于嵌入式QT- QT使用MQTT的文章就介紹完了。如果您還想了解更多內(nèi)容，請在右上角搜索TOY模板網(wǎng)以前的文章或繼續(xù)瀏覽下面的相關(guān)文章，希望大家以后多多支持TOY模板網(wǎng)！
