基于MQTT服務集群的會話處理方法及系統(tǒng)

基本信息

申請?zhí)?/td> CN202110315876.5 申請日 -
公開（公告）號 CN113242272A 公開（公告）日 2021-08-10
申請公布號 CN113242272A 申請公布日 2021-08-10
分類號 H04L29/08（2006.01）I;G06F9/54（2006.01）I 分類 電通信技術(shù);
發(fā)明人 王臻;劉欣;魏勇;戴巖;梁家興 申請（專利權(quán)）人 中國雄安集團數(shù)字城市科技有限公司
代理機構(gòu) 北京金咨知識產(chǎn)權(quán)代理有限公司 代理人 宋教花
地址 071700河北省保定市中國（河北）自由貿(mào)易試驗區(qū)雄安片區(qū)容城縣雄安市民服務中心雄安集團辦公樓226
法律狀態(tài) -

摘要

摘要 本發(fā)明提供一種基于MQTT服務集群的會話處理方法及系統(tǒng)，該方法包括：MQTT網(wǎng)關(guān)接收MQTT客戶端的訂閱請求，訂閱請求攜帶客戶端ID信息以及是否清空會話的指示；MQTT網(wǎng)關(guān)向調(diào)度器發(fā)送調(diào)用請求，以由調(diào)度器查找訂閱請求中攜帶的清空會話的指示；在未查找到清空會話的指示的情況下，調(diào)度器查找緩存區(qū)中的反映訂閱消息中攜帶的客戶端ID與第一服務端的映射關(guān)系的信息；在查找到反映訂閱消息中攜帶的客戶端ID與第一服務端的映射關(guān)系的信息的情況下，獲取第一服務端的地址信息，并將獲取到的地址信息發(fā)送至MQTT網(wǎng)關(guān)；在查找到清空會話的指示的情況下，清空緩存區(qū)中的與訂閱消息中攜帶的客戶端ID具有映射關(guān)系的緩存信息，并基于負載均衡算法為客戶端ID分配第二服務端。