來自：http://www.cnblogs.com/secondtononewe/p/6073089.html

官方協議有句如下的話來形容MQTT的設計思想：

“It is designed for connections with remote locations where a "small code footprint" is required or the network bandwidth is limited.”

MQTT：開源、可靠、輕巧、簡單，MQTT的傳輸格式非常精小，最小的資料包只有2個位元，且無應用訊息頭。 MQTT可以保證訊息的可 靠性，它包括三種不同的服務質量（最多隻傳一次、最少被傳一次、一次且只傳一次），如果客戶端意外掉線，可以使用“遺願”釋出一條訊息，同時支援持久訂 閱。MQTT在物聯網以及移動應用中的優勢有：

• 可靠傳輸。MQTT可以保證訊息可靠安全的傳輸，並可以與企業應用簡易整合。
• 訊息推送。支援訊息實時通知、豐富的推送內容、靈活的Pub-Sub以及訊息儲存和過濾。
• 低頻寬、低耗能、低成本。佔用移動應用程式頻寬小，並且頻寬利用率高，耗電量較少。   因此MQTT被廣泛應用於物聯網。

虛擬機器搭建MQTT環境，進行MQTT初體驗 參考：http://blog.csdn.net/xukai871105/article/details/39252653 安裝： # 下載原始碼包  安裝mosquitto時候出現這樣的問題 1.mosquitto_internal.h:51:20: error: ares.h: No such file or directory 其實是因為它新加的功能的原因。開啟config.mk檔案。 吧WITH_SRV:=yes 改成WITH_SRV:=no 就可以編譯了 或者sudo apt-get install libc-ares-dev 2, 找不到libmosquitto.so.1 error while loading shared libraries: libmosquitto.so.1: cannot open shared object file: No such file or directory 【解決方法】——修改libmosquitto.so位置 # 建立連結 sudo ln -s /usr/local/lib/libmosquitto.so.1 /usr/lib/libmosquitto.so.1 # 更新動態連結庫 sudo ldconfig 簡單測試  一個完整的MQTT示例包括一個代理器，一個釋出者和一個訂閱者。測試分為以下幾個步驟： 【1】啟動服務mosquitto。 【2】訂閱者通過mosquitto_sub訂閱指定主題的訊息。 【3】釋出者通過mosquitto_pub釋出指定主題的訊息。 【4】代理伺服器把該主題的訊息推送到訂閱者。 【測試說明】     測試環境：ubuntu 14.04 虛擬機器     在本例中，釋出者、代理和訂閱者均為localhsot，但是在實際的情況下三種並不是同一個裝置，在mosquitto中可通過-h(--host)設定主機名稱(hostname)

。為了實現這個簡單的測試案例，需要在linux中開啟三個控制檯，分別代表代理伺服器、釋出者和訂閱者。 啟動代理服務   mosquitto -v     【-v】列印更多的除錯資訊 訂閱主題 mosquitto_sub -v -t SmartAudio_zhangling     【-t】指定主題，此處為SmartAudio_zhangling     【-v】列印更多的除錯資訊 [email protected]:/opt/mqtt/mosquitto-1.4.10/src# ./mosquitto -c ../mosquitto.conf 1474336624: mosquitto version 1.4.10 (build date 2016-09-19 18:55:57-0700) starting 1474336624: Config loaded from ../mosquitto.conf. 1474336624: Opening ipv4 listen socket on port 1883. 1474336624: Opening ipv6 listen socket on port 1883. 1474336624: Error: Invalid user 'mosquitto'. [email protected]:/opt/mqtt/mosquitto-1.4.10/src# 解決方法： 1.修改配置檔案:mosquitto.conf ，增加登入的使用者   2.執行 adduser mosquitto 釋出訊息 mosquitto_pub -t SmartAudio_zhangling -m 12     【-t】指定主題     【-m】指定訊息內容      【-f】 是可以傳送檔案 通過-f傳遞的檔案上限預設是256M。邏輯中有對檔案大小的判斷，超過256M的檔案則不傳。不知道這裡如果吧這個值修改更大，會不會產生影響，筆者沒有嘗試，因為傳7M的檔案都感覺很慢。（這個問題在MQTT協議介紹中可以得到答案，MQTT檔案長度的表示是用1至4個位元組來表示，而其表示長度的方式又有特殊的加密方式，按照這種方式，其最大表示的長度為256M）  如果不是在同一個裝置，可通過-h指定代理的IP。 （另外還有一個mosquitto_passwd，用於管理密碼，應該是關閉SSL的原因） 執行結果 當釋出者推送訊息之後，訂閱者獲得以下內容   =======================mosquitto部分，嵌入音箱端及手機微信端，可實現廣域網內手機微信對音箱的控制================================= 伺服器部分 mosquitto伺服器部分，肖同學負責搭建好。音箱端與手機端pub和sub都是通過伺服器進行訊息傳遞。IP地址為"120.76.30.18"； 音箱部分 進入網路模式下，則需要開啟一個執行緒，用來開啟mosquitto subscribe 訂閱一個主體。一個音箱實體對應一個主體。其他客戶端可通過這個主題，來與音箱端實現連結。 本專案，定義的主題名字利用音箱的實體地址的唯一性，如SmartAudio_MacAddress。 手機微信部分 而，手機客戶端如何得知音箱端這個主題，方法一，是微信客戶端有提供對應開發包，區域網裝置發現，但是這個功能依賴微信端，尚不穩定，最後並沒採用； 方法二：將主題生成二維碼，貼在音箱上。目前採用方法二。 而協議約定客戶端名字，可以是b_MacAddress。 而手機微信部分是客戶端IOS/Android同仁負責，這裡不作介紹。 下面主要介紹音箱部分移植mosquitto進行應用開發的內容： 開啟訂閱主題執行緒 pthread_create(&mosquitto_client_thread_id, NULL, mosquitto_sub_start, NULL) mosquitto_sub_start 是利用mosquitto sub的原始碼加以修改。 核心內容是， 兩個回撥函式的註冊

mosquitto_connect_callback_set(mosq, my_connect_callback);    
mosquitto_message_callback_set(mosq, my_message_callback);

其中my_connect_callback是mosquitto_loop_forever這個一直存在的迴圈函式在收到伺服器傳遞回來CONNACK資訊（見_mosquitto_handle_connack），則會被觸發，用來呼叫mosquitto_subscribe完成訂閱。

其中my_message_callback則是用於音箱端應用程式的開發，用來接收手機微信端傳遞過來的內容。與手機客戶端定義互動的協議，用於控制音箱的推歌、上下首切換、音源切換、網路模式的切換、音量大小的改變等等。

      互動的內容採用json包，因此需要進行json包的解析和封裝。

正確完成音箱端的訂閱，

注意設定好：

cfg.port = 1883;

cfg.topics[cfg.topic_count-1] = strdup(deviceName);

cfg.host = strdup(serverIp);  //伺服器地址

這裡初始化了一個屬於音箱端全域性的mosq，可用它關聯pub和sub；（pub和sub共用一個全域性mosq即可，並不需要分別申請一個mosq）

音箱端部分，需要pub訊息給手機微信端。採用mosquitto_pub_start傳送訊息。這個不同於sub是一個一直存在的執行緒，pub屬於一次性，訊息傳遞完畢即結束。

mosquitto_pub_start 中 全域性變數pub_topic ，在mosquitto_sub_start裡面有初始化。