學習:MQTT協議及原理


1 MQTT協議實現方式:

實現MQTT協議需要客戶端和服務器端通訊完成,在通訊過程中,MQTT協議中有三種身份:發布者(Publish)、代理(Broker)(服務器)、訂閱者(Subscribe)。其中,消息的發布者和訂閱者都是客戶端,消息代理是服務器,消息發布者可以同時是訂閱者。

服務器端:消息代理

客戶端:主要消息的發布者和訂閱

MQTT傳輸的消息分為:主題(Topic)和負載(payload)兩部分:

(1)Topic,可以理解為消息的類型,訂閱者訂閱(Subscribe)后,就會收到該主題的消息內容(payload);

(2)payload,可以理解為消息的內容,是指訂閱者具體要使用的內容。

2  網絡傳輸與應用消息

MQTT會構建底層網絡傳輸:它將建立客戶端到服務器的連接,提供兩者之間的一個有序的、無損的、基於字節流的雙向傳輸。

當應用數據通過MQTT網絡發送時,MQTT會把與之相關的服務質量(QoS)和主題名(Topic)相關連。

3 MQTT客戶端

一個使用MQTT協議的應用程序或者設備,它總是建立到服務器的網絡連接。客戶端可以:

(1)發布其他客戶端可能會訂閱的信息;  //發布消息

(2)訂閱其它客戶端發布的消息;            //訂閱消息

(3)退訂或刪除應用程序的消息;    //退訂消息

(4)斷開與服務器連接。        //斷開,連接服務器

4  MQTT服務器

MQTT服務器以稱為“消息代理”(Broker),可以是一個應用程序或一台設備。它是位於消息發布者和訂閱者之間,它可以:

(1)接受來自客戶的網絡連接;         //接受客戶端連接

(2)接受客戶發布的應用信息;        //接收客戶端發布的消息

(3)處理來自客戶端的訂閱和退訂請求;    //處理消息的訂閱及退訂

(4)向訂閱的客戶轉發應用程序消息。     //推送消息

5  MQTT協議中的訂閱、主題、會話

一、訂閱(Subscription)

訂閱包含主題篩選器(Topic Filter)和最大服務質量(QoS)。訂閱會與一個會話(Session)關聯。一個會話可以包含多個訂閱。每一個會話中的每個訂閱都有一個不同的主題篩選器

二、會話(Session)

每個客戶端與服務器建立連接后就是一個會話,客戶端和服務器之間有狀態交互。會話存在於一個網絡之間,也可能在客戶端和服務器之間跨越多個連續的網絡連接。

三、主題名(Topic Name)----------事件名稱,根據訂閱主題名稱來匹配是否往客戶端發送消息

連接到一個應用程序消息的標簽,該標簽與服務器的訂閱相匹配。服務器會將消息發送給訂閱所匹配標簽的每個客戶端。

四、主題篩選器(Topic Filter)

一個對主題名通配符篩選器,在訂閱表達式中使用,表示訂閱所匹配到的多個主題。

五、負載(Payload) ------------消息體

消息訂閱者所具體接收的內容

6  MQTT協議中的方法

MQTT協議中定義了一些方法(也被稱為動作),來於表示對確定資源所進行操作。這個資源可以代表預先存在的數據或動態生成數據,這取決於服務器的實現。通常來說,資源指服務器上的文件或輸出。主要方法有:

(1)Connect。等待與服務器建立連接。

(2)Disconnect。等待MQTT客戶端完成所做的工作,並與服務器斷開TCP/IP會話。

(3)Subscribe。等待完成訂閱

(4)UnSubscribe。等待服務器取消客戶端的一個或多個topics訂閱。

(5)Publish。MQTT客戶端發送消息請求,發送完成后返回應用程序線程。

5  MQTT協議數據包結構

在MQTT協議中,一個MQTT數據包由:固定頭(Fixed header)、可變頭(Variable header)、消息體(payload)三部分構成。MQTT數據包結構如下:

 

(1)固定頭(Fixed header)。存在於所有MQTT數據包中,表示數據包類型及數據包的分組類標識。

(2)可變頭(Variable header)。存在於部分MQTT數據包中,數據包類型決定了可變頭是否存在及其具體內容。

(3)消息體(Payload)。存在於部分MQTT數據包中,表示客戶端收到的具體內容

5.1  MQTT固定頭

固定頭存在於所有MQTT數據包中,其結構如下:

 
 

5.1.1  MQTT數據包類型

位置:Byte 1中bits 7-4。

相於一個4位的無符號值,類型、取值及描述如下:

 
 

5.1.2  標識位

位置:Byte 1中bits 3-0。

在不使用標識位的消息類型中,標識位被作為保留位。如果收到無效的標志時,接收端必須關閉網絡連接:

 
 

(1)DUP:發布消息的副本。用來在保證消息的可靠傳輸,如果設置為1,則在下面的變長中增加MessageId,並且需要回復確認,以保證消息傳輸完成,但不能用於檢測消息重復發送。

(2)QoS:發布消息的服務質量,即:保證消息傳遞的次數

             Ø00:最多一次,即:<=1

            Ø01:至少一次,即:>=1

            Ø10:一次,即:=1

            Ø11:預留

(3)RETAIN: 發布保留標識,表示服務器要保留這次推送的信息,如果有新的訂閱者出現,就把這消息推送給它,如果設有那么推送至當前訂閱者后釋放。

5.1.3  剩余長度(Remaining Length)

地址:Byte 2。

固定頭的第二字節用來保存變長頭部和消息體的總大小的,但不是直接保存的。這一字節是可以擴展,其保存機制,前7位用於保存長度,后一部用做標識。當最后一位為1時,表示長度不足,需要使用二個字節繼續保存。例如:計算出后面的大小為0

5.2  MQTT可變頭

MQTT數據包中包含一個可變頭,它駐位於固定的頭和負載之間。可變頭的內容因數據包類型而不同,較常的應用是作為包的標識:

 
 

很多類型數據包中都包括一個2字節的數據包標識字段,這些類型的包有:PUBLISH (QoS > 0)、PUBACK、PUBREC、PUBREL、PUBCOMP、SUBSCRIBE、SUBACK、UNSUBSCRIBE、UNSUBACK。

5.3  Payload消息體

 
 

Payload消息體位MQTT數據包的第三部分,包含CONNECT、SUBSCRIBE、SUBACK、UNSUBSCRIBE四種類型的消息:

(1)CONNECT,消息體內容主要是:客戶端的ClientID、訂閱的Topic、Message以及用戶名和密碼。

(2)SUBSCRIBE,消息體內容是一系列的要訂閱的主題以及QoS。

(3)SUBACK,消息體內容是服務器對於SUBSCRIBE所申請的主題及QoS進行確認和回復。

(4)UNSUBSCRIBE,消息體內容是要訂閱的主題。



鏈接:https://www.jianshu.com/p/5c42cb0ed1e9






免責聲明!

本站轉載的文章為個人學習借鑒使用,本站對版權不負任何法律責任。如果侵犯了您的隱私權益,請聯系本站郵箱yoyou2525@163.com刪除。



 
粵ICP備18138465號   © 2018-2025 CODEPRJ.COM