[發(fā)明專利]數(shù)據(jù)同步方法、裝置、計算機(jī)設(shè)備和可讀存儲介質(zhì)

在審

• 申請?zhí)枺?/td>: 202011484355.4
• 申請日: 2020-12-16
• 公開（公告）號: CN112612583A
• 公開（公告）日: 2021-04-06
• 發(fā)明（設(shè)計）人: 王曉初;趙宏軍
• 申請（專利權(quán)）人: 平安消費金融有限公司
• 主分類號: G06F9/48
• 分類號: G06F9/48;G06F9/50
• 代理公司: 北京英特普羅知識產(chǎn)權(quán)代理有限公司 11015
• 代理人: 程超

1.一種數(shù)據(jù)同步方法，其特征在于，包括：

確定執(zhí)行數(shù)據(jù)同步線程的數(shù)據(jù)處理能力；

確定消息隊列中的消息主題；以及

在同步所述消息主題對應(yīng)的數(shù)據(jù)時，根據(jù)所述數(shù)據(jù)處理能力和所述消息主題的歷史流量信息，調(diào)整所述消息主題的線程分配數(shù)量。

2.根據(jù)權(quán)利要求1所述的數(shù)據(jù)同步方法，其特征在于，在同步所述消息主題對應(yīng)的數(shù)據(jù)時，根據(jù)所述數(shù)據(jù)處理能力和所述消息主題的歷史流量信息，調(diào)整消息主題的線程分配數(shù)量的步驟包括：

根據(jù)所述歷史流量信息確定所述消息主題的數(shù)據(jù)量變化周期和間隔周期；

根據(jù)所述變化周期確定所述線程分配數(shù)量的調(diào)整時間；

根據(jù)所述間隔周期確定所述調(diào)整時間所依據(jù)的歷史時間；

若當(dāng)前時間達(dá)到所述調(diào)整時間時，根據(jù)所述數(shù)據(jù)處理能力和所述歷史時間的數(shù)據(jù)量確定目標(biāo)線程數(shù)；

通過所述目標(biāo)線程數(shù)調(diào)整所述線程分配數(shù)量。

3.根據(jù)權(quán)利要求2所述的數(shù)據(jù)同步方法，其特征在于，根據(jù)所述數(shù)據(jù)處理能力和所述歷史時間的數(shù)據(jù)量確定目標(biāo)線程數(shù)的步驟包括：

根據(jù)所述數(shù)據(jù)處理能力確定在單位時長內(nèi)處理數(shù)據(jù)量和所需線程數(shù)的對應(yīng)關(guān)系；

根據(jù)所述歷史時間的數(shù)據(jù)量確定所述單位時長內(nèi)的歷史數(shù)據(jù)量；以及

在所述對應(yīng)關(guān)系中，確定與所述歷史數(shù)據(jù)量對應(yīng)的線程數(shù)，以得到所述目標(biāo)線程數(shù)。

4.根據(jù)權(quán)利要求2所述的數(shù)據(jù)同步方法，其特征在于，根據(jù)所述變化周期確定所述線程分配數(shù)量的調(diào)整時間的步驟包括：

當(dāng)所述變化周期不滿足與時間的相關(guān)性要求時，確定所述調(diào)整時間為每間隔預(yù)定時長調(diào)整一次，其中，所述預(yù)定時長小于或等于所述預(yù)定周期；

當(dāng)所述變化周期滿足與時間的相關(guān)性要求時，確定所述調(diào)整時間為每間隔所述變化周期對應(yīng)的時長調(diào)整一次。

5.根據(jù)權(quán)利要求1所述的數(shù)據(jù)同步方法，其特征在于，確定執(zhí)行數(shù)據(jù)同步的線程的數(shù)據(jù)處理能力的步驟包括：

在所述消息隊列的測試消息主題中寫入滿足測試量的測試數(shù)據(jù)；

訂閱所述測試消息主題，以使所述線程消費所述測試數(shù)據(jù)；

記錄所述線程的消費完成時間；以及

根據(jù)所述測試量和所述消費完成時間，確定所述線程的數(shù)據(jù)處理能力。

6.根據(jù)權(quán)利要求1所述的數(shù)據(jù)同步方法，其特征在于，在調(diào)整消息主題的線程分配數(shù)量的步驟之后，所述數(shù)據(jù)同步方法還包括：

將所述線程分配數(shù)量的線程分配至若干同步節(jié)點，其中，當(dāng)所述線程分配數(shù)量大于1時，至少將兩個所述線程分配至不同的同步節(jié)點。

7.根據(jù)權(quán)利要求6所述的數(shù)據(jù)同步方法，其特征在于，當(dāng)所述線程分配數(shù)量大于1時，將所述線程分配數(shù)量的線程分配至若干同步節(jié)點的步驟包括：

若所述線程分配數(shù)量等于所述同步節(jié)點的數(shù)量時，為每個所述同步節(jié)點分配一個所述線程；

若所述線程分配數(shù)量大于所述同步節(jié)點的數(shù)量時，為每個所述同步節(jié)點分配至少一個所述線程，且為線程運行數(shù)量少的所述同步節(jié)點線程分配數(shù)量多的所述線程；

若所述線程分配數(shù)量小于所述同步節(jié)點的數(shù)量時，將每個所述線程分配至不同的所述同步節(jié)點，且被分配線程的同步節(jié)點的線程運行數(shù)量小于或等于未被分配線程的同步節(jié)點的線程運行數(shù)量。

8.一種數(shù)據(jù)同步裝置，其特征在于，包括：

第一確定模塊，用于確定執(zhí)行數(shù)據(jù)同步線程的數(shù)據(jù)處理能力；

第二確定模塊，用于確定消息隊列中的消息主題；以及

調(diào)整模塊，用于在同步所述消息主題對應(yīng)的數(shù)據(jù)時，根據(jù)所述數(shù)據(jù)處理能力和所述消息主題的歷史流量信息，調(diào)整所述消息主題的線程分配數(shù)量。

9.一種計算機(jī)設(shè)備，包括存儲器、處理器以及存儲在存儲器上并可在處理器上運行的計算機(jī)程序，其特征在于，所述處理器執(zhí)行所述計算機(jī)程序時實現(xiàn)權(quán)利要求1至7任一項所述方法的步驟。

10.一種計算機(jī)可讀存儲介質(zhì)，包括存儲數(shù)據(jù)區(qū)和存儲程序區(qū)，存儲數(shù)據(jù)區(qū)存儲根據(jù)區(qū)塊鏈節(jié)點的使用所創(chuàng)建的數(shù)據(jù)，存儲程序區(qū)存儲有計算機(jī)程序，其特征在于，所述計算機(jī)程序被處理器執(zhí)行時實現(xiàn)權(quán)利要求1至7任一項所述方法的步驟。