消息集群平滑遷移的方法及系統(tǒng)

基本信息

申請(qǐng)?zhí)?/td> CN202110628532.X 申請(qǐng)日 -
公開(公告)號(hào) CN113268466A 公開(公告)日 2021-08-17
申請(qǐng)公布號(hào) CN113268466A 申請(qǐng)公布日 2021-08-17
分類號(hào) G06F16/21(2019.01)I 分類 計(jì)算;推算;計(jì)數(shù);
發(fā)明人 趙孟彬 申請(qǐng)(專利權(quán))人 上海數(shù)禾信息科技有限公司
代理機(jī)構(gòu) 北京市萬慧達(dá)律師事務(wù)所 代理人 劉鋒;邱忠貺
地址 201206上海市嘉定區(qū)自由貿(mào)易試驗(yàn)區(qū)金科路2889弄1號(hào)2層201室
法律狀態(tài) -

摘要

摘要 本發(fā)明公開一種消息集群平滑遷移的方法及系統(tǒng),涉及互聯(lián)網(wǎng)技術(shù)領(lǐng)域,解決了集群遷移過程中客戶端連接不能平滑切換的問題。該方法包括:獲取消費(fèi)者應(yīng)用和生產(chǎn)者應(yīng)用遷移前所連接的原始集群以及遷移后所連接的目標(biāo)集群;由消費(fèi)者應(yīng)用根據(jù)目標(biāo)集群的配置項(xiàng)建立與原始消費(fèi)者線程一一對(duì)應(yīng)的目標(biāo)消費(fèi)者線程并與目標(biāo)集群連接,且生產(chǎn)者應(yīng)用從向原始集群生產(chǎn)消息切換為向目標(biāo)集群生產(chǎn)消息;當(dāng)消費(fèi)者應(yīng)用監(jiān)測(cè)到原始集群無消息堆積且無新消息進(jìn)入時(shí)切換至目標(biāo)集群消費(fèi)消息。該系統(tǒng)運(yùn)行有上述方案所提的方法。