物聯(lián)網(wǎng)消息隊(duì)列后端網(wǎng)絡(luò)/通信【免費(fèi)下載鏈接】mosquittoEclipse Mosquitto - An open source MQTT broker項(xiàng)目地址https://gitcode.com/gh_mirrors/mo/mosquitto點(diǎn)擊查看免費(fèi)下載導(dǎo)讀Mosquitto 0.9.3 是 Eclipse Mosquitto 早期開(kāi)發(fā)階段的一個(gè)純?nèi)毕菪迯?fù)bugfix版本圍繞 QoS 2 保留消息狀態(tài)、監(jiān)聽(tīng)套接字地址族回退、非 clean session 重連消息保留、Python 客戶端腳本兼容性與 Windows 頭文件包含五個(gè)具體問(wèn)題展開(kāi)。本文以官方發(fā)布說(shuō)明 version-0-9-3-released.md 為主線逐條解析每個(gè)修復(fù)背后的行為差異并結(jié)合當(dāng)前倉(cāng)庫(kù)的 retain.c、handle_publish.c、net.c、handle_connect.c 等源碼說(shuō)明這些問(wèn)題在現(xiàn)代版本中的演進(jìn)形態(tài)幫助讀者理解 MQTT broker 在消息保留、會(huì)話管理和監(jiān)聽(tīng)器初始化上的底層機(jī)制。發(fā)布背景一次純 Bugfix 迭代Mosquitto 0.9.3 發(fā)布于 2011 年 3 月定位是缺陷修復(fù)版本官方說(shuō)明明確其不包含任何新功能只解決既有問(wèn)題。發(fā)布說(shuō)明列出了五條修復(fù)項(xiàng)為 QoS 2 消息設(shè)置保留retained消息狀態(tài)bug #726535僅當(dāng)沒(méi)有任何地址族可用時(shí)才以錯(cuò)誤退出而非任一地址族不可用就中止非 clean session 客戶端重連時(shí)不再清空已排隊(duì)消息讓 mosquitto.py 兼容 Python 2.6 以下版本修復(fù) mosquitto.h 在 Windows 平臺(tái)的頭文件包含問(wèn)題。這些修復(fù)覆蓋了 broker 的消息生命周期、監(jiān)聽(tīng)器初始化、會(huì)話恢復(fù)以及跨平臺(tái)構(gòu)建兼容性。下文逐條結(jié)合源碼展開(kāi)。修復(fù)一QoS 2 消息的保留標(biāo)志bug #726535MQTT 的 PUBLISH 報(bào)文頭中有一個(gè) RETAIN 標(biāo)志位0x01。當(dāng)發(fā)布者以 retain1 發(fā)布消息時(shí)broker 不僅要把消息分發(fā)給當(dāng)前訂閱者還要將其存入保留消息樹(shù)供后續(xù)訂閱該主題的客戶端在訂閱建立時(shí)立即收到。問(wèn)題 #726535 的場(chǎng)景是當(dāng) QoS 2 消息經(jīng)過(guò)完整的 PUBREC/PUBREL 握手之后其保留狀態(tài)沒(méi)有被正確設(shè)置導(dǎo)致本應(yīng)進(jìn)入保留消息樹(shù)的 QoS 2 消息丟失了 retain 語(yǔ)義。在當(dāng)前源碼 handle_publish.c 中消息進(jìn)入處理管線時(shí)首先解析保留位并做可用性檢查base_msg-data.retain (header 0x01); if(base_msg-data.retain db.config-retain_available false){ ... }隨后在 retain.c 的retain__store()中保留消息被寫(xiě)入一棵以主題層級(jí)組織的哈希樹(shù)if(retainhier-retained){ if(persist retainhier-retained-data.topic[0] ! $ base_msg-data.payloadlen 0){ /* Only delete if another retained message isnt replacing this one */ plugin_persist__handle_retain_msg_delete(retainhier-retained); } db__msg_store_ref_dec(retainhier-retained); ... } if(base_msg-data.payloadlen){ retainhier-retained base_msg; db__msg_store_ref_inc(retainhier-retained); ... }關(guān)鍵點(diǎn)在retain__store()之前QoS 2 消息在handle_publish.c中需要先走完去重與握手流程handle_publish.c 中通過(guò)db__message_store_find檢查已存儲(chǔ)消息、處理dup標(biāo)志只有經(jīng)過(guò)這些步驟后消息才會(huì)真正進(jìn)入sub__messages_queue和retain__store。0.9.3 修復(fù)的正是這一鏈條上 retain 狀態(tài)傳遞的缺口確保 QoS 2 消息在完成完整握手后仍能攜帶 retain 語(yǔ)義進(jìn)入保留消息樹(shù)。與之配套的讀取路徑是retain__queue()retain.c當(dāng)客戶端訂閱某個(gè)主題過(guò)濾器時(shí)broker 將訂閱主題切分為 token 后在保留樹(shù)上逐級(jí)搜索retain__search并通過(guò)retain__process按訂閱 QoS 與消息 QoS 的較小值下發(fā)保留消息retain.csub_qos sub-options 0x03; if (db.config-upgrade_outgoing_qos){ qos sub_qos; } else { qos retained-data.qos; if(qos sub_qos) qos sub_qos; }可見(jiàn)QoS 2 的保留消息能否被正確下發(fā)依賴寫(xiě)入端data.retain字段的正確傳遞。0.9.3 修復(fù)的 bug #726535 正是要保證這一字段在 QoS 2 握手下不被丟失。修復(fù)二監(jiān)聽(tīng)套接字按地址族回退而非整體中止在 0.9.3 之前broker 在打開(kāi)監(jiān)聽(tīng)套接字時(shí)如果某個(gè)地址族IPv4 或 IPv6不可用就會(huì)直接以錯(cuò)誤退出。修復(fù)后行為變?yōu)橹挥挟?dāng)所有地址族都無(wú)法打開(kāi)時(shí)才中止啟動(dòng)只要還有任一地址族可用broker 就繼續(xù)運(yùn)行。這一策略在現(xiàn)代版本中體現(xiàn)為 net.c 的net__socket_listen_tcp()實(shí)現(xiàn)。該函數(shù)先用getaddrinfo解析監(jiān)聽(tīng)地址listener-hostlistener-port然后遍歷返回的地址鏈表ainfohints.ai_family AF_UNSPEC; /* 未指定 socket_domain 時(shí)同時(shí)嘗試 IPv4/IPv6 */ hints.ai_flags AI_PASSIVE; hints.ai_socktype SOCK_STREAM; rc getaddrinfo(listener-host, service, hints, ainfo); ... for(rp ainfo; rp; rp rp-ai_next){ if(rp-ai_family AF_INET){ log__printf(NULL, MOSQ_LOG_INFO, Opening ipv4 listen socket on port %d., ...); }else if(rp-ai_family AF_INET6){ log__printf(NULL, MOSQ_LOG_INFO, Opening ipv6 listen socket on port %d., ...); }else{ continue; } sock socket(rp-ai_family, rp-ai_socktype, rp-ai_protocol); if(sock INVALID_SOCKET){ net__print_error(MOSQ_LOG_WARNING, Warning: %s); continue; /* 單個(gè)地址族失敗僅告警繼續(xù)嘗試下一個(gè) */ } ... }注意兩個(gè)細(xì)節(jié)逐地址族容錯(cuò)socket()失敗時(shí)只打 Warning 并continue不中斷整個(gè)監(jiān)聽(tīng)器創(chuàng)建。這正對(duì)應(yīng) 0.9.3 修復(fù)說(shuō)明中不再因任一地址族不可用而中止的語(yǔ)義。AI_PASSIVE與AF_UNSPEC組合未顯式配置socket_domain時(shí)net.chints.ai_family AF_UNSPEC讓系統(tǒng)同時(shí)解析 IPv4/IPv6只有配置了socket_domain時(shí)才強(qiáng)制單一地址族。若讀者在運(yùn)行環(huán)境中只啟用了 IPv6 或只有 IPv4 可用現(xiàn)代 Mosquitto 會(huì)在日志中分別打印Opening ipv4 listen socket.../Opening ipv6 listen socket...并繼續(xù)監(jiān)聽(tīng)成功的那一族——這正是 0.9.3 修復(fù)行為至今的延續(xù)。修復(fù)三非 clean session 重連不清空排隊(duì)消息MQTT 的 clean sessionv3.1/3.1.1或 clean startv5語(yǔ)義決定客戶端以 clean session1 連接時(shí)broker 必須丟棄該客戶端此前的一切會(huì)話狀態(tài)而 clean session0 時(shí)broker 應(yīng)保留訂閱與未投遞消息等待客戶端重連后繼續(xù)投遞。0.9.3 修復(fù)的問(wèn)題是此前非 clean session 客戶端重連時(shí)已排隊(duì)的消息被錯(cuò)誤清空破壞了持久會(huì)話persistent session的基本承諾。當(dāng)前源碼 handle_connect.c 對(duì)會(huì)話恢復(fù)的處理如下if(context-clean_start true){ sub__clean_session(found_context); } ... if(context-clean_start false found_context-session_expiry_interval 0){ ... /* v5 下按會(huì)話過(guò)期時(shí)間恢復(fù) */ }也就是說(shuō)只有clean_start true才調(diào)用sub__clean_session()清除會(huì)話clean session0 時(shí)則保留原有訂閱、入站/出站消息隊(duì)列msgs_in、msgs_out見(jiàn) context.c使斷線期間積壓的消息能在重連后繼續(xù)投遞。與之配套的還有db__message_write_queued_in()handle_publish.cbroker 在完成一次 PUBLISH 處理后立即嘗試沖刷該客戶端排隊(duì)中的入站消息。整個(gè)鏈路保證會(huì)話狀態(tài)只有顯式的 clean session/clean start 或會(huì)話過(guò)期session expirycontext.c才會(huì)被清除重連本身不再觸發(fā)隊(duì)列清空——這正是 0.9.3 該修復(fù)在現(xiàn)代版本中的語(yǔ)義落點(diǎn)。修復(fù)四mosquitto.py 兼容 Python 2.6 以下版本發(fā)布說(shuō)明提到讓mosquitto.py兼容 Python 2.6。這是早期 Mosquitto 隨發(fā)行包攜帶的純 Python MQTT 客戶端腳本后續(xù)演進(jìn)為獨(dú)立的paho-mqtt客戶端庫(kù)倉(cāng)庫(kù)當(dāng)前的 Python 測(cè)試客戶端見(jiàn) test/mosq_test.py。當(dāng)時(shí)的問(wèn)題主要是腳本中使用了僅在 Python 2.6 才提供的語(yǔ)法或標(biāo)準(zhǔn)庫(kù)特性例如json模塊的某些行為、字符串格式化方式導(dǎo)致舊版本 Python 無(wú)法導(dǎo)入。該修復(fù)屬于兼容性收窄在不引入新特性的前提下將腳本的語(yǔ)法/標(biāo)準(zhǔn)庫(kù)使用面收斂到 Python 2.6 之前即可解析的范圍以擴(kuò)大可運(yùn)行環(huán)境。對(duì)于今天的讀者其工程意義在于開(kāi)源項(xiàng)目在支持新 Python 版本的同時(shí)需要明確聲明并測(cè)試其最低支持版本避免隱式依賴某個(gè)較新版本才有的語(yǔ)言特性。修復(fù)五mosquitto.h 的 Windows 頭文件包含mosquitto.h是面向用戶的客戶端 API 頭文件當(dāng)前版本見(jiàn) include/mosquitto.h。0.9.3 之前該頭文件在 Windows 下編譯時(shí)存在包含順序或缺失包含的問(wèn)題導(dǎo)致 Windows 開(kāi)發(fā)者無(wú)法直接 include。修復(fù)后頭文件的包含邏輯在 Windows 與 POSIX 平臺(tái)上均能自洽工作?，F(xiàn)代版本中include/mosquitto.h 將公開(kāi) API 拆分為多個(gè)子頭文件并統(tǒng)一匯總#include mosquitto/mqtt_protocol.h #include mosquitto/libmosquitto.h #include mosquitto/libcommon.h #include mosquitto/broker.h #include mosquitto/broker_control.h #include mosquitto/broker_plugin.h其中l(wèi)ibmosquitto.h及各子頭文件內(nèi)部再按平臺(tái)做差異處理例如 common/winthread_mosq.h 與 lib/dummypthread.h 分別對(duì)應(yīng) Windows 與 POSIX 線程抽象。這種公開(kāi)頭文件自包含、平臺(tái)差異下放到內(nèi)部實(shí)現(xiàn)的架構(gòu)正是對(duì) 0.9.3 時(shí)代Windows 下頭文件包含不完整問(wèn)題的結(jié)構(gòu)性修復(fù)用戶只需 include 一個(gè)mosquitto.h其余平臺(tái)細(xì)節(jié)由庫(kù)內(nèi)部消化。版本演進(jìn)觀察0.9.3 所處的 0.9.x 階段是 Mosquitto 走向 1.0 之前的功能收斂期。對(duì)照當(dāng)前倉(cāng)庫(kù)可以清晰看到這五個(gè)修復(fù)所觸及的領(lǐng)域——保留消息retain.c、監(jiān)聽(tīng)器listeners.c 與 net.c、會(huì)話狀態(tài)context.c、handle_connect.c、客戶端頭文件include/mosquitto.h——在后來(lái)的 MQTT v5 支持、持久化插件化、多監(jiān)聽(tīng)器配置等演進(jìn)中不斷被重構(gòu)和擴(kuò)展但其核心語(yǔ)義QoS 2 保留、地址族容錯(cuò)、持久會(huì)話不清隊(duì)列一直延續(xù)至今。此外倉(cāng)庫(kù)的回歸測(cè)試體系也覆蓋了這些語(yǔ)義的現(xiàn)代形態(tài)例如保留消息相關(guān)的測(cè)試見(jiàn) test/broker 目錄下的04-retain-*.py系列如04-retain-qos0.py、04-retain-qos1-qos0.py、04-retain-upgrade-outgoing-qos.py會(huì)話與重連相關(guān)的測(cè)試見(jiàn)05-clean-session-qos1.py、05-session-expiry-v5.py等。這些測(cè)試可以視為 0.9.3 修復(fù)目標(biāo)的自動(dòng)化回歸保障?？偨Y(jié)Mosquitto 0.9.3 雖然只是一次缺陷修復(fù)發(fā)布但其五個(gè)修復(fù)點(diǎn)恰好對(duì)應(yīng)了 MQTT broker 最容易被忽視的語(yǔ)義細(xì)節(jié)修復(fù)項(xiàng)核心語(yǔ)義現(xiàn)代源碼參考QoS 2 保留狀態(tài)保留位在完整握手后不被丟失handle_publish.c、retain.c地址族回退單一地址族失敗不阻斷監(jiān)聽(tīng)器net.c非 clean session 不清隊(duì)列持久會(huì)話重連保留積壓消息handle_connect.cPython 2.6 兼容聲明并收斂最低運(yùn)行版本test/mosq_test.pyWindows 頭文件包含公開(kāi)頭文件跨平臺(tái)自包含include/mosquitto.h對(duì)于需要深挖行為的讀者建議結(jié)合 retain.c 的保留樹(shù)遍歷邏輯、net.c 的net__socket_listen_tcp()回退循環(huán)以及 handle_connect.c 的會(huì)話恢復(fù)分支進(jìn)行代碼級(jí)驗(yàn)證這些實(shí)現(xiàn)正是 0.9.3 修復(fù)思想在十余年演進(jìn)后的直接繼承者。贊分享物聯(lián)網(wǎng)消息隊(duì)列后端網(wǎng)絡(luò)/通信【免費(fèi)下載鏈接】mosquittoEclipse Mosquitto - An open source MQTT broker項(xiàng)目地址https://gitcode.com/gh_mirrors/mo/mosquitto點(diǎn)擊查看免費(fèi)下載相關(guān)推薦Eclipse Mosquitto 0.10.2 版本發(fā)布解讀四項(xiàng)關(guān)鍵 Bug 修復(fù)與源碼級(jí)解析Eclipse Mosquitto 0.10.2 版本發(fā)布解讀四項(xiàng)關(guān)鍵 Bug 修復(fù)與源碼級(jí)解析 Mosquitto 0.10.2 是 Eclipse Mos后端消息隊(duì)列消息路由Eclipse Mosquitto 2.0.20 版本解析關(guān)鍵 Bug 修復(fù)的技術(shù)內(nèi)幕與升級(jí)指南Eclipse Mosquitto 2.0.20 版本解析關(guān)鍵 Bug 修復(fù)的技術(shù)內(nèi)幕與升級(jí)指南 Mosquitto 2.0.20 于 2024 年 10 月后端消息隊(duì)列消息路由NumPy 1.15.2 發(fā)布說(shuō)明深度解讀四個(gè)關(guān)鍵 Bug 修復(fù)的技術(shù)內(nèi)幕NumPy 1.15.2 發(fā)布說(shuō)明深度解讀四個(gè)關(guān)鍵 Bug 修復(fù)的技術(shù)內(nèi)幕 NumPy 1.15.2 是繼 1.15.1 之后的一個(gè)純 bugfix 維護(hù)版本科學(xué)計(jì)算數(shù)據(jù)分析上一篇android-sunflower中的多模塊依賴分析項(xiàng)目報(bào)告生成下一篇vim-airline會(huì)話自動(dòng)備份頻率設(shè)置詳細(xì)指南創(chuàng)作聲明：本文部分內(nèi)容由AI輔助生成（AIGC），僅供參考