[發(fā)明專利]一種信息同步方法，裝置及系統(tǒng)

有效

• 申請(qǐng)?zhí)枺?/td>: 201810532858.0
• 申請(qǐng)日: 2018-05-29
• 公開(kāi)（公告）號(hào): CN110609865B
• 公開(kāi)（公告）日: 2022-04-15
• 發(fā)明（設(shè)計(jì)）人: 李軍浩;趙帥;王亮;鞏仔明;邱慧
• 申請(qǐng)（專利權(quán)）人: 優(yōu)信拍（北京）信息科技有限公司
• 主分類號(hào): G06F16/27
• 分類號(hào): G06F16/27;G06F16/23;G06F16/22;G06F16/2457
• 代理公司: 北京弘權(quán)知識(shí)產(chǎn)權(quán)代理有限公司 11363
• 代理人: 逯長(zhǎng)明;許偉群

1.一種信息同步方法，其特征在于，所述方法包括：

接收?qǐng)?zhí)行消息，確定所述執(zhí)行消息對(duì)應(yīng)的索引的重建標(biāo)識(shí)位；

如果所述重建標(biāo)識(shí)位為正在重建，繼續(xù)創(chuàng)建索引，將更新消息緩存于Redis隊(duì)列；

完成所述索引創(chuàng)建，遍歷Redis隊(duì)列，調(diào)取所述更新消息，實(shí)現(xiàn)Elasticsearch搜索引擎中的數(shù)據(jù)與查詢數(shù)據(jù)庫(kù)中數(shù)據(jù)的同步；

接收?qǐng)?zhí)行消息，所述執(zhí)行消息包括：更新消息以及重建消息；

判斷所述執(zhí)行消息的類型；

如果所述執(zhí)行消息為重建消息，創(chuàng)建索引；

如果所述執(zhí)行消息為更新消息，確定所述執(zhí)行消息對(duì)應(yīng)的索引的重建標(biāo)識(shí)位；

所述實(shí)現(xiàn)Elasticsearch搜索引擎中的數(shù)據(jù)與查詢數(shù)據(jù)庫(kù)中數(shù)據(jù)的同步的步驟包括：

確定更新項(xiàng)，所述更新項(xiàng)包括：更新列名，以及，更新數(shù)據(jù)，更新列名為更新數(shù)據(jù)對(duì)應(yīng)的列名；

根據(jù)所述更新列名，以及，更新數(shù)據(jù)，確定目標(biāo)索引；

基于所述目標(biāo)索引，遍歷查詢數(shù)據(jù)庫(kù)，搜索更新文檔ID；

發(fā)送所述更新文檔ID，至Java端，Java端基于更新文檔ID，搜索出更新數(shù)據(jù)，用更新數(shù)據(jù)更新Elasticsearch搜索引擎對(duì)應(yīng)的索引以及數(shù)據(jù)。

2.根據(jù)權(quán)利要求1所述方法，其特征在于，所述完成索引創(chuàng)建，遍歷Redis隊(duì)列，調(diào)取所述更新消息的步驟包括：

完成索引創(chuàng)建；

遍歷Redis，調(diào)取所述更新消息，切換所述索引的別名；

修改索引重建標(biāo)識(shí)位；

再次拉取所述Redis隊(duì)列中堆積的更新消息。

3.根據(jù)權(quán)利要求1所述的方法，其特征在于，所述基于目標(biāo)索引，遍歷查詢數(shù)據(jù)庫(kù)，

搜索更新文檔ID的步驟包括：

根據(jù)所述查詢數(shù)據(jù)庫(kù)中數(shù)據(jù)業(yè)務(wù)邏輯，確定所述目標(biāo)索引的子目標(biāo)索引；

根據(jù)目標(biāo)索引，確定目標(biāo)索引，根據(jù)子目標(biāo)索引確定子目標(biāo)節(jié)點(diǎn)文檔；

根據(jù)所述目標(biāo)節(jié)點(diǎn)文檔，以及，所述子目標(biāo)節(jié)點(diǎn)文檔，生成更新文檔ID。

4.根據(jù)權(quán)利要求1所述的方法，其特征在于，所述基于目標(biāo)索引，遍歷查詢數(shù)據(jù)庫(kù)，

搜索更新文檔ID的步驟包括：

根據(jù)所述目標(biāo)索引，確定局部文檔ID；

確定包含局部文檔ID的文檔ID為更新文檔ID。

5.根據(jù)權(quán)利要求1所述的方法，其特征在于，所述確定更新項(xiàng)的步驟包括：

獲取監(jiān)測(cè)數(shù)據(jù)，所述監(jiān)測(cè)數(shù)據(jù)包括：歷史數(shù)據(jù)以及實(shí)時(shí)數(shù)據(jù)；

將所述歷史數(shù)據(jù)與所述實(shí)時(shí)數(shù)據(jù)輸入gorouine進(jìn)行比對(duì)，確定更新項(xiàng)。

6.根據(jù)權(quán)利要求5所述的方法，其特征在于，所述將所述歷史數(shù)據(jù)與所述實(shí)時(shí)數(shù)據(jù)輸入gorouine進(jìn)行比對(duì)，確定更新項(xiàng)的步驟包括：

將所述歷史數(shù)據(jù)與所述實(shí)時(shí)數(shù)據(jù)輸入gorouine進(jìn)行比對(duì)，根據(jù)比對(duì)結(jié)果，確定待更新項(xiàng)；

判斷所述待更新項(xiàng)是否觸發(fā)Elasticsearch的更新操作；

如果觸發(fā)，確定所述待更新項(xiàng)為更新項(xiàng)；

如果不觸發(fā)，刪除待更新項(xiàng)。