1. 程式人生 > >深度剖析MQTT協議的整個通信流程

深度剖析MQTT協議的整個通信流程

建立連接 開源 中國移動 tcp 按鈕 硬件 qos p地址 OS

http://www.elecfans.com/d/587483.html

MQTT,目前物聯網的最主要的協議,基本所有收費的雲平臺都是基於MQTT協議,比如機智雲,和所有的開放雲平臺比如中國移動的oneNet、百度的雲平臺也都支持MQTT的接入。雖然MQTT很火,但是目前對MQTT的很少,尤其是在如何移植到嵌入式上來。大部分的平臺商的做法都是跟模塊商合作把MQTT協議集成到WiFi模塊跟GPRS模塊裏面,捆綁一銷售,不讓用戶過多的了解物聯網最核心的東西。

在還沒有深入去了解MQTT協議之前,總以為是非常復雜的東西,畢竟之前一直想深入,但無奈在浩渺的網絡裏居然找不到太多實質的資料。隨時自己對物聯網的不斷探索,越來越了解整個物聯網的架構,對MQTT了解越來越深入。在這篇文章中將帶大家先了解MQTT的協議,在後面的文章,再帶大家怎麽移植MQTT到STM32上,再到怎麽搭建自己的MQTT服務器。

MQTT的基礎知識這些大家通過百度知道都可以了解到,這裏主要深入去剖析MQTT協議的整個通信流程。但是如果只是看文字話,大家很難理解。因此我們借助Windows下的MQTT客戶端MQTT.fx跟網絡抓包工具Wireshark來一步步分析MQTT。

名字 流向 描述
CONNECT 1 C->S 客戶端請求與服務端建立連接
CONNACK 2 S->C 服務端確認連接建立
PUBLISH 3 CóS 發布消息
PUBACK 4 CóS 收到發布消息確認
PUBREC 5 CóS 發布消息收到
PUBREL 6 CóS 發布消息釋放
PUBCOMP 7 CóS 發布消息完成
SUBSCRIBE 8 C->S 訂閱請求
SUBACK 9 S->C 訂閱確認
UNSUBSCRIBE 10 C->S 取消訂閱
UNSUBACK 11 S->C 取消訂閱確認
PING 12 C->S 客戶端發送PING(連接保活)命令
PINGRSP 13 S->C PING命令回復
DISCONNECT 14 C->S 斷開連接

上面是MQTT的主要的通信協議,MQTT是基於TCP長連接,首先是先跟MQTT服務器建立TCP連接,然後發送登錄請求,要保持長連接,還要定時發心跳包跟服務保持連接。我們先用MQTT.fx來登錄開源的MQTT服務看看。

技術分享圖片

安裝好MQTT.fx(註意MQTT.fx是java開發的,電腦要安裝JDK才能安裝打開),一打開裏面就默認有一個開源的MQTT服務M2M Eclipse。點開旁邊的齒輪(設置按鈕)可以看服務器的域名m2m.eclipse.org,端口號1833(MQTT的默認端口號),下面還有個Keep Alive Interval就是心跳的時間。再打開Wireshark,選擇要捕獲的網絡接口,然後再過濾器輸入tcp.port==1883後回車,只捕獲1883這個端口號的數據包。再點下MQTT.fx的Connect連接服務器,就可以看到Wireshark捕到的數據

技術分享圖片

技術分享圖片

可以看到MQTT協議中本地給服務器發送了一個Connect登錄請求,然後,服務器回應一個ACK,表示登錄成功。再雙擊Connect Command這條數據包,我們可以看到詳細的數據包數據

技術分享圖片

上面的解析出來的MQTT協議包的內部,下面是對應的二進制數據,這裏我們可以對照附件上資料去了解協議的內容。看這裏,大家想是不是如果自己用TCP,再封裝發送下面的二進制數據就可以完成MQTT的登錄了呢?拿出網絡調試助手來,ping下m2m.eclipse.org得到IP地址,用端口號1883連接,然後發送Wireshark捕到的MQTT登錄協議的二進制數據,可以看到到服務器回應了 20 02 00 00 表示登錄成功。

技術分享圖片

再往下Wireshark捕到的數據包,可以看到每隔一定的時間,本地向服務器發送Ping Request心跳包,相應的服務器也會回應Ping Response。

技術分享圖片

接下來看MQTT最核心的傳輸協議 Subcribe(定閱)和Publish(推送)。簡單來說就是客戶端口(比如物聯網硬件)Subcribe一個topic(主題)後,其它的客戶端(比如手機)向服務器往這個topic 推送 Payload(有效數據),服務器就會把Payload轉發給定閱這個topic的客戶端(硬件)。

這樣就實現了客戶端(手機)通過服務器(MQTT)遠程發送數據給客戶端(物聯網硬件)。一樣用MQTT.fx來實驗。先點Subscribe然後面下面輸入led再點旁邊的Subscribe按鈕來定閱led這個topic。然後回到Publish,一樣在輸入框輸入led這個topic,下面大框就是輸入要推送的數據,輸入on,再點Publish按鈕,就把數據推送出去了。再回到Subcribe界面來可以看到右邊已經收到有推送過來的數據。如果這是硬件收到這個指令,就可以去控制點亮LED,我們就實現遠程控制LED燈。

技術分享圖片

技術分享圖片

想深入了解MQTT這一個過程的話,我們再回到Wireshark,來看看捕獲到的數據

技術分享圖片

具體的就不詳細的分析了,大家看附件的文檔來對照就可以很容易了解到。

最後來了解下QoS(定閱等級),分0、1、2三個等級,簡單來說是等級越高越可靠。QoS0,就是推送之後就完事了,至於對方有沒有收到,收到是什麽,數據有沒有丟失,都不管。

QoS1的話就是你收到推送後,你還得返回一個puback給對方,告訴對方收到了,不然對方會以為你沒收到,隔一段時間後重新給你推送,直到你給對方返回一個Puback為止。

技術分享圖片

深度剖析MQTT協議的整個通信流程