[發(fā)明專利]基于HBase數(shù)據(jù)庫的跨機(jī)房集群的容災(zāi)方法、裝置和系統(tǒng)

在審

• 申請(qǐng)?zhí)枺?/td>: 201911271462.6
• 申請(qǐng)日: 2019-12-12
• 公開（公告）號(hào): CN111190766A
• 公開（公告）日: 2020-05-22
• 發(fā)明（設(shè)計(jì)）人: 黃建庭;宋榮鑫;肖衛(wèi)渭;曹德高
• 申請(qǐng)（專利權(quán)）人: 北京淇瑀信息科技有限公司
• 主分類號(hào): G06F11/14
• 分類號(hào): G06F11/14
• 代理公司: 北京清誠知識(shí)產(chǎn)權(quán)代理有限公司 11691
• 代理人: 李博

1.一種基于HBase數(shù)據(jù)庫的跨機(jī)房集群的容災(zāi)方法，其特征在于，方法包括：

前端將消息寫入主集群服務(wù)器；

前端將消息發(fā)送到消息中間件集群，消費(fèi)功能模塊讀取消息中間件集群中的消息，消費(fèi)功能模塊將消息寫入從集群服務(wù)器；

前端從所述主集群服務(wù)器中讀取狀態(tài)，如果狀態(tài)讀取失敗，則前端將消息寫入從集群服務(wù)器，前端將消息發(fā)送到消息中間件集群，消費(fèi)功能模塊讀取消息中間件集群中的消息，消費(fèi)功能模塊將消息寫入主集群服務(wù)器。

2.如權(quán)利要求1所述的基于HBase數(shù)據(jù)庫的跨機(jī)房集群的容災(zāi)方法，其特征在于，同時(shí)前端將消息發(fā)送到消息中間件集群還包括：判斷所述消息是否成功發(fā)送到消息中間件集群，如果發(fā)送失敗則將消息發(fā)送至中轉(zhuǎn)路由，等待一定時(shí)間后中轉(zhuǎn)路由將所述消息補(bǔ)發(fā)給所述消息中間件集群。

3.如權(quán)利要求1-2任一項(xiàng)所述的基于HBase數(shù)據(jù)庫的跨機(jī)房集群的容災(zāi)方法，其特征在于，還包括：

設(shè)置補(bǔ)發(fā)次數(shù)閾值；

如果所述中轉(zhuǎn)路由補(bǔ)發(fā)消息給所述消息中間件集群成功，則所述補(bǔ)發(fā)次數(shù)清零；

如果所述中轉(zhuǎn)路由補(bǔ)發(fā)消息給所述消息中間件集群失敗則補(bǔ)發(fā)次數(shù)加1，當(dāng)所述補(bǔ)發(fā)次數(shù)超過閾值時(shí)，所述前端停止向所述消息中間件集群發(fā)送消息，所述主集群服務(wù)器定期同步數(shù)據(jù)到從集群服務(wù)器，覆蓋從集群服務(wù)器原有數(shù)據(jù)。

4.如權(quán)利要求1-3任一項(xiàng)所述的基于HBase數(shù)據(jù)庫的跨機(jī)房集群的容災(zāi)方法，其特征在于，方法還包括：主集群服務(wù)器定期與從集群服務(wù)器進(jìn)行數(shù)據(jù)比對(duì)和校驗(yàn)。

5.如權(quán)利要求1-4任一項(xiàng)所述的基于HBase數(shù)據(jù)庫的跨機(jī)房集群的容災(zāi)方法，其特征在于，所述消息中間件集群包括kafka、rabbitmq和Rocketmq。

6.如權(quán)利要求1-5任一項(xiàng)所述的基于HBase數(shù)據(jù)庫的跨機(jī)房集群的容災(zāi)方法，其特征在于，前端將消息發(fā)送到消息中間件集群包括，采用異步的方式將消息透傳到消息中間件集群。

7.如權(quán)利要求1-6任一項(xiàng)所述的基于HBase數(shù)據(jù)庫的跨機(jī)房集群的容災(zāi)方法，其特征在于，所述中轉(zhuǎn)路由為Mongos路由。

8.一種基于HBase數(shù)據(jù)庫的跨機(jī)房集群的容災(zāi)裝置，其特征在于，裝置包括：

主集群服務(wù)器寫入模塊，用于使前端將消息寫入主集群服務(wù)器；

從集群服務(wù)器寫入模塊，用于使前端將消息發(fā)送到消息中間件集群，消費(fèi)功能模塊讀取消息中間件集群中的消息，消費(fèi)功能模塊將消息寫入從集群服務(wù)器；

主從切換模塊，前端從所述主集群服務(wù)器中讀取狀態(tài)，如果狀態(tài)讀取失敗，則前端將消息寫入從集群服務(wù)器，前端將消息發(fā)送到消息中間件集群，消費(fèi)功能模塊讀取消息中間件集群中的消息，消費(fèi)功能模塊將消息寫入主集群服務(wù)器。

9.一種基于HBase數(shù)據(jù)庫的跨機(jī)房集群的容災(zāi)系統(tǒng)，其特征在于，包括：

存儲(chǔ)單元，用于存儲(chǔ)計(jì)算機(jī)可執(zhí)行程序；

處理單元，用于讀取所述存儲(chǔ)單元中的計(jì)算機(jī)可執(zhí)行程序，以執(zhí)行權(quán)利要求1至7中任一項(xiàng)所述的基于HBase數(shù)據(jù)庫的跨機(jī)房集群的容災(zāi)方法。

10.一種計(jì)算機(jī)可讀介質(zhì)，用于存儲(chǔ)計(jì)算機(jī)可讀程序，其特征在于，所述計(jì)算機(jī)可讀程序用于執(zhí)行權(quán)利要求1至7中任一項(xiàng)所述的基于HBase數(shù)據(jù)庫的跨機(jī)房集群的容災(zāi)方法。