Client鏈接Broker

1映之、CONNECT

連接的建立由Client端發(fā)起彼城，Client端首先向Broker發(fā)送一個CONNECT數(shù)據(jù)包皮钠，每一個數(shù)據(jù)包都包含

• 固定頭（Fixed header）：存在于所有的 MQTT 數(shù)據(jù)包中晚岭，用于表示數(shù)據(jù)包類型及對應(yīng)標(biāo)識迂烁，表明數(shù)據(jù)包大兄萏弧揭绑；
• 可變頭（Variable header）：存在于部分類型的 MQTT 數(shù)據(jù)包中，具體內(nèi)容由相應(yīng)類型的數(shù)據(jù)包決定郎哭；
• 消息體（Payload）：存在于部分 MQTT 數(shù)據(jù)包中他匪，存儲消息的具體數(shù)據(jù)

其中固定頭可參考我的另一篇文章 MQTT協(xié)議的基礎(chǔ)概念 這里我們略過

1.1 可變頭（Variable header）

在 CONNECT 數(shù)據(jù)包可變頭中，含有以下信息夸研。

• 協(xié)議名稱（Protocol Name）：值固定為字符 “MQTT”邦蜜。
• 協(xié)議版本（Protocol Level）：對 MQTT 3.1.1 來說，值為 4亥至。
• 用戶名標(biāo)識（User Name Flag）：消息體中是否有用戶名字段悼沈，1bit贱迟，0 或者 1。
• 密碼標(biāo)識（Password Flag）：消息體中是否有密碼字段絮供，1bit关筒，0 或者 1。
• 遺愿消息 Retain 標(biāo)識（Will Retain）：標(biāo)識遺愿消息是否是 Retain 消息杯缺，1bit蒸播，0 或者 1。
• 遺愿消息 QOS 標(biāo)識（Will QOS）：標(biāo)識遺愿消息的 QOS萍肆，2bit袍榆，0、1 或者 2塘揣。
• 遺愿標(biāo)識（Will Flag）：標(biāo)識是否使用遺愿消息包雀，1bit，0 或者 1亲铡。
• 會話清除標(biāo)識（Clean Session）：標(biāo)識 Client 是否建立一個持久化的會話才写，1bit，0 或者 1奖蔓，當(dāng) Clean Session 的標(biāo)識設(shè)為 0 時赞草，代表 Client 希望建立一個持久會話的連接，Broker 將存儲該 Client 訂閱的主題和未接受的消息吆鹤，否則 Broker 不會存儲這些數(shù)據(jù)厨疙，同時在建立連接時清除這個 Client 之前存在的持久化會話所保存的數(shù)據(jù)。
• 連接币晌瘢活（Keep Alive）: 設(shè)置一個單位為秒的時間間隔沾凄，Client 和 Broker 之間在這個時間間隔之內(nèi)需要至少有一次消息交互，否則 Client 和 Broker 會認(rèn)為它們之間的連接已經(jīng)斷開

1.2 消息體（Payload）

CONNECT 數(shù)據(jù)包的消息體中包含以下數(shù)據(jù)知允。

• 客戶端標(biāo)識符（Client Identifier）：Client Identifier 是用來標(biāo)識 Client 身份的字段撒蟀，在 MQTT 3.1.1 的版本中，這個字段的長度是 1 到 23 個字節(jié)温鸽，而且只能包含數(shù)字和 26 個字母（包括大小寫）保屯，Broker 通過這個字段來區(qū)分不同的 Client。所以在連接的時候嗤朴，Client 應(yīng)該保證它的 Identifier 是唯一的配椭，通常我們可以使用比如 UUID，唯一的設(shè)備硬件標(biāo)識雹姊，或者 Android 設(shè)備的 DEVICE_ID 等作為 Client Identifier 的取值來源股缸。
• MQTT 協(xié)議中要求 Client 連接時必須帶上 Client Identifier，但是也允許 Broker 在實現(xiàn)時 Client Identifier 為空吱雏，這時 Broker 會為 Client 分配一個內(nèi)部唯一的 Identifier敦姻。如果你需要使用持久化會話瘾境，那就必須自己為 Client 設(shè)定一個唯一的 Identifier。
• 用戶名（Username）：如果可變頭中的用戶名標(biāo)識設(shè)為 1镰惦，那么消息體中將包含用戶名字段迷守，Broker 可以使用用戶名和密碼來對接入的 Client 進行驗證，只允許已授權(quán)的 Client 接入旺入。注意不同的 Client 需要使用不同的 Client Identifier兑凿，但它們可以使用同樣的用戶名和密碼進行連接。
• 密碼（Password）：如果可變頭中的密碼標(biāo)識設(shè)為 1茵瘾，那么消息體中將包含密碼字段礼华。
• 遺愿主題（Will Topic）：如果可變頭中的遺愿標(biāo)識設(shè)為 1，那么消息體中將包含遺愿主題拗秘，當(dāng) Client 非正常地中斷連接的時候圣絮，Broker 將向指定的遺愿主題中發(fā)布遺愿消息。
• 遺愿消息（Will Message）：如果可變頭中的遺愿標(biāo)識設(shè)為 1雕旨，那么消息體中將包含遺愿消息扮匠，當(dāng) Client 非正常地中斷連接的時候，Broker 將向指定的遺愿主題中發(fā)布由該字段指定的內(nèi)容凡涩。

1.3 代碼實現(xiàn)

在這里我們使用 Node.js 的 MQTT 庫棒搜，請確保已安裝 Node.js，并通過 npm install mqtt --save 安裝了 MQTT 庫突照。
這里我們使用一個公共的 Broker：mqtt.eclipse.org:1883帮非。
本次建立的是一個持久化的連接氧吐，如果需要非持久的連接只需要把clean的參數(shù)設(shè)為True讹蘑，新建client_borker.js文件

var mqtt = require('mqtt')
var client = mqtt.connect('mqtt://mqtt.eclipse.org:1883',{
    clientId:"mqtt_sample_id_1",
    clean:false
})

client.on('connect',function(connack){
    console.log(`return code:${connack.returnCode},sessionPresent:${connack.sessionPresent}`)
    client.end()
})

在終端上運行node client_borker.js,輸出以下

輸出結(jié)果

本次先到這里了，有興趣的可以嘗試打開兩個終端分別運行該程序看看會輸出什么翠拣。