丘源 經(jīng)本欽 李精華?

摘 要：設(shè)計(jì)了一種基于ESP8266 WiFi模塊和MQTT協(xié)議的物聯(lián)網(wǎng)傳感節(jié)點(diǎn)，該節(jié)點(diǎn)具有數(shù)據(jù)采集、數(shù)據(jù)上報(bào)和遠(yuǎn)程控制功能。傳感節(jié)點(diǎn)通過(guò)輕量級(jí)物聯(lián)網(wǎng)MQTT協(xié)議與數(shù)據(jù)采集中心通信，數(shù)據(jù)采集中心能夠自動(dòng)識(shí)別和實(shí)時(shí)顯示傳感節(jié)點(diǎn)的采集數(shù)據(jù)。實(shí)驗(yàn)證明，所設(shè)計(jì)的傳感器節(jié)點(diǎn)可靠、擴(kuò)展性強(qiáng)、通用性好。

關(guān)鍵詞：ESP8266;MQTT協(xié)議;物聯(lián)網(wǎng);傳感器節(jié)點(diǎn);遠(yuǎn)程控制;實(shí)時(shí)顯示

中圖分類(lèi)號(hào)：TP393 文獻(xiàn)標(biāo)識(shí)碼：A 文章編號(hào)：2095-1302（2019）06-00-03

0 引 言

隨著物聯(lián)網(wǎng)技術(shù)日趨成熟，物聯(lián)網(wǎng)已被廣泛應(yīng)用在醫(yī)療、交通與物流、能源與公用事業(yè)、零售業(yè)等領(lǐng)域[1]。據(jù)思科公司（Cisco）思科視覺(jué)化網(wǎng)絡(luò)指數(shù)顯示，到2022年全球有超過(guò)半數(shù)設(shè)備和連接將會(huì)是機(jī)器對(duì)機(jī)器（M2M）的互聯(lián)，比2017年增加34%。智能音箱、固定設(shè)備、移動(dòng)設(shè)備及其他物件的連接數(shù)將從2017年的61億增至2022年的146億[2]。互聯(lián)設(shè)備的數(shù)量和類(lèi)型越來(lái)越多，應(yīng)用環(huán)境日趨復(fù)雜，實(shí)現(xiàn)資源有限或帶寬有限環(huán)境下的傳感器聯(lián)網(wǎng)和保證傳感數(shù)據(jù)的可靠傳輸成為物聯(lián)網(wǎng)技術(shù)應(yīng)用應(yīng)重點(diǎn)考慮的問(wèn)題之一。

物聯(lián)網(wǎng)傳感節(jié)點(diǎn)作為物聯(lián)網(wǎng)和物理世界交互的邊界節(jié)點(diǎn)，負(fù)責(zé)信息的采集和簡(jiǎn)單處理，與將數(shù)據(jù)傳輸?shù)綉?yīng)用層進(jìn)行數(shù)據(jù)分析和處理[3]。傳感器節(jié)點(diǎn)的通信方式主要分為近距離通信和遠(yuǎn)距離通信，傳感器節(jié)點(diǎn)之間一般采用短距離無(wú)線(xiàn)通信，如藍(lán)牙，ZigBee，WiFi等;傳感器與物聯(lián)網(wǎng)云服務(wù)器或應(yīng)用服務(wù)器采用遠(yuǎn)距離通信，如固網(wǎng)、移動(dòng)網(wǎng)絡(luò)（2G/3G/4G）、NB-IoT網(wǎng)絡(luò)等。無(wú)線(xiàn)網(wǎng)絡(luò)連接類(lèi)型（WiFi、移動(dòng)網(wǎng)絡(luò)）是主流?，F(xiàn)在越來(lái)越多的應(yīng)用場(chǎng)合要求傳感器節(jié)點(diǎn)自帶接入網(wǎng)關(guān)，即支持物聯(lián)網(wǎng)網(wǎng)絡(luò)接入服務(wù)。由于傳感器節(jié)點(diǎn)資源有限，受CPU處理能力、內(nèi)存等限制，通常在LwIP協(xié)議棧上采用輕量級(jí)物聯(lián)網(wǎng)傳輸協(xié)議。目前，應(yīng)用最廣泛的物聯(lián)網(wǎng)標(biāo)準(zhǔn)傳輸協(xié)議包括MQTT、CoAP。MQTT是一種在TCP/IP協(xié)議上的基于訂閱/發(fā)布模式的輕量級(jí)傳輸協(xié)議，適用于引入第三方云平臺(tái)的物聯(lián)網(wǎng)應(yīng)用。CoAP即約束應(yīng)用協(xié)議，類(lèi)似HTTP，是一種文檔傳輸協(xié)議，也是一種基于請(qǐng)求/響應(yīng)的客戶(hù)端/服務(wù)器端輕量級(jí)UDP傳輸協(xié)議，適合將物聯(lián)網(wǎng)應(yīng)用嵌入到現(xiàn)有Web服務(wù)器中[4]。

本文基于ESP8266 WiFi模塊和MQTT協(xié)議設(shè)計(jì)了一種低成本物聯(lián)網(wǎng)傳感節(jié)點(diǎn)，以ESP8266嵌入式處理器為核心，采用AM2302傳感器采集溫濕度數(shù)據(jù)，進(jìn)行簡(jiǎn)單處理后將傳感數(shù)據(jù)通過(guò)MQTT協(xié)議發(fā)布到百度天工物聯(lián)網(wǎng)云平臺(tái)IoTHub。數(shù)據(jù)采集中心采用Visual C#實(shí)現(xiàn)，能自動(dòng)識(shí)別傳感節(jié)點(diǎn)和訂購(gòu)傳感器的數(shù)據(jù)，可保存、處理和顯示傳感節(jié)點(diǎn)的溫濕度數(shù)據(jù)。數(shù)據(jù)采集中心可通過(guò)云平臺(tái)IoTHub下發(fā)命令，實(shí)現(xiàn)傳感器節(jié)點(diǎn)參數(shù)配置并讓傳感節(jié)點(diǎn)執(zhí)行指定操作（打開(kāi)/關(guān)閉繼電器）。傳感器節(jié)點(diǎn)性能可靠，擴(kuò)展性強(qiáng)，通用性好。

1 系統(tǒng)總體結(jié)構(gòu)系統(tǒng)由傳感節(jié)點(diǎn)、數(shù)據(jù)采集中心和百度天工物聯(lián)網(wǎng)云平臺(tái)組成，如圖1所示。傳器節(jié)點(diǎn)由ESP8266和AM2302構(gòu)成，實(shí)現(xiàn)溫濕度的采集和上報(bào);數(shù)據(jù)采集中心基于Visual C#開(kāi)發(fā)，實(shí)現(xiàn)傳感數(shù)據(jù)的接收、存儲(chǔ)、分析和顯示;百度天工物聯(lián)網(wǎng)云平臺(tái)IoTHub作為MQTT消息代理，負(fù)責(zé)主題訂閱管理、消息轉(zhuǎn)發(fā)和緩沖，實(shí)現(xiàn)傳感節(jié)點(diǎn)與數(shù)據(jù)采集中心的信息交互。傳感節(jié)點(diǎn)與數(shù)據(jù)采集中心的交互數(shù)據(jù)類(lèi)型為JSON格式。

2 傳感節(jié)點(diǎn)設(shè)計(jì)傳感節(jié)點(diǎn)負(fù)責(zé)采集感知對(duì)象相關(guān)信息，并通過(guò)相應(yīng)的通信模塊將數(shù)據(jù)通過(guò)MQTT消息代理推送到遠(yuǎn)端數(shù)據(jù)采集中心。

2.1 硬件設(shè)計(jì)傳感節(jié)點(diǎn)以ESP8266EX WiFi模塊為核心，通過(guò)I/O外接傳感器AM2302及其他設(shè)備。傳感節(jié)點(diǎn)硬件框圖如圖2所示。

2.2 軟件設(shè)計(jì)

傳感節(jié)點(diǎn)軟件基于NodeMCU固件開(kāi)發(fā)。NodeMCU固件使用Lua腳本語(yǔ)言編程，在樂(lè)鑫ESP8266 Non-OS SDK上開(kāi)發(fā)而來(lái)。NodeMCU固件封裝了ESP8266硬件操作的應(yīng)用編程接口函數(shù)API，同時(shí)還提供I2C，SPI，UART等外設(shè)總線(xiàn)驅(qū)動(dòng)函數(shù)及OLED/TFT顯示驅(qū)動(dòng)、各種類(lèi)型傳感器驅(qū)動(dòng)、網(wǎng)絡(luò)協(xié)議庫(kù)（TCP/UDP，HTTP，MQTT等），開(kāi)發(fā)者無(wú)需了解底層硬件驅(qū)動(dòng)即可快速開(kāi)發(fā)應(yīng)用。傳感節(jié)點(diǎn)程序主要通過(guò)數(shù)據(jù)采集模塊、MQTT客戶(hù)端和網(wǎng)絡(luò)連接模塊實(shí)現(xiàn)。數(shù)據(jù)采集模塊負(fù)責(zé)定時(shí)讀取溫濕度數(shù)據(jù);MQTT客戶(hù)端負(fù)責(zé)維護(hù)與MQTT消息代理IoTHub的連接、發(fā)布傳感數(shù)據(jù)、接收并響應(yīng)數(shù)據(jù)采集中心的命令;網(wǎng)絡(luò)連接模塊負(fù)責(zé)WiFi連接。系統(tǒng)軟件主流程如圖3所示。

2.2.1 數(shù)據(jù)采集模塊

數(shù)據(jù)采集模塊創(chuàng)建了一個(gè)tmr定時(shí)器，周期調(diào)用dht庫(kù)的read（）函數(shù)讀取溫濕度數(shù)據(jù)，再使用string.format函數(shù)將溫濕度數(shù)據(jù)轉(zhuǎn)換為JSON格式。讀取傳感器數(shù)據(jù)代碼：

2.2.2 MQTT客戶(hù)端

傳感節(jié)點(diǎn)和數(shù)據(jù)采集中心基于訂購(gòu)/發(fā)布機(jī)制的MQTT協(xié)議通信進(jìn)行信息交互。傳感節(jié)點(diǎn)和數(shù)據(jù)采集中心作為MQTT客戶(hù)端，百度IoTHub云平臺(tái)作為MQTT代理。消息的發(fā)布和訂購(gòu)基于主題（topic）進(jìn)行。MQTT代理負(fù)責(zé)管理訂閱關(guān)系或緩存消息（保留標(biāo)志為真的消息），將消息轉(zhuǎn)發(fā)給已訂閱主題的MQTT客戶(hù)端。為了實(shí)現(xiàn)傳感節(jié)點(diǎn)與數(shù)據(jù)采集中心的數(shù)據(jù)交互，兩者發(fā)布與訂閱的主題見(jiàn)表1所列。

msghandler為訂購(gòu)消息處理函數(shù)，用于解析和處理從數(shù)據(jù)采集中心收到的JSON格式數(shù)據(jù)。JSON數(shù)據(jù)采用鍵（key）值（value）對(duì)結(jié)構(gòu)，key可用來(lái)表示消息類(lèi)型，value為消息內(nèi)容。JSON格式數(shù)據(jù)用sjson模塊的decode（）函數(shù)解析成table表格數(shù)據(jù)。傳感節(jié)點(diǎn)調(diào)用publish函數(shù)向某個(gè)主題發(fā)布消息，語(yǔ)法：mqtt：publish（topic，payload，qos，retain[，function（client）]）。topic是發(fā)布的主題;payload為將發(fā)布的消息;qos為QoS服務(wù)質(zhì)量;0表示只發(fā)送最多一次便可送達(dá)，1表示至少一次可送達(dá)，2表示一次便到達(dá);Retain為保留標(biāo)志，指示服務(wù)端是否需要存儲(chǔ)當(dāng)前消息;function（client）為消息發(fā)布成功回調(diào)函數(shù)，在收到代理發(fā)布確認(rèn)PUBACK消息后執(zhí)行函數(shù)。

3 數(shù)據(jù)采集中心設(shè)計(jì)數(shù)據(jù)采集中心負(fù)責(zé)傳感節(jié)點(diǎn)的管理及傳感數(shù)據(jù)的顯示，其中傳感節(jié)點(diǎn)管理包括節(jié)點(diǎn)自動(dòng)識(shí)別、節(jié)點(diǎn)主題訂閱、節(jié)點(diǎn)控制等。數(shù)據(jù)采集中心與傳感節(jié)點(diǎn)通過(guò)MQTT協(xié)議的訂購(gòu)/發(fā)布機(jī)制進(jìn)行異步通信，兩者不必知道對(duì)方的IP地址，所有消息均通過(guò)MQTT消息代理轉(zhuǎn)發(fā)。數(shù)據(jù)采集中心識(shí)別傳感節(jié)點(diǎn)流程如圖4所示。傳感節(jié)點(diǎn)上線(xiàn)時(shí)向主題$baidu/iot/general/data/id/status發(fā)布保留標(biāo)志為真的消息“online”，離線(xiàn)時(shí)通過(guò)最后遺囑（Last Will）發(fā)布離線(xiàn)消息“offline”。數(shù)據(jù)采集中心連接到MQTT消息代理IoTHub，在訂閱主題$baidu/iot/general/data/+/status后，會(huì)收到所有傳感節(jié)點(diǎn)的狀態(tài)消息，從消息主題解析出節(jié)點(diǎn)ID（+通配符所對(duì)應(yīng)的字段），如果是新節(jié)點(diǎn)，則先添加節(jié)點(diǎn)再更新?tīng)顟B(tài)，否則直接更新節(jié)點(diǎn)狀態(tài)。

數(shù)據(jù)采集中心訂購(gòu)傳感節(jié)點(diǎn)主題$baidu/iot/general/data/id/data后，當(dāng)傳感節(jié)點(diǎn)向此主題發(fā)布消息時(shí)，消息代理IoTHub將會(huì)把消息轉(zhuǎn)發(fā)給數(shù)據(jù)采集中心。數(shù)據(jù)采集中心收到傳感節(jié)點(diǎn)數(shù)據(jù)后，解析JSON格式消息獲得消息的數(shù)據(jù)類(lèi)型。如果是傳感數(shù)據(jù)，則存儲(chǔ)后顯示;如果是傳感節(jié)點(diǎn)配置信息，則存儲(chǔ)到節(jié)點(diǎn)信息。信息處理流程如圖5所示。

數(shù)據(jù)采集中心界面如圖6所示。界面上部分顯示節(jié)點(diǎn)列表及最新的節(jié)點(diǎn)傳感數(shù)據(jù)，下部分顯示節(jié)點(diǎn)數(shù)據(jù)曲線(xiàn)圖。

4 結(jié) 語(yǔ)

本文設(shè)計(jì)了基于MQTT協(xié)議的物聯(lián)網(wǎng)傳感節(jié)點(diǎn)，采用ESP8266WiFi模塊+傳感器采集數(shù)據(jù)與NodeMCU物聯(lián)網(wǎng)平臺(tái)的MQTT模塊實(shí)現(xiàn)傳感節(jié)點(diǎn)與數(shù)據(jù)采集中心交互，數(shù)據(jù)采集中心采用Visual C# + MQTTnet庫(kù)實(shí)現(xiàn)傳感節(jié)點(diǎn)的自動(dòng)識(shí)別與控制、傳感節(jié)點(diǎn)數(shù)據(jù)的存儲(chǔ)與顯示。系統(tǒng)運(yùn)行穩(wěn)定，擴(kuò)展性強(qiáng)，搭配不同傳感器就能實(shí)現(xiàn)特定的物聯(lián)網(wǎng)傳感節(jié)點(diǎn)。

參 考 文 獻(xiàn)

[1]沃達(dá)豐.物聯(lián)網(wǎng)市場(chǎng)晴雨表（2017版）[R/OL].2017.

[2] Cisco. Cisco Visual Networking Index： Forecast and Trends，2017–2022[R/OL].2018.

[3]吳大鵬，舒毅，王汝言，等.物聯(lián)網(wǎng)技術(shù)與應(yīng)用[M].北京：電子工業(yè)出版社，2012：63-64.

[4]王劍秋，趙一.物聯(lián)網(wǎng)傳輸協(xié)議MQTT與CoAP比較與應(yīng)用[J].計(jì)算機(jī)時(shí)代，2017（10）：25-28.

[5]樂(lè)鑫信息科技.ESP8266EX技術(shù)規(guī)格書(shū)[Z].2018.

[6]奧松電子.溫濕度模塊AM2302產(chǎn)品手冊(cè)[Z].2018.

[7]王成，王躍.基于MQTT協(xié)議與Android技術(shù)的跨平臺(tái)訪(fǎng)客管理系統(tǒng)[J].物聯(lián)網(wǎng)技術(shù)，2017，7（3）：50-52.

[8]王浩.基于ESP8266WiFi平臺(tái)和MQTT協(xié)議的遠(yuǎn)程設(shè)備數(shù)據(jù)采集與控制設(shè)計(jì)[J].泰山學(xué)院學(xué)報(bào)，2017，39（6）：86-91.

[9]王瑞，兀玉潔，李燕蘋(píng).基于MQTT協(xié)議的物聯(lián)網(wǎng)實(shí)訓(xùn)云平臺(tái)設(shè)計(jì)[J].工業(yè)控制計(jì)算機(jī)，2018，31（9）：101-103.

[10]于亦瀟，鄭其林，成欣雨.基于語(yǔ)音識(shí)別和MQTT協(xié)議的智能家居系統(tǒng)實(shí)現(xiàn)[J].物聯(lián)網(wǎng)技術(shù)，2017，7（11）：97-99.