[發(fā)明專利]一種同步方法、同步系統(tǒng)、計(jì)算機(jī)設(shè)備和存儲(chǔ)介質(zhì)

在審

• 申請(qǐng)?zhí)枺?/td>: 202210474327.7
• 申請(qǐng)日: 2022-04-29
• 公開（公告）號(hào): CN114676199A
• 公開（公告）日: 2022-06-28
• 發(fā)明（設(shè)計(jì)）人: 曹仁杰
• 申請(qǐng)（專利權(quán)）人: 北京中啟智源數(shù)字信息技術(shù)有限責(zé)任公司
• 主分類號(hào): G06F16/27
• 分類號(hào): G06F16/27;G06F16/23
• 代理公司: 北京汲智翼成知識(shí)產(chǎn)權(quán)代理事務(wù)所(普通合伙) 11381
• 代理人: 陳曦;董燁飛

1.一種應(yīng)用于中間服務(wù)器的同步方法，其特征在于包括如下步驟：

S20：通過(guò)中間服務(wù)器的管道實(shí)時(shí)獲取關(guān)系型數(shù)據(jù)庫(kù)的更新信息，所述更新信息為所述管道實(shí)時(shí)向所述關(guān)系型數(shù)據(jù)庫(kù)發(fā)送的第一查詢請(qǐng)求獲得的，所述更新信息包括所述關(guān)系型數(shù)據(jù)庫(kù)的更新數(shù)據(jù)；

S40：解析所述更新信息并將所述更新數(shù)據(jù)存儲(chǔ)到消息隊(duì)列；

S60：根據(jù)所述消息隊(duì)列將所述更新數(shù)據(jù)同步到列式數(shù)據(jù)庫(kù)。

2.如權(quán)利要求1所述的同步方法，其特征在于還包括：

S10：獲取所述關(guān)系型數(shù)據(jù)庫(kù)的歷史數(shù)據(jù)并存儲(chǔ)到所述消息隊(duì)列，根據(jù)所述消息隊(duì)列將所述歷史數(shù)據(jù)同步到所述列式數(shù)據(jù)庫(kù)，所述歷史數(shù)據(jù)為所述中間服務(wù)器的控制器向所述關(guān)系型數(shù)據(jù)庫(kù)發(fā)送的第二查詢請(qǐng)求獲得的。

3.如權(quán)利要求1或2所述的同步方法，其特征在于還包括：

S1：初始化守護(hù)計(jì)數(shù)器；

S2：利用預(yù)設(shè)置的第一守護(hù)進(jìn)程實(shí)時(shí)監(jiān)控所述管道與所述關(guān)系型數(shù)據(jù)庫(kù)的第一連接關(guān)系、以及所述管道與所述列式數(shù)據(jù)庫(kù)的第二連接關(guān)系，所述第一連接關(guān)系為通過(guò)向所述關(guān)系型數(shù)據(jù)庫(kù)發(fā)送第一連接請(qǐng)求以獲取第一連接信息獲得的，所述第二連接關(guān)系為通過(guò)向所述列式數(shù)據(jù)庫(kù)發(fā)送第二連接請(qǐng)求以獲取第二連接信息獲得的；

S3：判斷所述第一連接關(guān)系和/或所述第二連接關(guān)系是否存在中斷，若存在中斷則判斷所述守護(hù)計(jì)數(shù)器是否大于守護(hù)閾值，若大于則跳轉(zhuǎn)至S4，若小于則響應(yīng)于所述第一連接和/或第二連接的中斷重新建立連接，所述守護(hù)計(jì)數(shù)器計(jì)數(shù)，并跳轉(zhuǎn)到S2；

S4：利用預(yù)設(shè)置的第二守護(hù)進(jìn)程實(shí)時(shí)監(jiān)控所述第一守護(hù)進(jìn)程，響應(yīng)于所述第一守護(hù)進(jìn)程的異常重啟所述第一守護(hù)進(jìn)程，并跳轉(zhuǎn)至S1。

4.一種應(yīng)用于關(guān)系型數(shù)據(jù)庫(kù)的同步方法，其特征在于包括如下步驟：

接收中間服務(wù)器的管道實(shí)時(shí)發(fā)送的第一查詢請(qǐng)求發(fā)送更新信息至所述管道，所述更新信息包括更新數(shù)據(jù)，以使得所述管道解析所述更新信息并將所述更新數(shù)據(jù)存儲(chǔ)到消息隊(duì)列，并根據(jù)所述消息隊(duì)列將所述更新數(shù)據(jù)同步到列式數(shù)據(jù)庫(kù)。

5.如權(quán)利要求4所述的同步方法，其特征在于還包括：

接收所述中間服務(wù)器發(fā)送的第二查詢請(qǐng)求發(fā)送歷史數(shù)據(jù)至所述控制器，以使得所述控制器將所述歷史數(shù)據(jù)存儲(chǔ)到消息隊(duì)列，并根據(jù)所述消息隊(duì)列將所述歷史數(shù)據(jù)同步到列式數(shù)據(jù)庫(kù)。

6.一種應(yīng)用于列式數(shù)據(jù)庫(kù)的同步方法，其特征在于包括如下步驟：

實(shí)時(shí)獲取更新數(shù)據(jù)并存儲(chǔ)，所述更新數(shù)據(jù)為中間服務(wù)器的管道實(shí)時(shí)向關(guān)系型數(shù)據(jù)庫(kù)發(fā)送第一查詢請(qǐng)求獲取的更新信息、經(jīng)所述管道從所述更新信息中解析出的并存儲(chǔ)在所述消息隊(duì)列中的。

7.如權(quán)利要求6所述的同步方法，其特征在于還包括：

獲取歷史數(shù)據(jù)并存儲(chǔ)，所述歷史數(shù)據(jù)為所述中間服務(wù)器的控制器實(shí)時(shí)向關(guān)系型數(shù)據(jù)庫(kù)發(fā)送第二查詢請(qǐng)求獲取的、并存儲(chǔ)在所述消息隊(duì)列中的。

8.一種同步系統(tǒng)，包括關(guān)系型數(shù)據(jù)庫(kù)、中間服務(wù)器和列式數(shù)據(jù)庫(kù)，其中，所述中間服務(wù)器包括控制器、管道和消息隊(duì)列，其特征在于所述控制器被配置為：

S20：通過(guò)管道實(shí)時(shí)獲取關(guān)系型數(shù)據(jù)庫(kù)的更新信息，所述更新信息為所述管道實(shí)時(shí)向所述關(guān)系型數(shù)據(jù)庫(kù)發(fā)送的第一查詢請(qǐng)求獲得的，所述更新信息包括所述關(guān)系型數(shù)據(jù)庫(kù)的更新數(shù)據(jù)；

S40：解析所述更新信息并將所述更新數(shù)據(jù)存儲(chǔ)到消息隊(duì)列；

S60：根據(jù)所述消息隊(duì)列將所述更新數(shù)據(jù)同步到列式數(shù)據(jù)庫(kù)。

9.一種計(jì)算機(jī)可讀存儲(chǔ)介質(zhì)，其上存儲(chǔ)有計(jì)算機(jī)程序，其特征在于：

該程序被處理器執(zhí)行時(shí)實(shí)現(xiàn)權(quán)利要求1～3中任意一項(xiàng)所述的方法；

或者

該程序被處理器執(zhí)行時(shí)實(shí)現(xiàn)權(quán)利要求4～5中任意一項(xiàng)所述的方法；

或者

該程序被處理器執(zhí)行時(shí)實(shí)現(xiàn)權(quán)利要求6～7中任意一項(xiàng)所述的方法。

10.一種計(jì)算機(jī)設(shè)備，包括存儲(chǔ)器、處理器及存儲(chǔ)在存儲(chǔ)器上并可在處理器上運(yùn)行的計(jì)算機(jī)程序，其特征在于：

所述處理器執(zhí)行所述程序時(shí)實(shí)現(xiàn)權(quán)利要求1～3中任意一項(xiàng)所述的方法；

或者

所述處理器執(zhí)行所述程序時(shí)實(shí)現(xiàn)權(quán)利要求4～5中任意一項(xiàng)所述的方法；

或者

所述處理器執(zhí)行所述程序時(shí)實(shí)現(xiàn)權(quán)利要求6～7中任意一項(xiàng)所述的方法。