學習: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