[發(fā)明專利]機(jī)房容災(zāi)處理方法、終端及存儲介質(zhì)

有效

• 申請?zhí)枺?/td>: 202011058742.1
• 申請日: 2020-09-30
• 公開（公告）號: CN112291082B
• 公開（公告）日: 2023-08-29
• 發(fā)明（設(shè)計）人: 石鵬;宋磊
• 申請（專利權(quán)）人: 北京大米科技有限公司
• 主分類號: H04L41/0663
• 分類號: H04L41/0663;H04L41/0668
• 代理公司: 北京恒博知識產(chǎn)權(quán)代理有限公司 11528
• 代理人: 張曉芳

本申請公開了一種機(jī)房容災(zāi)處理方法、終端及存儲介質(zhì)。該機(jī)房容災(zāi)處理方法包括當(dāng)檢測到第一機(jī)房故障時，確定所述第一機(jī)房中發(fā)生故障的終端為目標(biāo)終端；所述目標(biāo)終端用于處理所述第一機(jī)房的第一集群中的消息；向第二機(jī)房的所述目標(biāo)終端發(fā)送容災(zāi)指令；所述容災(zāi)指令用于指示所述第二機(jī)房的所述目標(biāo)終端處理所述第一集群的所述消息。本方案保證了第一機(jī)房發(fā)生故障時對業(yè)務(wù)使用kafka服務(wù)無影響，避免了容災(zāi)時整個機(jī)房切換而導(dǎo)致故障機(jī)房積壓的消息不能夠及時被消費(fèi)的情況發(fā)生。

技術(shù)領(lǐng)域

本申請涉及機(jī)房容災(zāi)處理領(lǐng)域，具體而言，涉及一種機(jī)房容災(zāi)處理方法、終端及存儲介質(zhì)。

背景技術(shù)

kafka是常用的消息隊列中間件，若業(yè)務(wù)強(qiáng)依賴于kafka，需要保證服務(wù)商故障時，使用kafka的業(yè)務(wù)不受影響。當(dāng)前現(xiàn)有的解決方案為在兩個機(jī)房分別部署兩套kafka集群，當(dāng)一個機(jī)房故障時，把故障機(jī)房的kafka流量切到另一個機(jī)房的kafka上，業(yè)務(wù)消費(fèi)kafka的用戶終端同樣消費(fèi)另一機(jī)房的kafka，這種方案的缺陷在于如果故障機(jī)房的kafka的消息有積壓，那么當(dāng)切換到另一機(jī)房時，積壓的消息不能夠及時被消費(fèi)。

發(fā)明內(nèi)容

為了解決上述問題，本申請實(shí)施例提供了一種機(jī)房容災(zāi)處理方法、終端及存儲介質(zhì)。

第一方面，本申請實(shí)施例提供了一種機(jī)房容災(zāi)處理方法，所述方法包括：

當(dāng)檢測到第一機(jī)房故障時，確定所述第一機(jī)房中發(fā)生故障的終端為目標(biāo)終端；所述目標(biāo)終端用于處理所述第一機(jī)房的第一集群中的消息；

向第二機(jī)房的所述目標(biāo)終端發(fā)送容災(zāi)指令；所述容災(zāi)指令用于指示所述第二機(jī)房的所述目標(biāo)終端處理所述第一集群的所述消息。

可選地，所述目標(biāo)終端為服務(wù)器；

所述向第二機(jī)房的所述目標(biāo)終端發(fā)送容災(zāi)指令，包括：

向所述第二機(jī)房的所述服務(wù)器發(fā)送第一指令；所述第一指令用于指示所述第二機(jī)房的所述服務(wù)器開啟并配置所述第一機(jī)房的所述服務(wù)器的第一配置信息；所述第一配置信息為所述第二機(jī)房的所述服務(wù)器向所述第一集群寫入消息所需配置信息；

在所述第二機(jī)房的所述服務(wù)器開啟后，向所述第二機(jī)房的所述服務(wù)器發(fā)送第二指令；所述第二指令用于指示所述第二機(jī)房的所述服務(wù)器向所述第一集群寫入消息。

可選地，所述目標(biāo)終端為用戶終端；

所述向第二機(jī)房的所述目標(biāo)終端發(fā)送容災(zāi)指令，包括：

向所述第二機(jī)房的所述用戶終端發(fā)送第三指令；所述第三指令用于指示所述第二機(jī)房的所述用戶終端開啟并配置所述第一機(jī)房的所述用戶終端的第二配置信息；所述第二配置信息為所述第二機(jī)房的所述用戶終端向所述第一集群讀取消息所需配置信息；

在所述第二機(jī)房的所述用戶終端開啟后，向所述第二機(jī)房的所述用戶終端發(fā)送第四指令；所述第四指令用于指示所述第二機(jī)房的所述用戶終端向所述第一集群讀取消息。

可選地，所述在所述第二機(jī)房的所述用戶終端開啟后，向所述第二機(jī)房的所述用戶終端發(fā)送第四指令之后，還包括：

檢測所述第一機(jī)房的服務(wù)器是否故障；

當(dāng)所述第一機(jī)房的服務(wù)器故障時，向所述第二機(jī)房的所述服務(wù)器發(fā)送第五指令；所述第五指令用于指示所述第二機(jī)房的所述服務(wù)器開啟并向所述第二機(jī)房的第二集群寫入消息；

在所述第二機(jī)房的所述服務(wù)器開啟后，向所述第二機(jī)房的所述用戶終端發(fā)送第六指令；所述第六指令用于指示所述第二機(jī)房的所述用戶終端同時向所述第一集群與第二集群讀取消息。

可選地，所述第一集群包括至少兩個分區(qū)，每個分區(qū)分別位于不同的地理位置。

可選地，所述當(dāng)檢測到第一機(jī)房故障時，確定所述第一機(jī)房中發(fā)生故障的終端為目標(biāo)終端之前，還包括：