mqttx截圖

mqtt sub （mqtt訂閱主題）

接下來我們試一下訂閱主題，使用多通配符來測試

先測試 “” 通配符，””比較特殊，應用不能使用”$”開頭的系統主題！
按規范服務端不能將 $ 字符開頭的主題名匹配通配符 (#或+) 開頭的主題過濾器

由于應用不能使用”**”開頭的系統主題所以 “broker.emqx.io” 不允許訂閱 “**SYS”, 但是為了測試我把我的mqtt服務器設置為允許訂閱，下圖示例使用我的mqtt服務器來進行測試。 如果您測試的時候發現訂閱失敗請查看您的mqtt服務器是否允許應用訂閱”$”開頭的系統主題

我使用emqx服務端，當訂閱 “$SYS/#” 時會觸發保留消息打印地址、應用名、版本等信息

RyanMqtt訂閱結果

mqttx訂閱結果

再來測試 “/“、”#”、”+” 通配符
為了快速我就在一個主題里面使用多個通配符，發送符合不同通配符的消息來進行測試
訂閱主題：testdown/+/nihao/#

下圖中紅框發送的是符合訂閱主題通配符的，黑框是不符合訂閱主題通配符的。
可以看到RyanMqtt可以準確的接收到通配符消息。

mqtt unsub （mqtt取消訂閱主題）
取消訂閱主題，取消沒訂閱的主題時會自動忽略。

可以看到取消訂閱后再發送消息，RyanMqtt就不會收到了

下圖第一個紅框為第一次取消可以觸發回調，第二次取消就沒有任何響應。

mqtt listsub （mqtt獲取已訂閱主題）
打印結果執行順序為:

打印已訂閱主題 —> 訂閱”testdown/+/nihao/#”主題 —> 打印已訂閱主題 —> 訂閱”testdown2”主題 —> 打印已訂閱主題 —> 取消訂閱”testdown/+/nihao/#”主題 —> 打印已訂閱主題

mqtt listack （打印ack鏈表,輔助功能）
ack鏈表包含發送qos1 / qos2 的ack報文、接收qos1 / qos2 的ack報文、訂閱 / 取消訂閱主題的ack報文。
根據上面的描述可以知道 ack鏈表 通常都應該為空。只有在上訴情況下才會存在，但是礙于篇幅這里無法進行測試了，等下一篇文章測試qos1 / qos2消息穩定性時再進行展示

mqtt listmsg （打印msg鏈表,輔助功能）
msg鏈表保存著訂閱主題的信息，接收消息、取消訂閱的時候都會操作msg鏈表。
所以listmsg和listsub是一摸一樣的操作，結果自然也就一樣，這里就不展示了

mqtt data （打印測試信息用戶自定義的）
此接口我用來測試qos消息穩定性，沒有實際意義。

4、將RyanMqtt添加到自己項目代碼里，不使用msh示例
上面我們使用msh示例來進行RyanMqtt的測試，但在項目中我們肯定不會通過msh來操作mqtt，所以我們將根據msh示例來將RyanMqtt添加到代碼里
首先我們思考下mqtt的執行流程，根據示例來看我們需要

處理訂閱消息
連接mqtt服務器 —> 訂閱主題 —> 收到訂閱主題的消息 —> 在回調函數里面消費消息（調函數的執行環境是mqtt客戶端的線程，所以非常不建議在回調函數里面做復雜邏輯操作，一是會阻塞mqtt線程運行，二是可能會導致mqtt線程爆棧。還是看使用場景如果需要串行處理mqtt消息在回調里面使用是挺好的）

發布消息
連接mqtt服務器 —> 發布主題消息(qos1 / qos2會有發送成功或者超過重發次數的回調)

重連邏輯

配置mqtt客戶端自動重連 —> 連接服務器
不配置mqtt客戶端自動重連 —> 連接服務器 —> 獲取mqtt客戶端狀態（斷連狀態手動調用重連函數）
根據上面的處理方式我們來進行代碼編寫，為了方便我都放在main函數了

這是原始main函數，只設置了netdev狀態變更回調

先添加頭文件，如下圖

1、先添加連接服務器函數，這里直接將msh示例中的connect函數復制到main.c，并處理報錯地方(自行處理都很簡單，都是資源未定義），圖片放不下我就不截圖了

2、再添加訂閱主題函數，訂閱主要要等mqtt連接成功后。所以不管有沒有使能clearSession，都非常推薦在連接成功回調函數中訂閱主題 如下圖所示

3、再添加發布消息，這里簡單起見直接加個循環，每10秒發送一個hello。(mqtt沒有連接成功時也可以發布但是mqtt客戶端不會進行處理，會直接丟棄不管qos等級) 如下圖所示

4、消費訂閱主題的消息，這里是直接打印出來消息的主題、報文id、載荷長度、載荷指針，推薦通過消息隊列發送到別的線程進行處理，或者您如果知道在回調函數處理的副作用的話可以在回調函數中直接處理

注：載荷指針最后一位沒有 “?”，可能會存在臟數據，需要用戶手動處理。下圖給出一種處理方案
或者mqtt消息一般為json，可以使用RyanJson / cJSON來處理json數據，都可以自動識別尾部臟數據

5、這樣我們就添加完成了，燒錄進行測試
如下面兩個圖所示，每秒上傳一次消息，接收到消息后進行打印出來。結果如我們所想

5、總結
這篇文章簡單介紹了RyanMqtt的使用，包括msh示例和添加到自己的工程代碼里面。但文章礙于篇幅限制介紹的始終很淺，想深入的了解還是要看代碼，RyanMqtt注釋都為中文。

接下來應該還會寫兩篇文章介紹RyanMqtt，一篇進行RyanMqtt的qos1 / qos2消息等級的穩定性測試，另一篇介紹下RyanMqtt移植指南

后面看要不要詳細介紹一下mqtt協議，RyanMqtt代碼倉庫docs/下有mqtt3.1.1協議中文版本pdf，一般來說看文檔就可以了。
以及mqtt5.0，5.0增加了很多激動人心的特性，在考慮要不要適配一下，看大家需求了，可能遙遙無期哈哈哈哈哈。