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

核心亮點(diǎn)

公共 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 進(jìn)行安全釋放。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 進(jìn)行安全釋放。externRyanMqttError_eRyanMqttGetConfig(RyanMqttClient_t *client, RyanMqttClientConfig_t **pclientConfig);externRyanMqttError_eRyanMqttFreeConfigFromGet(RyanMqttClientConfig_t *clientConfig);

新增功能價值

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

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

uint32_tplatformUptimeMs(void);

跨平臺毫秒級運(yùn)行時間

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

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

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

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

異常恢復(fù)路徑更明確

測試體系全面升級

新增8 大類專項(xiàng)測試用例，覆蓋從基礎(chǔ)功能到極限壓力場景的全流程驗(yàn)證：

測試覆蓋范圍

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

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

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

并發(fā)壓測:

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

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

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

資源安全：全鏈路內(nèi)存泄漏、句柄泄漏檢測

代碼質(zhì)量與規(guī)范

工具鏈全面集成

檢查重點(diǎn)覆蓋

內(nèi)存安全：杜絕泄漏、越界、懸空指針

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

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

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

安全性與可靠性全面提升

公共 API 全面審查

核心數(shù)據(jù)結(jié)構(gòu)訪問均受同步機(jī)制保護(hù)

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

輸入驗(yàn)證與邊界檢查更嚴(yán)格，防御性編程增強(qiáng)

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

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

總結(jié)

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

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

架構(gòu)更清晰：模塊高度解耦，抽象設(shè)計更合理

質(zhì)量更可信：專項(xiàng)測試 + 靜態(tài)分析 + AI 審查構(gòu)筑強(qiáng)大防線

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

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

從 1.x 遷移至 2.x

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

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

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

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

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

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

強(qiáng)烈建議所有用戶都升級到2.0！選擇latest就是2.0版本，已在公司項(xiàng)目運(yùn)行好幾個月

不準(zhǔn)備升級到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核心庫細(xì)節(jié)優(yōu)化、test新增3個測試?yán)?/p>

20251013更新

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

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

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

測試增強(qiáng)：補(bǔ)充對應(yīng)的單元測試代碼

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