[發(fā)明專利]redis數(shù)據(jù)同步方法及服務(wù)器

有效

• 申請?zhí)枺?/td>: 202010364699.5
• 申請日: 2020-04-30
• 公開（公告）號: CN111680100B
• 公開（公告）日: 2023-02-28
• 發(fā)明（設(shè)計(jì)）人: 劉先攀;矯恒浩;馬忠飛;胡曉峰;胡新靜;張宏波;吳連朋
• 申請（專利權(quán)）人: 聚好看科技股份有限公司
• 主分類號: G06F16/27
• 分類號: G06F16/27
• 代理公司: 北京弘權(quán)知識產(chǎn)權(quán)代理有限公司 11363
• 代理人: 逯長明;許偉群

本申請實(shí)施例提供了一種redis數(shù)據(jù)同步方法及服務(wù)器，方法包括：同步單元和源redis建立連接；同步單元判斷預(yù)設(shè)位置是否存儲有持久化的位置信息，其中，所述位置信息包括所述同步單元的位置偏移量、所述同步單元上次與所述源redis連接時(shí)記錄的運(yùn)行身份信息；如果所述預(yù)設(shè)位置存儲有所述位置信息，同步單元根據(jù)所述位置信息向所述源redis發(fā)送增量同步請求；同步單元根據(jù)接收到來自所述源redis的增量同步信息，執(zhí)行增量同步，并定時(shí)持久化位置信息。本申請實(shí)施例通過定時(shí)持久化位置信息，解決了同步單元和不能進(jìn)行增量同步而導(dǎo)致的redis數(shù)據(jù)同步效率低的問題。

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

本申請涉及電視的智能測試技術(shù)領(lǐng)域，尤其涉及一種redis數(shù)據(jù)同步方法及服務(wù)器。

背景技術(shù)

隨著互聯(lián)網(wǎng)的迅速發(fā)展，各公司的業(yè)務(wù)逐步擴(kuò)大，業(yè)務(wù)的穩(wěn)定性備受關(guān)注。目前，很多公司采用異地雙活的系統(tǒng)架構(gòu)，異地的兩個(gè)機(jī)房之間進(jìn)行redis(Remote DictionaryServer，遠(yuǎn)程字典服務(wù))數(shù)據(jù)單向同步，這樣，當(dāng)一個(gè)機(jī)房出現(xiàn)故障后，該機(jī)房的業(yè)務(wù)可迅速切換到另一個(gè)機(jī)房，以提高業(yè)務(wù)的穩(wěn)定性。

基于RedisShake的數(shù)據(jù)同步方法是實(shí)現(xiàn)redis數(shù)據(jù)單向同步的一種重要方法，該方法利用RedisShake模擬redis主從協(xié)議，使RedisShake作為源redis的從節(jié)點(diǎn)接收redis數(shù)據(jù)，再將redis數(shù)據(jù)寫到目標(biāo)redis，從而實(shí)現(xiàn)數(shù)據(jù)單向同步。該方法可在異地機(jī)房配置高可用的目標(biāo)redis，從而提高業(yè)務(wù)穩(wěn)定性。

然而，向RedisShake寫redis數(shù)據(jù)的機(jī)房有時(shí)會(huì)發(fā)生主從切換，即該機(jī)房中作為源redis的redis主節(jié)點(diǎn)掛掉，redis從節(jié)點(diǎn)被提升為redis主節(jié)點(diǎn)，而redis主節(jié)點(diǎn)和redis從節(jié)點(diǎn)的運(yùn)行身份信息在重新上線后會(huì)改變，源redis只能匹配自己的從節(jié)點(diǎn)或自己的舊主節(jié)點(diǎn)的從節(jié)點(diǎn)，這將導(dǎo)致源redis發(fā)生兩次及以上的主從切換時(shí)，RedisShake作為舊主節(jié)點(diǎn)之前的主節(jié)點(diǎn)的從節(jié)點(diǎn)，無法與源redis進(jìn)行匹配，只能作為一個(gè)新的從節(jié)點(diǎn)與源redis進(jìn)行匹配，導(dǎo)致原有的數(shù)據(jù)單向同步不能增量進(jìn)行，只能重新進(jìn)行全量同步，導(dǎo)致同步效率降低。

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

為解決上述技術(shù)問題，本申請?zhí)峁┝艘环Nredis數(shù)據(jù)同步方法及服務(wù)器。

第一方面，本申請實(shí)施例提供了一種redis數(shù)據(jù)同步方法，該方法包括：

同步單元和源redis建立連接；

判斷預(yù)設(shè)位置是否存儲有持久化的位置信息，其中，所述位置信息包括所述同步單元的位置偏移量、所述同步單元上次與所述源redis連接時(shí)記錄的運(yùn)行身份信息；

如果所述預(yù)設(shè)位置存儲有所述位置信息，則根據(jù)所述位置信息向所述源redis發(fā)送增量同步請求；

根據(jù)接收到來自所述源redis的增量同步信息，執(zhí)行增量同步，并定時(shí)持久化位置信息。

第二方面，本申請實(shí)施例提供了一種服務(wù)器，該服務(wù)器被配置為：

同步單元與源redis建立連接；

同步單元判斷預(yù)設(shè)位置是否存儲有持久化的位置信息，其中，所述位置信息包括所述同步單元的位置偏移量、所述同步單元上次與所述源redis連接時(shí)記錄的運(yùn)行身份信息；

如果所述預(yù)設(shè)位置存儲有所述位置信息，同步單元根據(jù)所述位置信息向所述源redis發(fā)送增量同步請求；

同步單元根據(jù)接收到來自所述源redis的增量同步信息，執(zhí)行增量同步，并定時(shí)持久化位置信息。

本申請?zhí)峁﹔edis數(shù)據(jù)同步方法及服務(wù)器的有益效果包括：