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

基本信息

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

摘要

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