在工業(yè)物聯(lián)網(wǎng)（IIoT）的通信協(xié)議體系中，MQTT（Message Queuing Telemetry Transport）憑借其輕量級(jí)、發(fā)布 - 訂閱模式和低帶寬占用等特性，成為連接邊緣設(shè)備與云端平臺(tái)的首選協(xié)議。從傳感器數(shù)據(jù)采集到設(shè)備遠(yuǎn)程控制，從車(chē)間級(jí)監(jiān)控到跨廠區(qū)協(xié)同，MQTT 正在重塑工業(yè)通信架構(gòu)。GraniStudio 軟件通過(guò)對(duì) MQTT 協(xié)議的全場(chǎng)景整合，將其復(fù)雜的連接管理、消息路由和 QoS 保障等機(jī)制封裝為可視化組件，為工業(yè)用戶提供了 “零代碼” 構(gòu)建 MQTT 通信鏈路的能力。本文將從協(xié)議原理、技術(shù)特性、GraniStudio 整合實(shí)現(xiàn)及工業(yè)應(yīng)用四個(gè)維度，全面解析 MQTT 協(xié)議的技術(shù)內(nèi)核。

一、MQTT 協(xié)議的核心原理與通信模型

MQTT 由 IBM 于 1999 年開(kāi)發(fā)，最初為石油管道監(jiān)控設(shè)計(jì)，歷經(jīng)二十余年發(fā)展，已成為工業(yè)物聯(lián)網(wǎng)的事實(shí)標(biāo)準(zhǔn)協(xié)議。其核心設(shè)計(jì)理念是 “輕量級(jí)、可靠、低功耗”，適合資源受限的邊緣設(shè)備和不穩(wěn)定的網(wǎng)絡(luò)環(huán)境。

實(shí)現(xiàn)MQTT協(xié)議需要客戶端和服務(wù)器端通訊完成， 在通訊過(guò)程中, MQTT協(xié)議中有三種身份:發(fā)布者(Publish)、代理(Broker)(服務(wù)器)、訂閱者(Subscribe)。 其中，消息的發(fā)布者和訂閱者都是客戶端，消息代理是服務(wù)器，消息發(fā)布者可以同時(shí)是訂閱者。

MQTT傳輸?shù)南⒎譃? 主題(Topic) 和 負(fù)載(payload)兩部分:

Topic: 可以理解為消息的類(lèi)型，訂閱者訂閱(Subscribe)后，就會(huì)收到該主題的消息內(nèi)容(payload)

payload: 可以理解為消息的內(nèi)容，是指訂閱者具體要使用的內(nèi)容

1.1 發(fā)布 - 訂閱模式的架構(gòu)設(shè)計(jì)

MQTT 采用 “發(fā)布 - 訂閱”（Publish-Subscribe）模式，與傳統(tǒng)的客戶端 - 服務(wù)器模式相比，具有更高的解耦性和擴(kuò)展性。核心組件包括：

發(fā)布者（Publisher）：生成消息并發(fā)布到特定主題（Topic）的客戶端，例如傳感器上傳溫度數(shù)據(jù)；

訂閱者（Subscriber）：向代理服務(wù)器訂閱特定主題，接收相關(guān)消息的客戶端，例如 SCADA 系統(tǒng)訂閱設(shè)備狀態(tài)；

代理服務(wù)器（Broker）：中央樞紐，負(fù)責(zé)接收發(fā)布者的消息，并將其路由到匹配的訂閱者，例如 EMQ X、Mosquitto 等；

主題（Topic）：消息的邏輯分類(lèi)，采用層級(jí)結(jié)構(gòu)（如factory1/workshop2/machine3/temperature），訂閱者通過(guò)主題過(guò)濾器（如factory1/#）匹配感興趣的消息。

這種模式使發(fā)布者與訂閱者無(wú)需直接連接，降低了系統(tǒng)耦合度。例如，車(chē)間內(nèi)的 200 臺(tái)設(shè)備作為發(fā)布者，將數(shù)據(jù)發(fā)布到equipment/status主題；MES 系統(tǒng)作為訂閱者，訂閱該主題獲取所有設(shè)備狀態(tài)，雙方無(wú)需預(yù)先知道對(duì)方的存在。

1.2 服務(wù)質(zhì)量（QoS）保障機(jī)制

MQTT 定義了三種消息傳遞質(zhì)量等級(jí)，滿足不同場(chǎng)景的可靠性需求：

1.3 會(huì)話保持與遺囑機(jī)制

針對(duì)工業(yè)場(chǎng)景中網(wǎng)絡(luò)不穩(wěn)定的問(wèn)題，MQTT 設(shè)計(jì)了兩項(xiàng)關(guān)鍵機(jī)制：

會(huì)話保持（Session Persistence）：客戶端連接時(shí)設(shè)置Clean Session標(biāo)志：

Clean Session = true：連接斷開(kāi)后，代理服務(wù)器丟棄該客戶端的所有訂閱和未發(fā)送消息；

Clean Session = false：代理服務(wù)器保留訂閱和未發(fā)送消息，客戶端重新連接時(shí)繼續(xù)接收。
工業(yè)場(chǎng)景通常選擇Clean Session = false，確保設(shè)備斷網(wǎng)恢復(fù)后能繼續(xù)接收歷史消息。

遺囑消息（Last Will and Testament）：客戶端連接時(shí)設(shè)置遺囑消息，當(dāng)代理服務(wù)器檢測(cè)到客戶端異常斷開(kāi)（如網(wǎng)絡(luò)故障）時(shí)，自動(dòng)發(fā)布該消息。例如，設(shè)備連接時(shí)設(shè)置遺囑主題device/offline，當(dāng)設(shè)備意外斷電時(shí)，代理服務(wù)器向該主題發(fā)布 “設(shè)備離線” 消息，通知監(jiān)控系統(tǒng)及時(shí)處理。

二、MQTT 協(xié)議的技術(shù)特性與工業(yè)適配

MQTT 的技術(shù)特性使其天然適合工業(yè)場(chǎng)景，尤其是在邊緣計(jì)算、低帶寬網(wǎng)絡(luò)和資源受限設(shè)備中表現(xiàn)突出。

2.1 輕量級(jí)協(xié)議設(shè)計(jì)

MQTT 協(xié)議頭最小僅 2 字節(jié)，消息格式緊湊，相比 HTTP 協(xié)議（通常數(shù)百字節(jié)），帶寬占用降低 80% 以上。在工業(yè)環(huán)境中，這種輕量化設(shè)計(jì)帶來(lái)顯著優(yōu)勢(shì)：

低帶寬需求：適合車(chē)間級(jí) WiFi（通常帶寬＜10Mbps）和蜂窩網(wǎng)絡(luò)（如 4G 偏遠(yuǎn)廠區(qū)）；

低功耗：邊緣設(shè)備（如電池供電的傳感器）發(fā)送 MQTT 消息的能耗僅為 HTTP 的 1/3；

快速連接：建立連接耗時(shí)＜50ms，遠(yuǎn)低于 HTTP 的 TCP+TLS 握手（通常＞200ms）。

某汽車(chē)廠的實(shí)踐顯示，采用 MQTT 替代 HTTP 后，車(chē)間級(jí)數(shù)據(jù)傳輸延遲從 500ms 降至 100ms，網(wǎng)絡(luò)帶寬占用減少 75%。

2.2 主題層級(jí)與通配符機(jī)制

MQTT 的主題采用 “/” 分隔的層級(jí)結(jié)構(gòu)（如factory/line/machine/parameter），并支持兩種通配符：

單層通配符（+）：匹配任意單個(gè)層級(jí)，例如factory/+/temperature可匹配factory/line1/temperature和factory/line2/temperature；

多層通配符（#）：匹配任意數(shù)量的層級(jí)，例如factory/#可匹配factory/line1/machine1/status和factory/statistics。

這種設(shè)計(jì)使消息路由更加靈活，例如：

設(shè)備監(jiān)控系統(tǒng)訂閱factory/+/+/status，獲取所有生產(chǎn)線的設(shè)備狀態(tài)；

能源管理系統(tǒng)訂閱factory/#/energy，獲取全廠所有設(shè)備的能耗數(shù)據(jù)；

報(bào)警系統(tǒng)訂閱factory/alert/#，接收所有報(bào)警信息。

2.3 安全增強(qiáng)機(jī)制

針對(duì)工業(yè)網(wǎng)絡(luò)安全需求，MQTT 提供多層次安全保障：

傳輸層安全（TLS）：支持 SSL/TLS 加密，防止中間人攻擊和數(shù)據(jù)竊聽(tīng)，例如通過(guò)配置mqtts://broker:8883啟用 TLS；

身份認(rèn)證：支持用戶名 / 密碼認(rèn)證和客戶端證書(shū)認(rèn)證，例如某化工廠要求所有設(shè)備連接 MQTT 代理時(shí)必須提供 CA 簽發(fā)的證書(shū)；

訪問(wèn)控制：代理服務(wù)器（如 EMQ X）可配置基于主題的訪問(wèn)控制列表（ACL），例如：

plaintext

{allow, {user, "admin"}, pubsub, ["#"]}. # 管理員可發(fā)布/訂閱所有主題

{allow, {user, "device1"}, publish, ["device1/#"]}. # 設(shè)備1只能發(fā)布自己的主題

{allow, {user, "monitor"}, subscribe, ["factory/#"]}. # 監(jiān)控系統(tǒng)只能訂閱工廠相關(guān)主題

三、GraniStudio 對(duì) MQTT 協(xié)議的工具統(tǒng)一

針對(duì)工業(yè)場(chǎng)景的特殊性，GraniStudio 對(duì) MQTT 協(xié)議進(jìn)行了模塊化歸納，構(gòu)建了 “MQTT服務(wù)器 – MQTT客戶端- MQTT發(fā)送文本- MQTT接受文本-關(guān)閉MQTT服務(wù)器”的MQTT通信協(xié)議工具。

MQTT 客戶端

概述：在 GraniStudio 平臺(tái)中，MQTT 客戶端是用于與 MQTT 服務(wù)器進(jìn)行交互的組件。它可以是連接到網(wǎng)絡(luò)的設(shè)備、應(yīng)用程序或其他實(shí)體，負(fù)責(zé)向服務(wù)器發(fā)布消息，或者訂閱感興趣的主題以接收相關(guān)消息。

作用：

發(fā)布消息：根據(jù)業(yè)務(wù)需求，將特定主題的消息發(fā)布到 MQTT 服務(wù)器上。比如在智能家居場(chǎng)景中，智能溫濕度傳感器作為 MQTT 客戶端，會(huì)將實(shí)時(shí)采集到的溫度、濕度數(shù)據(jù)，按照設(shè)定的主題（如 “home/temperature_humidity” ）發(fā)布到服務(wù)器。

訂閱主題：客戶端可以訂閱一個(gè)或多個(gè)主題，當(dāng)服務(wù)器上對(duì)應(yīng)主題有新消息發(fā)布時(shí)，客戶端能夠接收到這些消息。例如，智能照明設(shè)備客戶端可以訂閱 “home/lighting/control” 主題，以接收來(lái)自服務(wù)器的燈光控制指令。

特點(diǎn)：具有靈活的配置選項(xiàng)，能適應(yīng)不同網(wǎng)絡(luò)環(huán)境和安全要求，可方便地與各種物聯(lián)網(wǎng)設(shè)備集成，實(shí)現(xiàn)數(shù)據(jù)的高效傳輸和交互。

MQTT 服務(wù)器

概述：MQTT 服務(wù)器也被稱(chēng)為消息代理（Message Broker），是 MQTT 通信中的核心樞紐。在 GraniStudio 應(yīng)用場(chǎng)景中，它負(fù)責(zé)接收來(lái)自各個(gè) MQTT 客戶端發(fā)布的消息，并根據(jù)客戶端的訂閱情況，將消息轉(zhuǎn)發(fā)給相應(yīng)的訂閱客戶端。

作用：

消息存儲(chǔ)與轉(zhuǎn)發(fā)：接收客戶端發(fā)布的消息，暫存并根據(jù)主題將其轉(zhuǎn)發(fā)給訂閱了該主題的其他客戶端，實(shí)現(xiàn)消息的高效分發(fā)。比如在工業(yè)物聯(lián)網(wǎng)中，設(shè)備監(jiān)控系統(tǒng)的 MQTT 服務(wù)器接收來(lái)自多個(gè)生產(chǎn)設(shè)備客戶端上傳的運(yùn)行狀態(tài)消息，并將其轉(zhuǎn)發(fā)給監(jiān)控終端、數(shù)據(jù)分析系統(tǒng)等訂閱了相關(guān)主題的客戶端。

連接管理：管理所有連接到服務(wù)器的 MQTT 客戶端，包括建立連接啟動(dòng)服務(wù)、維護(hù)會(huì)話狀態(tài)、處理斷開(kāi)停止服務(wù)等操作，確保通信的穩(wěn)定性和可靠性。

特點(diǎn)：具備高并發(fā)處理能力，能夠支持大量客戶端的連接和消息交互。

MQTT 發(fā)送文本

概述：在 GraniStudio 中，MQTT 發(fā)送文本指的是 MQTT 客戶端將文本格式的消息發(fā)布到 MQTT 服務(wù)器的過(guò)程。這些文本消息通常會(huì)被關(guān)聯(lián)到特定的主題。

實(shí)現(xiàn)方式：

配置主題：在發(fā)送消息前，需要明確指定消息要發(fā)布到的主題。比如，要發(fā)布關(guān)于工廠設(shè)備運(yùn)行日志的文本消息，可以設(shè)定主題為 “factory/device/logs” 。

構(gòu)建消息內(nèi)容：將需要發(fā)送的文本信息按照一定格式組織好，如 JSON字符串格式的日志數(shù)據(jù)（{"device_id": "123", "log_content": "設(shè)備在 10:00 出現(xiàn)短暫過(guò)載"}） 。

調(diào)用發(fā)送接口：利用 GraniStudio 提供的 MQTT 客戶端 API，傳入主題和消息內(nèi)容，執(zhí)行發(fā)送操作，將文本消息發(fā)送到 MQTT 服務(wù)器。

應(yīng)用場(chǎng)景：廣泛應(yīng)用于各類(lèi)數(shù)據(jù)上報(bào)場(chǎng)景，如環(huán)境監(jiān)測(cè)數(shù)據(jù)上報(bào)（發(fā)送 “溫度：25℃，濕度：60%” 等文本消息）、設(shè)備狀態(tài)告警（發(fā)送 “設(shè)備故障，需立即檢修” 等文本消息）。

MQTT 接收文本

概述：MQTT 接收文本是指 MQTT 客戶端通過(guò)訂閱主題，從 MQTT 服務(wù)器獲取相關(guān)文本消息的過(guò)程。

實(shí)現(xiàn)方式：

訂閱主題：客戶端預(yù)先通過(guò) GraniStudio 的 MQTT 客戶端配置界面或 API，訂閱感興趣的主題，如 “home/security/alarm” 。

監(jiān)聽(tīng)消息：客戶端保持與 MQTT 服務(wù)器的連接，持續(xù)監(jiān)聽(tīng)所訂閱主題的消息動(dòng)態(tài)。當(dāng)服務(wù)器上有新消息發(fā)布到該主題時(shí)，客戶端會(huì)收到通知。

應(yīng)用場(chǎng)景：在智能家居中用于接收控制指令（如接收 “打開(kāi)客廳燈光” 的文本指令）；在工業(yè)自動(dòng)化中接收設(shè)備參數(shù)調(diào)整指令等 。

3.1 消息轉(zhuǎn)換與路由引擎

工業(yè)數(shù)據(jù)通常需要在不同格式間轉(zhuǎn)換（如 二進(jìn)制→十六進(jìn)制，字符串轉(zhuǎn)換為數(shù)值），GraniStudio 的 “進(jìn)制轉(zhuǎn)換”“類(lèi)型轉(zhuǎn)換” 算子提供靈活的轉(zhuǎn)換能力：

格式轉(zhuǎn)換：支持二進(jìn)制、八進(jìn)制、十進(jìn)制、十六進(jìn)制。數(shù)值、字符串、浮點(diǎn)等格式的互相轉(zhuǎn)換，例如將傳感器發(fā)送的浮點(diǎn)數(shù)據(jù)（如 25.5）轉(zhuǎn)換為二進(jìn)制數(shù)據(jù)（0x41C8）；

數(shù)據(jù)提?。和ㄟ^(guò)配置“字符串操作算子/文本解析算子”，提取消息中的特定字段，例如從 JSON 消息{"deviceId":"D001","temp":25.3}中提取temp字段；

消息路由：可通過(guò)搭建任務(wù)流程，根據(jù)消息內(nèi)容動(dòng)態(tài)路由到不同主題，例如：

plaintext

當(dāng)溫度＞30℃時(shí)，轉(zhuǎn)發(fā)至`factory/alarm/high_temp`主題；

某食品廠的冷鏈監(jiān)控系統(tǒng)中，GraniStudio 將溫度傳感器數(shù)據(jù)（JSON 格式）轉(zhuǎn)換為 CSV 格式后存儲(chǔ)，同時(shí)將異常溫度（＜-18℃或＞-15℃）轉(zhuǎn)發(fā)至報(bào)警主題，實(shí)現(xiàn) “數(shù)據(jù)存儲(chǔ) + 異常報(bào)警” 的并行處理。

四、MQTT 協(xié)議的工業(yè)應(yīng)用場(chǎng)景與價(jià)值

在工業(yè)物聯(lián)網(wǎng)場(chǎng)景中，MQTT 協(xié)議憑借其特性優(yōu)勢(shì)，在多個(gè)關(guān)鍵領(lǐng)域發(fā)揮著核心作用：

4.1 分布式設(shè)備監(jiān)控與管理

在大型工廠中，分布在不同區(qū)域的設(shè)備通過(guò) MQTT 實(shí)現(xiàn)集中監(jiān)控：

數(shù)據(jù)采集：車(chē)間內(nèi)的 PLC、傳感器等設(shè)備作為 MQTT 客戶端，將運(yùn)行數(shù)據(jù)（如溫度、壓力、轉(zhuǎn)速）發(fā)布到equipment/data主題；

狀態(tài)監(jiān)控：SCADA 系統(tǒng)訂閱該主題，實(shí)時(shí)展示設(shè)備狀態(tài)；

異常報(bào)警：當(dāng)設(shè)備參數(shù)超出閾值時(shí)，觸發(fā)規(guī)則引擎生成報(bào)警消息，發(fā)布到alarm/equipment主題，通知運(yùn)維人員。

某鋼鐵廠部署了 1000 + 臺(tái) MQTT 客戶端設(shè)備，通過(guò) 3 臺(tái)負(fù)載均衡的 EMQ X 代理服務(wù)器，實(shí)現(xiàn)了秒級(jí)數(shù)據(jù)采集與分析，設(shè)備故障響應(yīng)時(shí)間從小時(shí)級(jí)縮短至分鐘級(jí)。

4.2 工業(yè)云平臺(tái)與邊緣設(shè)備連接

在 “云邊協(xié)同” 架構(gòu)中，MQTT 是邊緣設(shè)備與云端平臺(tái)的首選通信協(xié)議：

邊緣數(shù)據(jù)上傳：邊緣網(wǎng)關(guān)（如工業(yè)路由器）收集現(xiàn)場(chǎng)設(shè)備數(shù)據(jù)，通過(guò) MQTT 發(fā)送至云端平臺(tái)；

云端指令下發(fā)：云端平臺(tái)通過(guò) MQTT 向邊緣設(shè)備發(fā)送配置更新、控制指令等；

離線緩存：邊緣網(wǎng)關(guān)在網(wǎng)絡(luò)斷開(kāi)時(shí)緩存數(shù)據(jù)，網(wǎng)絡(luò)恢復(fù)后通過(guò) QoS 1 補(bǔ)發(fā)，確保數(shù)據(jù)完整性。

某汽車(chē)制造企業(yè)的 MES 系統(tǒng)通過(guò) MQTT 連接全國(guó) 5 個(gè)工廠的邊緣設(shè)備，每天處理超過(guò) 1 億條生產(chǎn)數(shù)據(jù)，系統(tǒng)可用性達(dá)到 99.99%。

4.3 工業(yè)移動(dòng)應(yīng)用開(kāi)發(fā)

MQTT 的低延遲特性使其非常適合開(kāi)發(fā)工業(yè)移動(dòng)應(yīng)用：

實(shí)時(shí)數(shù)據(jù)查看：運(yùn)維人員通過(guò)手機(jī) APP 訂閱equipment/real-time主題，查看設(shè)備實(shí)時(shí)狀態(tài)；

遠(yuǎn)程控制：工程師通過(guò) APP 發(fā)布控制指令到control/command主題，實(shí)現(xiàn)對(duì)設(shè)備的遠(yuǎn)程操作；

離線通知：APP 在后臺(tái)保持 MQTT 連接，當(dāng)訂閱的主題有新消息（如報(bào)警）時(shí)，推送通知提醒用戶。

某化工企業(yè)開(kāi)發(fā)的移動(dòng)運(yùn)維 APP，通過(guò) MQTT 連接生產(chǎn)現(xiàn)場(chǎng)設(shè)備，使工程師可隨時(shí)隨地監(jiān)控工藝參數(shù)，緊急情況下可遠(yuǎn)程停機(jī)，避免安全事故。

五、與其他工業(yè)協(xié)議的對(duì)比及選擇策略

在實(shí)際工業(yè)應(yīng)用中，常采用 “MQTT+HTTP+OPC UA” 的混合協(xié)議策略：

MQTT 用于設(shè)備與邊緣 / 云端的實(shí)時(shí)數(shù)據(jù)傳輸和控制指令下發(fā)；

HTTP 用于 Web 界面與后端的交互（如報(bào)表查詢、配置管理）；

OPC UA 用于 PLC 與 SCADA 系統(tǒng)的深度集成（如實(shí)時(shí)控制、程序上傳下載）。

GraniStudio 支持這種混合協(xié)議架構(gòu)，通過(guò)統(tǒng)一的界面配置實(shí)現(xiàn)多協(xié)議協(xié)同，降低系統(tǒng)復(fù)雜度。

六、總結(jié)與技術(shù)展望

MQTT 協(xié)議在工業(yè)物聯(lián)網(wǎng)中的核心價(jià)值在于 “輕量級(jí)、可靠、靈活”，而 GraniStudio 的深度整合使其從 “通用協(xié)議” 升級(jí)為 “工業(yè)專(zhuān)用通信解決方案”。通過(guò)連接池管理、消息轉(zhuǎn)換、協(xié)議橋接等功能，軟件解決了工業(yè)場(chǎng)景中 MQTT 應(yīng)用的 “連接不穩(wěn)定、數(shù)據(jù)處理復(fù)雜、多系統(tǒng)集成難” 等痛點(diǎn)。

對(duì)于工業(yè)用戶而言，GraniStudio 中的 MQTT 方案不僅是一種通信工具，更是構(gòu)建 “實(shí)時(shí)、可靠、安全” 工業(yè)物聯(lián)網(wǎng)系統(tǒng)的基石，在設(shè)備監(jiān)控、遠(yuǎn)程運(yùn)維、云邊協(xié)同等場(chǎng)景中，將持續(xù)發(fā)揮不可替代的作用。

審核編輯 黃宇