mqtt協(xié)議,流程圖

1、竭誠(chéng)為您提供優(yōu)質(zhì)文檔 /雙擊可除第1頁(yè)共 6 頁(yè)mqtt 協(xié)議,流程圖篇一：mqttmqtt 協(xié)議筆記之消息流網(wǎng)絡(luò)故障mqtt 協(xié)議假定客戶(hù)端和服務(wù)器端穩(wěn)定情況一般，彼此之通信管道不可靠，一旦客 戶(hù)端網(wǎng)絡(luò)斷開(kāi)，情況就會(huì)很?chē)?yán)重，很難恢復(fù)原狀。但別忘記， 很多客戶(hù)端會(huì)有永久性存儲(chǔ)設(shè)備支持，比如閃存Rom 存儲(chǔ)卡等，在通信出現(xiàn)異常的情況下可以用于保存關(guān)鍵數(shù)據(jù)或狀 態(tài)信息等?？傊?，異常網(wǎng)絡(luò)情況很復(fù)雜，只能小心處理之。消息重發(fā)策略在 qos0 情況下，publish、pubRel、subscRibe、unsubscRibe 等類(lèi)型消息在發(fā)送者發(fā)送完之后，需要等待一 個(gè)響應(yīng)消息，若在一個(gè)指定時(shí)間段內(nèi)沒(méi)有收

2、到，發(fā)送者可能 需要重試。重發(fā)的消息，要求 dup 標(biāo)記要設(shè)置為 1.等待響應(yīng) 的超時(shí)應(yīng)該在消息成功發(fā)送之后開(kāi)始算起，并且等待超時(shí)應(yīng) 該是可以配置選項(xiàng)，以便在下一次重試的時(shí)候，適當(dāng)加大。比如第一次重試超時(shí) 10 秒，下一次可能為 20 秒，再一次重 試可能為 60 秒呢。當(dāng)然，還要有一個(gè)重試次數(shù)限制的。還 有一種情況，客戶(hù)端重新連接，但未在可變頭部中設(shè)置 cleansession 標(biāo)記，但雙方（客戶(hù)端和服務(wù)器端）都應(yīng)該重試第 2 頁(yè)共 6 頁(yè)先前未發(fā)送的動(dòng)態(tài)消息(in-flightmessages )?？蛻?hù)端不被 強(qiáng)制要求發(fā)送未被確認(rèn)的消息，但服務(wù)器端就得需要重發(fā)那 些未被去確認(rèn)的消息。qos

3、level 決定的消息流 mqtt3.1 協(xié)議在4.1qualityofservicelevelsandflows章節(jié)中，僅僅討論了客戶(hù)端到服務(wù)器的發(fā)布流程， 不太完整。 因?yàn)闆Q定消息 到達(dá)率，能夠提升發(fā)送質(zhì)量的，應(yīng)該是服務(wù)器發(fā)布publish消息到訂閱者這一消息流方向。qoslevelO 至多發(fā)送一次，發(fā)送即丟棄。沒(méi)有確認(rèn)消息，也不知道對(duì)方是否收到。clientmessageanddirectionqos=Opublish-Reception:clientqos=1dup=0messageid=xaction:storemessagemessageanddirectionactions:pu

4、blish- serverstoremessagepublishmessagetosubscribersdeletemessageReception:=1action:discardmessagepubacksubscriberstoremessagemakemessageavailableReception:=1pubackserve r 方向，會(huì)有一個(gè)總體印象：clientqos=2dup=0messageid=xaction:storemessagemessageanddirectionserveraction(a)storemessageorpublish- actions(b):st

5、oremessageidpublishmessagetosubscriberspubRecclientmessageanddirectionactions(a):serverpublishme第3頁(yè)共 6 頁(yè)ssagetosubscribersdeletemessageoraction(b):deletemessageidmessageid=xpubRel-（mqtt 協(xié)議,流程圖）-action:discardmessagepubcompsubscriber:serverqos=2dup=0messageid=xmessageanddirectionpubli sh-pubRecpubcomppublish2- publish3- pubRec1clientmessageanddirectionserver- pubRec3pubcomp1pubcomp2 服務(wù)器，進(jìn)入的字節(jié)流，逐個(gè)字節(jié) /單位讀 取，可還原成一個(gè)具體的消息對(duì)象（解碼的過(guò)程）。要發(fā)送到客戶(hù)端的消息對(duì)象，轉(zhuǎn)換（編碼）成字節(jié)流，然后由 tcp 通道流轉(zhuǎn)到接收者。篇二：mqtt 協(xié)議簡(jiǎn)記mqtt-mqtelemetrytransport輕量