MQTT協(xié)議之消息訂閱

在MQTT協(xié)議中养渴,最重要的就是發(fā)布/訂閱,下面重點分析下消息訂閱争群。

SUBSCRIBE

一般來講,客戶端在成功建立TCP連接之后大年,發(fā)送CONNECT消息换薄,在得到服務器端授權允許建立彼此連接的CONNACK消息之后,客戶端會發(fā)送SUBSCRIBE消息翔试,訂閱感興趣的Topic主題列表(至少一個主題)轻要,一個完整示范如下:


mqtt-subscribe

固定頭部

Qos Level,可根據(jù)實際情況進行調整為0/1/2等垦缅。一般設為0表示最多一次冲泥。客戶端可設置OoS Level值壁涎。 DUP flag凡恍,值為0表示第一次發(fā)送。

可變頭部

因為上面示范QoS level值為1怔球,因此需要客戶端傳遞消息ID嚼酝,16位,無符號的short類型竟坛。

消息體

訂閱的主題名稱采用修改版UTF-8編碼闽巩,然后緊跟著對應的QoS值。下面的次序担汤,可能更為形象:

Topic name "a/b"
Requested QoS 1
Topic name "c/d"
Requested QoS 2

訂閱者的Topic name支持通配符#和+ :

  1. #支持一個主題內任意級別話題
  • +只匹配一個主題級別的通配符

eg:
finance/stock/#
finance/sotkc/ibm/+
都是有效涎跨,更具體規(guī)則,請參閱協(xié)議附加部分崭歧。
在服務器接收處理時隅很,按照順序讀取即可:

String topicName = readUTF();
int qosVal = read();

服務器可以發(fā)送QoS不大于客戶端設置OoS的消息,尤其是服務器不提供良好的持久化機制的時候驾荣。

SUBACK

服務器會對發(fā)出SUBSCRIBE的消息返回一個確認消息外构。


mqtt-suback

可變頭部

Message Identifier,服務器需要附加播掷,客戶端需要處理审编。

消息體

QoS,為服務器根據(jù)實際情況授予的QoS級別列表歧匈,和客戶端發(fā)送的SUBSCRIBE的訂閱Topic Name順序完全一致垒酬。

客戶端訂閱幾個TOPIC,服務器端一一給出各個TOPIC的QoS具體值。

UNSUBSCRIBE

服務器需要支持客戶端取消訂閱功能勘究,UNSUBSCRIBE消息格式和SUBSCRIBE消息格式差不多矮湘,除了消息類型不同,消息體中沒有了QoS字節(jié)口糕,其它沒有區(qū)別缅阳。


mqtt-unsubscribe

  可變頭部的消息ID的出現(xiàn)還是由固定頭部的QoS Level(1)決定是否存在。
  一般來講景描,客戶端發(fā)布退訂十办,服務器端需要返回退訂確認。
  MQTT沒講是否允許客戶端退訂所有TOPIC超棺。

UNSUBACK

服務器返回的UNSUBSCRIBE消息UNSUBACK相應很簡單向族,沒有消息體。


mqtt-unsuback

小結

訂閱部分棠绘,共有四個消息件相,分別一一對應。

命令 響應 備注 建議
SUBSCRIBE SUBACK 協(xié)議沒有涉及最多運行訂閱TOPIC數(shù)目氧苍,隱藏的隱患 建議至多10個
UNSUBSCRIBE UNSUBACK 是否可以退訂所有訂閱夜矗,不詳 建議保留至少一個Topic
最后編輯于
?著作權歸作者所有,轉載或內容合作請聯(lián)系作者
  • 序言:七十年代末,一起剝皮案震驚了整個濱河市候引,隨后出現(xiàn)的幾起案子侯养,更是在濱河造成了極大的恐慌敦跌,老刑警劉巖澄干,帶你破解...
    沈念sama閱讀 212,718評論 6 492
  • 序言:濱河連續(xù)發(fā)生了三起死亡事件,死亡現(xiàn)場離奇詭異柠傍,居然都是意外死亡麸俘,警方通過查閱死者的電腦和手機,發(fā)現(xiàn)死者居然都...
    沈念sama閱讀 90,683評論 3 385
  • 文/潘曉璐 我一進店門惧笛,熙熙樓的掌柜王于貴愁眉苦臉地迎上來从媚,“玉大人,你說我怎么就攤上這事患整“菪В” “怎么了?”我有些...
    開封第一講書人閱讀 158,207評論 0 348
  • 文/不壞的土叔 我叫張陵各谚,是天一觀的道長紧憾。 經常有香客問我,道長昌渤,這世上最難降的妖魔是什么赴穗? 我笑而不...
    開封第一講書人閱讀 56,755評論 1 284
  • 正文 為了忘掉前任,我火速辦了婚禮,結果婚禮上般眉,老公的妹妹穿的比我還像新娘了赵。我一直安慰自己,他們只是感情好甸赃,可當我...
    茶點故事閱讀 65,862評論 6 386
  • 文/花漫 我一把揭開白布柿汛。 她就那樣靜靜地躺著,像睡著了一般埠对。 火紅的嫁衣襯著肌膚如雪苛茂。 梳的紋絲不亂的頭發(fā)上,一...
    開封第一講書人閱讀 50,050評論 1 291
  • 那天鸠窗,我揣著相機與錄音妓羊,去河邊找鬼。 笑死稍计,一個胖子當著我的面吹牛躁绸,可吹牛的內容都是我干的。 我是一名探鬼主播臣嚣,決...
    沈念sama閱讀 39,136評論 3 410
  • 文/蒼蘭香墨 我猛地睜開眼净刮,長吁一口氣:“原來是場噩夢啊……” “哼!你這毒婦竟也來了硅则?” 一聲冷哼從身側響起淹父,我...
    開封第一講書人閱讀 37,882評論 0 268
  • 序言:老撾萬榮一對情侶失蹤,失蹤者是張志新(化名)和其女友劉穎怎虫,沒想到半個月后暑认,有當?shù)厝嗽跇淞掷锇l(fā)現(xiàn)了一具尸體,經...
    沈念sama閱讀 44,330評論 1 303
  • 正文 獨居荒郊野嶺守林人離奇死亡大审,尸身上長有42處帶血的膿包…… 初始之章·張勛 以下內容為張勛視角 年9月15日...
    茶點故事閱讀 36,651評論 2 327
  • 正文 我和宋清朗相戀三年蘸际,在試婚紗的時候發(fā)現(xiàn)自己被綠了。 大學時的朋友給我發(fā)了我未婚夫和他白月光在一起吃飯的照片徒扶。...
    茶點故事閱讀 38,789評論 1 341
  • 序言:一個原本活蹦亂跳的男人離奇死亡粮彤,死狀恐怖,靈堂內的尸體忽然破棺而出姜骡,到底是詐尸還是另有隱情导坟,我是刑警寧澤,帶...
    沈念sama閱讀 34,477評論 4 333
  • 正文 年R本政府宣布圈澈,位于F島的核電站惫周,受9級特大地震影響,放射性物質發(fā)生泄漏士败。R本人自食惡果不足惜闯两,卻給世界環(huán)境...
    茶點故事閱讀 40,135評論 3 317
  • 文/蒙蒙 一褥伴、第九天 我趴在偏房一處隱蔽的房頂上張望。 院中可真熱鬧漾狼,春花似錦重慢、人聲如沸。這莊子的主人今日做“春日...
    開封第一講書人閱讀 30,864評論 0 21
  • 文/蒼蘭香墨 我抬頭看了看天上的太陽。三九已至稽煤,卻和暖如春核芽,著一層夾襖步出監(jiān)牢的瞬間,已是汗流浹背酵熙。 一陣腳步聲響...
    開封第一講書人閱讀 32,099評論 1 267
  • 我被黑心中介騙來泰國打工轧简, 沒想到剛下飛機就差點兒被人妖公主榨干…… 1. 我叫王不留,地道東北人匾二。 一個月前我還...
    沈念sama閱讀 46,598評論 2 362
  • 正文 我出身青樓哮独,卻偏偏與公主長得像,于是被迫代替她去往敵國和親察藐。 傳聞我的和親對象是個殘疾皇子皮璧,可洞房花燭夜當晚...
    茶點故事閱讀 43,697評論 2 351

推薦閱讀更多精彩內容

  • Spring Cloud為開發(fā)人員提供了快速構建分布式系統(tǒng)中一些常見模式的工具(例如配置管理,服務發(fā)現(xiàn)分飞,斷路器悴务,智...
    卡卡羅2017閱讀 134,638評論 18 139
  • 前言 前面的筆記已把所有消息類型都過了一遍,這里從消息處理流程的角度嘗試解讀一下譬猫。 網絡故障 在任何網絡環(huán)境下讯檐,都...
    技術學習閱讀 12,519評論 1 4
  • 序 本篇會把連接(CONNECT)、心跳(PINGREQ/PINGRESP)删窒、確認(CONNACK)裂垦、斷開連接(D...
    技術學習閱讀 9,747評論 0 8
  • MQTT Protocol MQTT協(xié)議特性 一句話總結:MQTT是一個簡單顺囊,輕量的消息發(fā)布/訂閱協(xié)議肌索。 MQTT...
    福克斯記閱讀 7,240評論 0 9
  • “我一位前任結婚了特碳,也邀請了我诚亚,你要不要和我一塊去?” “你會不會坐的是前任桌啊午乓≌咀冢” “有可能喔~” “真酷,以后...
    烏吉瑪拉_boy閱讀 1,011評論 1 2