物聯網協議MQTT

MQTT(消息隊列遙測傳輸)是ISO 標準(ISO/IEC PRF 20922)下基于發布/訂閱范式的消息協議。它工作在 TCP/IP協議族上，是為硬件性能低下的遠程設備以及網絡狀況糟糕的情況下而設計的發布/訂閱型消息協議，為此，它需要一個消息中間件?。

MQTT是一個基于客戶端-服務器的消息發布/訂閱傳輸協議。由IBM在1999年發布。MQTT協議是輕量、簡單、開放和易于實現的，這些特點使它適用范圍非常廣泛。在很多情況下，包括受限的環境中，作為一種低開銷、低帶寬占用的即時通訊協議，使其在物聯網、小型設備、移動應用等方面有較廣泛的應用。如：機器與機器（M2M）通信和物聯網（IoT）。其在通過衛星鏈路通信傳感器、偶爾撥號的醫療設備、智能家居、及一些小型化設備中已廣泛使用。

MQTT最大優點在于，用極少的代碼和有限的帶寬，為連接遠程設備提供實時可靠的消息服務。

2.MQTT特點

本協議運行在 TCP/IP，或其它提供了有序、可靠、 雙向連接的網絡連接上。MQTT屬于應用層協議，它有以下特點：

使用發布/訂閱消息模式，提供了一對多的消息分發和應用之間的解耦。

消息傳輸不需要知道負載內容。

提供三種等級的服務質量：
QS0：“最多一次”，盡操作環境所能提供的最大努力分發消息。 消息可能會丟失。 例如， 這個等級可用于環境傳感器數據，單 次的數據丟失沒關系， 因為不久之后會再次發送。

QS1：“至少一次”，保證消息可以到達， 但是可能會重復。

QS2： “僅一次”， 保證消息只到達一次。 例如， 這個等級可用在一個計費系統中， 這里如果消息重復或丟失會導致不正 確的收費。很小的傳輸消耗和協議數據交換，最大限度減少網絡流量。

3.MQTT控制報文

??MQTT 協議通過交換預定義的 MQTT 控制報文來通信。MQTT 控制報文由三部分組成：固定報頭(Fixed header)、可變報頭(Variable header)、有效載荷(Payload)。

3.1 固定報頭格式

控制報文類型

3.2 MQTT控制報文類型集標志

固定報頭第1個字節高4位(4 ~ 7)為控制報文類型，一共14個，低4位(0~3)包含每個 MQTT 控制報文類型特定的標志，見下表。表中任何標記為“保留”的標志位，都是保留給以后使用的，必須設置為表格中列出的值。如果收到非法的標志，接收者必須關閉網絡連接。

??DUP1 =控制報文的重復分發標志。
??QoS2 = PUBLISH 報文的服務質量等級。
??RETAIN3 = PUBLISH 報文的保留標志。
??PUBLISH 控制報文中的 DUP, QoS 和 RETAIN 標志。
??詳情參考MQTT3.1協議。

3.3 剩余長度計算

剩余長度（Remaining Length） 表示當前報文剩余部分的字節數，包括可變報頭和負載的數據。 剩余長度不包括用于編碼剩余長度字段本身的字節數。

剩余長度字段使用一個可變長度編碼方案，對小于128的值它使用單字節編碼。 更大的值按下面的方式處理。低7位有效位用于編碼數據8，最高有效位用于指示是否有更多的字節。 即剩余長度安裝128進制進行計數，剩余長度字段最大 4 個字節。

剩余長度字段取值如下：

?剩余長度按128進制計數，采用16進制方式表示，低字節在前。剩余長度編碼示例：
①例如64：(64/128)取整=0，說明64不需要進位，1個字節即可表示，即：0x40;
②例如456：(456/128)取整=3，(3/128)取整=0，說明456需要2個字節表示。
?第一個字節bit7=1，(bit0~bit6)=456%128=72=0x48，即第一個字節表示為：0xc8;
?第二個字節bit7=3/128=0，(bit0~bit6)=3%128=3，即第二個字節表示位：0x3;
?綜上，456采用2個字節表示為：0xc8 0x3;
③例如100000：(100000/128)=781，(781/128)=6，說明100000需要3字節表示
?第一個字節bit7=1，(bit0~bit6)=100000%128=0x20，即第一個字節為0xa0;
?第二個字節bit7=1，(bit0~bit6)=781%128=0x0d，即第二個字節為0x8d;
?第三個字節bit7=0，(bit0~bit6)=6%128=6，即第三個字節為0x6;
?綜上，100000采用3字節表示為：0xa0 0x8d 0x6;

3.4 剩余長度計算C語言實現示例

剩余長度編碼

int MQTT_RemainSum(int data,u8 buff[])
{
	int cnt=0;//記錄編碼的字節數
	do
	{
		u8 encodedByte = data % 128;
		data/=128;
		if(data>0)
		{
			//若data超過128，則將最最高位置1
			encodedByte=encodedByte|=0x80;
		}
		buff[cnt++]=encodedByte;
		
	}while(data>0);
	return cnt;//返回需要編碼的字節數個數
}

剩余長度解碼

int MQTT_remainGet(u8 buff[],int cnt)
{
	int data=0;
	int i=0;
	int count=1;
	for(;i

測試示例：

int main(int argc,char *argv[])
{
	if(argc!=2)
	{
		printf("格式:./a.out <剩余長度>n");
		return 0;
	}
	int data=atoi(argv[1]);
	u8 buff[4];
	int cnt=MQTT_RemainSum(data,buff);
	for(int i=0;i

4.MQTT消息等級

MQTT提供三種等級的服務質量

QS0：“最多一次”，盡操作環境所能提供的最大努力分發消息。 消息可能會丟失。 例如，這個等級可用于環境傳感器數據，單次的數據丟失沒關系， 因為不久之后會再次發送。

QS1：“至少一次”，保證消息可以到達， 但是可能會重復。

QS2： “僅一次”， 保證消息只到達一次。 例如， 這個等級可用在一個計費系統中，這里如果消息重復或丟失會導致不正確的收費。很小的傳輸消耗和協議數據交換，最大限度減少網絡流量。

??PUBLISH報文不能將 QoS所有的位設置為1。如果服務端或客戶端收到QoS所有位都為 1的PUBLISH報文，它必須關閉網絡連接。

Qos0最多一次

??發送者 只發送一次消息，不進行重試。在協議中也沒有定義重傳的語義。消息可能到達服務器1次，也可能根本不會到達。

Qos1至少一次

服務器接收到消息會被確認，通過傳輸一個PUBACK信息。如果有一個可以辨認的傳輸失敗，無論是通訊連接還是發送設備，還是過了一段時間確認信息沒有收到，發送方都會將消息頭的DUP位置1，然后再次發送消息。消息最少一次到達服務器。

如果客戶端沒有接收到PUBACK信息（無論是應用定義的超時，還是檢測到失敗然后通訊session重啟），客戶端都會再次發送PUBLISH信息，并且將DUP位置1。

當它從客戶端接收到重復的數據，服務器重新發送消息給訂閱者，并且發送另一個PUBACK消息。

? 如上圖所示， Qos1消息等級為了保證至少傳達一次，發布方會將發送的消息本地暫存，并且會每隔一段時間重發一次，直到接收方返回應答為止。當我們收到應答后即可將暫存消息刪除，停止重傳。

對應接收方，則需要在每次收到消息后都要回復應答。在上圖中publisher(發布方)到broker(代理方，服務器)和broker(代理方，服務器)到subscriber(訂閱方)是同等的，兩段通信都應按以上討論的進行實現。

Qos2僅一次

? QS2消息等級保證消息一定可以到達一次，publisher(發布方)到broker(代理方，服務器)和broker(代理方，服務器)到subscriber(訂閱方)是同等的，兩段通信都是相同等級。具體消息傳輸過程如下：

1.發布方發送消息，并將消息內容本地暫存。

2.接收方接收到消息內容后，將消息內容暫存本地，并給發送方回復一個應答(PUBREC),發布方在沒有收到PUBREC之前會隔一段時間進行消息重發一次，以確保消息一定可以送達。

3.當發布方收到PUBREC后，則停止消息重發，并給接收方發送釋放(PUBREL)消息內容,接收方收到PUBREL后即可確定消息傳輸成功。

4.刪除暫存的消息，之后發送端每次收到PUBREC都直接發送一個PUBREL消息給接收端。

5.接收端在收到PUBREL消息后，修改暫存的消息狀態為發布完成，停止發送PUBREC，然后給發送端發去一個發布完成（PUBCOM）的消息。此時接收端則將刪除暫存的消息，之后每次收到PUBREL都直接回復PUBCOM。

6.發送端收到PUBCOM，如果發現暫存的消息還每刪除的話，就刪除暫存消息，如果已經刪除了就不管了。

注意：在此過程中本地暫存消息的作用是為了在收到重復內容時可以實現去重，在接收到PUBREL后，就能確定發送端不再會發送此消息，所以這個時候就可以刪除暫存消息了，同樣的，發送端在接收到PUBREC后知道接收端已經接收到消息了，所以不必再發送消息，并且可以刪除暫存了。

審核編輯 黃昊宇