RyanMqtt 2.0

RT-Thread 社區(qū)精品軟件包 RyanMqtt 發(fā)布 2.0 新版本！
更輕、更快、更安全、更可靠，為你的物聯(lián)網(wǎng)連接注入新動力。

軟件包地址：https://packages.rt-thread.org/detail.html?package=RyanMqtt

原文鏈接，歡迎討論：https://club.rt-thread.org/ask/article/3d5f29ae6ac922e0.html

核心亮點

公共 API 變化

新增接口

// 批量訂閱/取消訂閱externRyanMqttError_eRyanMqttSubscribeMany(RyanMqttClient_t *client,int32_tcount, RyanMqttSubscribeData_t subscribeManyData[]);externRyanMqttError_eRyanMqttUnSubscribeMany(RyanMqttClient_t *client,int32_tcount, RyanMqttUnSubscribeData_t unSubscribeManyData[]);// 帶用戶數(shù)據(jù)的發(fā)布externRyanMqttError_eRyanMqttPublishAndUserData(RyanMqttClient_t *client,char*topic,uint16_ttopicLen, char*payload,uint32_tpayloadLen, RyanMqttQos_e qos, RyanMqttBool_e retain,void*userData);// 線程安全的訂閱查詢，僅可通過 RyanMqttSafeFreeSubscribeResources 進行安全釋放。externRyanMqttError_eRyanMqttGetSubscribeSafe(RyanMqttClient_t *client, RyanMqttMsgHandler_t **msgHandles, int32_t*subscribeNum);externRyanMqttError_eRyanMqttSafeFreeSubscribeResources(RyanMqttMsgHandler_t *msgHandles,int32_tsubscribeNum);// 訂閱數(shù)量查詢externRyanMqttError_eRyanMqttGetSubscribeTotalCount(RyanMqttClient_t *client,int32_t*subscribeTotalCount);// 獲取 MQTT Config 信息，僅可通過 RyanMqttFreeConfigFromGet 進行安全釋放。externRyanMqttError_eRyanMqttGetConfig(RyanMqttClient_t *client, RyanMqttClientConfig_t **pclientConfig);externRyanMqttError_eRyanMqttFreeConfigFromGet(RyanMqttClientConfig_t *clientConfig);

新增功能價值

平臺抽象層優(yōu)化

1. 統(tǒng)一時間接口

uint32_tplatformUptimeMs(void);

跨平臺毫秒級運行時間

內部處理 32 位回繞，長時間運行穩(wěn)定

2. 網(wǎng)絡收發(fā)模型簡化

收發(fā)接口改為單次調用語義，減少冗余循環(huán)與分支

返回實際傳輸字節(jié)數(shù)，更貼近底層行為

異常恢復路徑更明確

測試體系全面升級

新增8 大類專項測試用例，覆蓋從基礎功能到極限壓力場景的全流程驗證：

測試覆蓋范圍

基礎連接：100 次循環(huán)連接/斷開，混合 QoS 消息與訂閱

消息流控：連續(xù)發(fā)送 QoS0/1/2 等級 1000 條消息，混合 QoS 壓力測試

訂閱管理：批量、大量、重復、混合 QoS 訂閱與取消

并發(fā)壓測:

單客戶端 20 線程 × 各 1000 條 QoS1/2 消息

多客戶端 20 并發(fā)實例進行雙向發(fā)布/訂閱

可靠性：長連接、弱網(wǎng)、Keep-Alive、重連機制驗證

資源安全：全鏈路內存泄漏、句柄泄漏檢測

代碼質量與規(guī)范

工具鏈全面集成

檢查重點覆蓋

內存安全：杜絕泄漏、越界、懸空指針

性能優(yōu)化：減少冗余拷貝與低效算法

可讀性：命名規(guī)范、注釋完整、邏輯清晰

成果：實現(xiàn)接近語法級”零缺陷“，長期維護成本大幅降低

安全性與可靠性全面提升

公共 API 全面審查

核心數(shù)據(jù)結構訪問均受同步機制保護

動態(tài)內存策略更健壯，異常路徑也能安全釋放

輸入驗證與邊界檢查更嚴格，防御性編程增強

網(wǎng)絡異常處理更完善，弱網(wǎng)環(huán)境下連接恢復更快

錯誤恢復路徑更穩(wěn)健，超時策略更精準

總結

本次 RyanMqtt 2.0 是一次具有里程碑意義的升級：

技術棧現(xiàn)代化：遷移至 coreMQTT，擁抱更活躍的生態(tài)與未來擴展能力

架構更清晰：模塊高度解耦，抽象設計更合理

質量更可信：專項測試 + 靜態(tài)分析 + AI 審查構筑強大防線

性能再優(yōu)化：更低資源占用、更高吞吐效率

維護更輕松：統(tǒng)一代碼規(guī)范、平臺抽象降低長期開發(fā)成本

從 1.x 遷移至 2.x

RyanMqtt 2.0 在設計上盡量減少破壞性變更。升級過程極為簡單：

從V1.x升級到V2.x時，需在RyanMqttClientConfig_t結構體中移除以下四個已廢棄字段：

char*recvBuffer; // MQTT 接收緩沖區(qū)（已廢棄）char*sendBuffer; // MQTT 發(fā)送緩沖區(qū)（已廢棄）uint32_trecvBufferSize;// 接收緩沖區(qū)大?。ㄒ褟U棄）uint32_tsendBufferSize;// 發(fā)送緩沖區(qū)大?。ㄒ褟U棄）

受影響的主要接口（其余接口原則上兼容，如有差異以頭文件為準）：

RyanMqttError_eRyanMqttSetConfig(RyanMqttClient_t *client, RyanMqttClientConfig_t *clientConfig);// packetType 不再使用enum msgTypes, 新類型請參考 RyanMqttPublic.h 文件內MQTT packet types宏定義RyanMqttError_eRyanMqttDiscardAckHandler(RyanMqttClient_t *client,uint8_tpacketType,uint16_tpacketId);

其余 API 與配置保持兼容，無需額外修改即可完成遷移。若編譯期出現(xiàn)不兼容，請以 mqttclient/include/*.h 中的最新簽名為準。

強烈建議所有用戶都升級到2.0！選擇latest就是2.0版本，已在公司項目運行好幾個月

不準備升級到2.0的用戶可以選擇1.2.1版本，是V1的最后一個版本

RyanMqtt github倉庫：

https://github.com/Ryan-CW-Code/RyanMqtt

RT-Thread社區(qū)軟件包：

https://packages.rt-thread.org/detail.html?package=RyanMqtt

20250916更新

RyanMqtt核心庫細節(jié)優(yōu)化、test新增3個測試例程

20251013更新

修復客戶端銷毀邏輯：在 init 后未執(zhí)行 start 即銷毀時，資源無法釋放的問題

支持零長度字符串：clientId、userName、password 現(xiàn)在允許長度為 0

內存優(yōu)化：降低 Config 內存占用

測試增強：補充對應的單元測試代碼

RT-Thread Github 開源倉庫，歡迎撒個星(Star)支持，更期待你的代碼貢獻：https://github.com/RT-Thread/rt-thread