前言

本文將簡(jiǎn)單介紹DTU701訂閱MQTT消息，遠(yuǎn)程控制LED燈。

MQTT是IBM開發(fā)的一個(gè) 即時(shí)通訊 協(xié)議。MQTT是面向M2M和物聯(lián)網(wǎng)的連接協(xié)議，采用輕量級(jí)發(fā)布和訂閱消息傳輸機(jī)制。

若初次接觸MQTT協(xié)議，可先理解以下概念：

MQTT協(xié)議特點(diǎn)—— 借助消息推送功能，可以更好地實(shí)現(xiàn)遠(yuǎn)程控制。

MQTT協(xié)議角色—— 發(fā)布者，代理器（服務(wù)器）和訂閱者。

MQTT協(xié)議消息—— 消息可理解為發(fā)布者和訂閱者交換的內(nèi)容（負(fù)載），這些消息包含具體的內(nèi)容，可以被訂閱者使用。

MQTT協(xié)議主題—— 主題可理解為相同類型或相似類型的消息集合。

所以要完成目標(biāo)，需要搭建一臺(tái)MQTT服務(wù)器，我們采用ubuntu系統(tǒng)，IP為 10.10.80.106 。

發(fā)布者，采用Windows 運(yùn)行MQTT測(cè)試工具。訂閱者，為DTU701，采用python編寫，并控制LED。

?

設(shè)計(jì)一個(gè)簡(jiǎn)單的測(cè)試案例，在ubuntu上運(yùn)行MQTT代理服務(wù)器，而DTU701訂閱主題為gpio的消息，Windows發(fā)布同主題消息，消息的內(nèi)容為JSON數(shù)據(jù)包，數(shù)據(jù)包格式為{“index”:130,“value”:0}，index代表GPIO的編號(hào)，value代表打開或關(guān)閉狀態(tài)。

?

MQTT服務(wù)器

Mosquitto是一款實(shí)現(xiàn)了 MQTT v3.1 協(xié)議的開源消息代理軟件，提供輕量級(jí)的，支持發(fā)布/訂閱的的消息推送模式，使設(shè)備對(duì)設(shè)備之間的短消息通信簡(jiǎn)單易用。我們?cè)趗buntu上安裝mosquitto。

下載源碼http://mosquitto.org/files/source/

這里選擇mosquitto-1.4.5，解壓編譯make & make install

?

常見(jiàn)問(wèn)題：

編譯找不到openssl/ssl.h

解決方法：安裝openssl

sudo apt-get install libssl-dev

編譯過(guò)程找不到ares.h

解決方法：修改config.mk中的WITH_SRV:=yes，改為WITH_SRV:=yes

使用過(guò)程中找不到libmosquitto.so.1

error while loading shared libraries: libmosquitto.so.1: cannot open shared object file: No such file or directory

解決方法：修改libmosquitto.so位置 創(chuàng)建鏈接

sudo ln -s /usr/local/lib/libmosquitto.so.1 /usr/lib/libmosquitto.so.1

# 更新動(dòng)態(tài)鏈接庫(kù)

sudo ldconfig

make: g++：命令未找到

解決方法：安裝g++編譯器

sudo apt-get install g++

?

開啟MQTT服務(wù)

在ubuntu終端輸入如下命令：

mosquitto -v

Ubuntu 系統(tǒng)IP為10.10.80.106

?

?

發(fā)布者

采用windows下mqtt工具，mqtt工具很多如mqtt-spy，為了方便我這邊采用MQTT測(cè)試工具（網(wǎng)盤可下載）：

輸入MQTT服務(wù)器IP及端口號(hào)，點(diǎn)擊connect

?

訂閱者

基于DTU701 采用python編寫代碼實(shí)現(xiàn)mqtt訂閱。

paho-python是一個(gè)符合MQTT v3.1協(xié)議的客戶端，paho-python可連接MQTT代理服務(wù)器、發(fā)布消息、訂閱消息和獲得推送消息。DTU701默認(rèn)帶有paho-python模塊。

DTU701訂閱代碼 mqtt.py

注意：網(wǎng)絡(luò)編程中，服務(wù)器和瀏覽器只認(rèn)bytes 類型數(shù)據(jù)。所以msg.payload為bytes類型字符串。

運(yùn)行python mqtt.py 訂閱，? MQTT測(cè)試工具 發(fā)布send。結(jié)果如下：

至此，已實(shí)現(xiàn)預(yù)定的設(shè)想。可見(jiàn)python 采用50行代碼實(shí)現(xiàn)MQTT，足見(jiàn)其強(qiáng)橫。

?