[發(fā)明專利]微服務(wù)的數(shù)據(jù)同步方法、裝置及計(jì)算機(jī)可讀存儲(chǔ)介質(zhì)

在審

• 申請(qǐng)?zhí)枺?/td>: 202010025271.8
• 申請(qǐng)日: 2020-01-09
• 公開(kāi)（公告）號(hào): CN111209120A
• 公開(kāi)（公告）日: 2020-05-29
• 發(fā)明（設(shè)計(jì)）人: 羅鳳寧
• 申請(qǐng)（專利權(quán)）人: 平安科技（深圳）有限公司
• 主分類號(hào): G06F9/52
• 分類號(hào): G06F9/52;G06F9/54;G06F9/50
• 代理公司: 深圳市沃德知識(shí)產(chǎn)權(quán)代理事務(wù)所(普通合伙) 44347
• 代理人: 高杰;于志光

本發(fā)明涉及一種大數(shù)據(jù)技術(shù)，揭露了一種微服務(wù)的數(shù)據(jù)同步方法，包括：基于預(yù)先構(gòu)建的一致性哈希算法對(duì)原始微服務(wù)的負(fù)載均衡場(chǎng)景進(jìn)行動(dòng)態(tài)增刪，得到標(biāo)準(zhǔn)負(fù)載均衡場(chǎng)景，其中，所述標(biāo)準(zhǔn)負(fù)載均衡場(chǎng)景包括微服務(wù)的實(shí)例負(fù)載監(jiān)控和微服務(wù)的實(shí)例狀態(tài)變化檢測(cè)；通過(guò)預(yù)先創(chuàng)建的單元服務(wù)器組向所述標(biāo)準(zhǔn)負(fù)載均衡場(chǎng)景進(jìn)行實(shí)時(shí)數(shù)據(jù)讀取，得到實(shí)時(shí)數(shù)據(jù)集；將所述實(shí)時(shí)數(shù)據(jù)集輸入至所述預(yù)先創(chuàng)建的單元服務(wù)器組的單元節(jié)點(diǎn)中，通過(guò)消息中間件實(shí)現(xiàn)所述單元節(jié)點(diǎn)之間的實(shí)時(shí)數(shù)據(jù)同步。本發(fā)明還提出一種微服務(wù)的數(shù)據(jù)同步裝置以及一種計(jì)算機(jī)可讀存儲(chǔ)介質(zhì)。本發(fā)明實(shí)現(xiàn)了微服務(wù)的數(shù)據(jù)同步。

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

本發(fā)明涉及大數(shù)據(jù)技術(shù)領(lǐng)域，尤其涉及一種微服務(wù)的數(shù)據(jù)同步方法、裝置及計(jì)算機(jī)可讀存儲(chǔ)介質(zhì)。

背景技術(shù)

微服務(wù)架構(gòu)是一項(xiàng)在云中部署應(yīng)用和服務(wù)的新技術(shù)。隨著微服務(wù)架構(gòu)的逐漸應(yīng)用，一個(gè)上游系統(tǒng)會(huì)對(duì)接N個(gè)下游系統(tǒng)，由于每一個(gè)下游系統(tǒng)對(duì)接口響應(yīng)的標(biāo)準(zhǔn)不一樣、業(yè)務(wù)特殊性不能配合優(yōu)化以及各個(gè)系統(tǒng)之間的實(shí)時(shí)數(shù)據(jù)同步等問(wèn)題導(dǎo)致上游系統(tǒng)的優(yōu)化受限制，從而導(dǎo)致系統(tǒng)之間的耦合度過(guò)高，上游系統(tǒng)服務(wù)器壓力過(guò)大，上游系統(tǒng)接口響應(yīng)過(guò)慢。

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

本發(fā)明提供一種微服務(wù)的數(shù)據(jù)同步方法、裝置及計(jì)算機(jī)可讀存儲(chǔ)介質(zhì)，其主要目的在于當(dāng)用戶在進(jìn)行微服務(wù)的數(shù)據(jù)同步時(shí)，給用戶呈現(xiàn)出精準(zhǔn)的數(shù)據(jù)同步結(jié)果。

為實(shí)現(xiàn)上述目的，本發(fā)明提供的一種微服務(wù)的數(shù)據(jù)同步方法，包括：

基于預(yù)先構(gòu)建的一致性哈希算法對(duì)原始微服務(wù)的負(fù)載均衡場(chǎng)景進(jìn)行動(dòng)態(tài)增刪，得到標(biāo)準(zhǔn)負(fù)載均衡場(chǎng)景，其中，所述標(biāo)準(zhǔn)負(fù)載均衡場(chǎng)景包括微服務(wù)的實(shí)例負(fù)載監(jiān)控和微服務(wù)的實(shí)例狀態(tài)變化檢測(cè)；

通過(guò)預(yù)先創(chuàng)建的單元服務(wù)器組向所述標(biāo)準(zhǔn)負(fù)載均衡場(chǎng)景進(jìn)行實(shí)時(shí)數(shù)據(jù)讀取，得到實(shí)時(shí)數(shù)據(jù)集；

將所述實(shí)時(shí)數(shù)據(jù)集輸入至所述預(yù)先創(chuàng)建的單元服務(wù)器組的單元節(jié)點(diǎn)中，通過(guò)消息中間件實(shí)現(xiàn)所述單元節(jié)點(diǎn)之間的實(shí)時(shí)數(shù)據(jù)同步。

可選地，所述預(yù)先構(gòu)建的一致性哈希算法包括：

預(yù)設(shè)虛擬節(jié)點(diǎn)的數(shù)目，以實(shí)現(xiàn)存儲(chǔ)空間分配的均衡性；

采用TreeMap數(shù)據(jù)結(jié)構(gòu)對(duì)所述虛擬節(jié)點(diǎn)的數(shù)據(jù)存儲(chǔ)結(jié)構(gòu)進(jìn)行構(gòu)建，所述TreeMap數(shù)據(jù)結(jié)構(gòu)通過(guò)紅黑樹(shù)實(shí)現(xiàn)所述節(jié)點(diǎn)的存儲(chǔ)；

選擇所述虛擬節(jié)點(diǎn)的散列函數(shù)，通過(guò)所述散列函數(shù)實(shí)現(xiàn)所述虛擬節(jié)點(diǎn)的哈希檢索操作。

可選地，所述原始微服務(wù)的負(fù)載均衡場(chǎng)景包括將任務(wù)分?jǐn)偟蕉鄠€(gè)單元服務(wù)器上共同完成，其中，所述操作單元包括Web服務(wù)器、FTP服務(wù)器、企業(yè)關(guān)鍵應(yīng)用服務(wù)器。

可選地，所述微服務(wù)的實(shí)例負(fù)載監(jiān)控包括：微服務(wù)的實(shí)例調(diào)用、微服務(wù)的實(shí)例并發(fā)以及微服務(wù)的實(shí)例數(shù)據(jù)更新。

可選地，所述微服務(wù)的實(shí)例狀態(tài)變化檢測(cè)包括：

通過(guò)負(fù)載均衡定時(shí)檢測(cè)所述微服務(wù)的實(shí)例狀態(tài)變化是否為實(shí)例增加和/或刪除；

當(dāng)所述微服務(wù)的實(shí)例狀態(tài)變化是實(shí)例增加和/或刪除時(shí)，采用所述一致性哈希算法對(duì)所述實(shí)例請(qǐng)求進(jìn)行重新分配，并將分配結(jié)果返回對(duì)應(yīng)的調(diào)用者；

當(dāng)所述微服務(wù)的實(shí)例狀態(tài)變化不是實(shí)例增加和/或刪除時(shí)，報(bào)告所述實(shí)例運(yùn)行的負(fù)載狀態(tài)，并定時(shí)判斷所述實(shí)例的負(fù)載狀態(tài)是否達(dá)到預(yù)設(shè)的負(fù)載閥值。

可選地，所述單元服務(wù)器組的創(chuàng)建包括：

構(gòu)建所述單元服務(wù)器組存儲(chǔ)數(shù)據(jù)結(jié)構(gòu)、選擇所述單元服務(wù)器組持久化方式、利用Redis的復(fù)制功能實(shí)現(xiàn)所述單元服務(wù)器組的數(shù)據(jù)備份以及存儲(chǔ)所述單元服務(wù)器組固定的數(shù)據(jù)，以完成對(duì)所述單元服務(wù)器組的創(chuàng)建。

可選地，所述利用Redis的復(fù)制功能實(shí)現(xiàn)所述單元服務(wù)器組的數(shù)據(jù)備份，包括：