MQTT協(xié)議使用及體驗

   
    Mosquitto是一款實(shí)現了 MQTT v3.1 協(xié)議的開(kāi)源消息代理軟件，提供輕量級的，支持發(fā)布/訂閱的的消息推送模式，使設備對設備之間的短消息通信簡(jiǎn)單易用。   

   MQTT是“Message QueuingTelemetry Transport”的英文縮寫(xiě)意思是“消息隊列遙測傳輸”是IBM開(kāi)發(fā)的一個(gè)即時(shí)通訊協(xié)議。它是一種輕量級的、基于代理的“發(fā)布/訂閱”模式的消息傳輸協(xié)議。其具有協(xié)議簡(jiǎn)潔、小巧、可擴展性強、省流量、省電等優(yōu)點(diǎn)，而且已經(jīng)有PHP，JAVA，Python，C，C#等多個(gè)語(yǔ)言版本，基本可以使用在任何平臺上，幾乎可以把所有聯(lián)網(wǎng)物品和外部連接起來(lái)，所以特別適合用來(lái)當做物聯(lián)

網(wǎng)的通信協(xié)議


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

【MQTT協(xié)議特點(diǎn)】——相比于RESTful架構的物聯(lián)網(wǎng)系統，MQTT協(xié)議借助消息推送功能，可以更好地實(shí)現遠程控制。

【MQTT協(xié)議角色】——在RESTful架構的物聯(lián)網(wǎng)系統，包含兩個(gè)角色客戶(hù)端和服務(wù)器端，而在MQTT協(xié)議中包括發(fā)布者，代理器（服務(wù)器）和訂閱者。

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

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

為了方便理解我們可以看一下鏈接：http://blog.csdn.net/xukai871105/article/details/39255089

1 安裝和使用注意點(diǎn)

1.1 安裝

截止2014年9月，最新版本為mosquitto-1.3.4

# 下載源代碼包

wget http://mosquitto.org/files/source/mosquitto-1.3.4.tar.gz

# 解壓

tar zxfv mosquitto-1.3.4.tar.gz

# 進(jìn)入目錄
cd mosquitto-1.3.4

# 編譯

make

# 安裝
sudo make install

1.2 安裝注意點(diǎn)

【1】編譯找不到openssl/ssl.h

【解決方法】——安裝openssl

sudo apt-get install libssl-dev

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

【解決方法】——修改config.mk中的WITH_SRV:=yes，改為WITH_SRV:=no

【3】使用過(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)鏈接庫

sudo ldconfig

【4】make: g++：命令未找到

【解決方法】

安裝g++編譯器

sudo apt-get install g++

2 簡(jiǎn)單測試

一個(gè)完整的MQTT示例包括一個(gè)代理器，一個(gè)發(fā)布者和一個(gè)訂閱者。測試分為以下幾個(gè)步驟：

【1】啟動(dòng)服務(wù)mosquitto。

【2】訂閱者通過(guò)mosquitto_sub訂閱指定主題的消息。

【3】發(fā)布者通過(guò)mosquitto_pub發(fā)布指定主題的消息。

【4】代理服務(wù)器把該主題的消息推送到訂閱者。

【測試說(shuō)明】

測試環(huán)境：ubuntu 12.04 虛擬機

在本例中，發(fā)布者、代理和訂閱者均為localhsot，但是在實(shí)際的情況下三種并不是同一個(gè)設備，在mosquitto中可通過(guò)-h(--host)設置主機名稱(chēng)(hostname)。為了實(shí)現這個(gè)簡(jiǎn)單的測試案例，需要在linux中打開(kāi)三個(gè)控制臺，分別代表代理服務(wù)器、發(fā)布者和訂閱者。

2.1 啟動(dòng)代理服務(wù)

mosquitto -v

【-v】打印更多的調試信息

2.2 訂閱主題

mosquitto_sub -v -t sensor

【-t】指定主題，此處為sensor

【-v】打印更多的調試信息

2.3 發(fā)布內容

mosquitto_pub -t sensor -m 12

【-t】指定主題

【-m】指定消息內容

2.4 運行結果

當發(fā)布者推送消息之后，訂閱者獲得以下內容

sensor 12

而代理服務(wù)器控制臺中會(huì )出現——連接、消息發(fā)布和心跳等調試信息。通過(guò)代理服務(wù)器的調試輸出可以對MQTT協(xié)議的相關(guān)過(guò)程有所了解。