華杰智控MQTT網(wǎng)關(guān)HJ8300支持MQTT協(xié)議，支持二次開發(fā)， 協(xié)議定制，支持C，C++,PHP，Python語音開發(fā)。

1. MQTT說明

MQTT是一種基于發(fā)布/訂閱（publish/subscribe）模式的“輕量級”通訊協(xié)議，構(gòu)建于TCP/IP協(xié)議上，IBM在1999年發(fā)布。MQTT最大優(yōu)點是可以以極少的代碼和有限的帶寬，為連接遠程設(shè)備提供實時可靠的消息服務(wù)。做為一種低開銷、低帶寬占用的即時通訊協(xié)議，使其在物聯(lián)網(wǎng)、小型設(shè)備、移動應用等方面有較廣泛的應用。

MQTT發(fā)布/訂閱消息模式，如下示意圖

MQTT協(xié)議在客戶端和服務(wù)器端之間通訊完成，通訊過程中，MQTT協(xié)議中有三種身份：發(fā)布者（Publish）、代理服務(wù)器（Broker）和訂閱者（Subscribe）。

消息的發(fā)布者和訂閱者都是客戶端，消息代理是服務(wù)器，消息發(fā)布者可以同時是訂閱者。

MQTT傳輸?shù)南⒎譃椋褐黝}（Topic）和負載（payload）兩個部分

1. Topic： 消息的類型，訂閱者訂閱（Subscribe）后，就會收到該主題的消息內(nèi)容（payload）。

2. Payload：消息的內(nèi)容，是指訂閱者具體要使用的內(nèi)容。

HJ8300MQTT工業(yè)級網(wǎng)關(guān)是一款帶SDK二次開發(fā)工業(yè)級4G路由器，利用移動網(wǎng)絡(luò)為終端設(shè)備提供無線數(shù)據(jù)傳輸功能，可以安裝MQTT Mosquitto 。 支持SDK二次開發(fā)，ROOT權(quán)限，集成交叉編譯器，集成了GCC、GDB、GLIBC庫，支持C/C++,Python，PHP,支持MQTT，SSH、FTP、MySQL。用戶可以直接通過SSH在HJ8300里編譯自己軟件，直接運行。HJ8300MQTT4G路由器支持4G全網(wǎng)通、WIFI、以太網(wǎng)、交換機、路由器DTU、RS232、RS485。支持遠程控制終端設(shè)備，如PLC、觸摸屏、儀表儀器遠程上下載程序、遠程調(diào)試。

HJ8300的MQTT使用

安裝軟件mosquitto-1.4.15 和 json-c-0.12

Mosquitto提供了Windows、Linux以及qnx系統(tǒng)的版本，HJ8000系列安裝的linux操作系統(tǒng)，所以選擇了mosquitto的linux版本源碼安裝。

HJ8000系列的MQTT的demo采用json編碼，網(wǎng)關(guān)模式作為MQTT的客服端，可以發(fā)布和訂閱MQTT消息，程序部分使用C語言編寫。

demo程序的文件說明：

main.c 主程序文件

base.h 頭文件

Makefile 編譯的Make文件

poll_rftcm_s.txt 配置文件，包含MQTT的服務(wù)器的地址和端口等配置信息

MQTT的消息格式：

網(wǎng)關(guān)發(fā)布消息的TOPIC：/ge/MQTT帳號/網(wǎng)關(guān)MAC/采集設(shè)備地址

網(wǎng)關(guān)訂閱消息的TOPIC：/gc/MQTT帳號/網(wǎng)關(guān)MAC/采集設(shè)備地址

比如服務(wù)器發(fā)布一個時間消息給網(wǎng)關(guān)的82號設(shè)備格式如下：

/ge/bluegw/C2-48-00-00-32-47/82

{ "h":{/* message header */

"T":85,

"ID:1

},

"b":{/* message body */

"cf":3,

"cc":1,/* message command */

"dl":{/* message parameter list */

"week":1,

"hour":12,

"minites":35,

"second":21,

}

}

}

網(wǎng)關(guān)訂閱一個MQTT消息：/ge/bluegw/C2-48-00-00-32-47/82，這樣服務(wù)器或者其他客戶端只要發(fā)送這個消息主題的內(nèi)容，網(wǎng)關(guān)都會收到，然后網(wǎng)關(guān)根據(jù)實際實際情況處理。

HJ8200MQTT demo說明

HJ8200系列有很多接口，比如RS232/RS485/ETH/RF433M等，HJ8200的軟件管理了這些接口，如果用戶需要使用這些接口，可以發(fā)送一個接管命令給HJ8000的軟件，HJ8000就會把這些接口的數(shù)據(jù)直接發(fā)送到linux的命名pipe里面，這樣就可以直接從這些命名pipe里面讀取數(shù)據(jù)，或者寫入數(shù)據(jù)到命名pipe，HJ8000軟件就會直接寫到實際的端口。

MQTT的demo使用的RF433M接口，RF433M接口的命名pipe如下

讀取的pipe名稱: /var/vspp/WR_RF4;

寫入的pipe名稱: /var/vspp/RD_RF4;

MQTTdemo的框架示意圖（由PIPE線程和MQTT線程組成）

注意：

1. MQTT訂閱的消息處理回調(diào)函數(shù)解析命令，把命令掛在在PIPE線程的rf_cmmd_list隊列，由PIPE線程負責發(fā)送

2. PIPE線程的定時器負責檢查超時的數(shù)據(jù)處理。

3. PIPE線程接收函數(shù)負責處理從RF433M的管道來的數(shù)據(jù)，同時發(fā)送rf_cmmd_list隊列的數(shù)據(jù)到RF433M的管道。