[發(fā)明專利]一種數據同步的控制方法、系統(tǒng)及裝置

在審

• 申請?zhí)枺?/td>: 201811442204.5
• 申請日: 2018-11-29
• 公開（公告）號: CN109684391A
• 公開（公告）日: 2019-04-26
• 發(fā)明（設計）人: 楊井
• 申請（專利權）人: 無錫天脈聚源傳媒科技有限公司
• 主分類號: G06F16/25
• 分類號: G06F16/25;G06F16/27;G06Q40/04
• 代理公司: 廣州嘉權專利商標事務所有限公司 44205
• 代理人: 譚英強

1.一種數據同步的控制系統(tǒng)，其特征在于，包括數據業(yè)務層、卡夫卡層和數據庫，所述數據業(yè)務層通過卡夫卡層與數據庫連接；

所述數據業(yè)務層用于獲取并運算貨幣交易數據，并將貨幣交易數據傳輸至卡夫卡層；

所述卡夫卡層用于采用消息隊列方式接收并分析貨幣交易數據后，將分析后的貨幣交易數據傳輸至數據庫；

所述數據庫用于將接收到的貨幣交易數據存儲接收到相應的MongoDB模塊中。

2.根據權利要求1所述的一種數據同步的控制系統(tǒng)，其特征在于，所述卡夫卡層包括Java服務模塊，所述Java服務模塊用于在接收到貨幣交易數據后，根據貨幣交易數據的類型將貨幣交易數據存儲在預設的數據組中，并將數據組中的貨幣交易數據映射存儲至相應類型的MongoDB模塊中。

3.根據權利要求2所述的一種數據同步的控制系統(tǒng)，其特征在于，所述數據組包括同步數據組和異步數據組。

4.根據權利要求3所述的一種數據同步的控制系統(tǒng)，其特征在于，所述夫卡層還包括數據分析模塊，所述數據分析模塊用于從異步數據組中獲取各類型的貨幣交易數據，并對貨幣交易數據進行分析后，將分析結果存儲至相應的MongoDB模塊中。

5.根據權利要求4所述的一種數據同步的控制系統(tǒng)，其特征在于，所述數據業(yè)務層包括主節(jié)點模塊和備份節(jié)點模塊；

所述主節(jié)點模塊用于對貨幣交易數據進行運算處理；

所述備份節(jié)點模塊用于實時備份主節(jié)點模塊的運算節(jié)點，并在判斷主節(jié)點模塊出現故障時，替換主節(jié)點模塊對貨幣交易數據進行運算處理。

6.一種數據同步的控制方法，其特征在于，包括以下步驟：

S1、獲取并運算貨幣交易數據；

S2、采用卡夫卡的消息隊列方式接收并分析貨幣交易數據后，將分析后的貨幣交易數據存儲接收到相應的MongoDB模塊中。

7.根據權利要求6所述的一種數據同步的控制方法，其特征在于，所述步驟S2中采用消息隊列方式接收貨幣交易數據的步驟，具體為：

在接收到貨幣交易數據后，根據貨幣交易數據的類型將貨幣交易數據存儲在預設的數據組中，并將數據組中的貨幣交易數據映射存儲至相應類型的MongoDB模塊中。

8.根據權利要求7所述的一種數據同步的控制方法，其特征在于，所述數據組包括同步數據組和異步數據組，所述步驟S2中采用消息隊列方式分析貨幣交易數據的步驟，具體為：

從異步數據組中獲取各類型的貨幣交易數據，并對貨幣交易數據進行分析后，將分析結果存儲至相應的MongoDB模塊中。

9.根據權利要求8所述的一種數據同步的控制方法，其特征在于，所述步驟S1，具體為：

獲取貨幣交易數據后，采用主節(jié)點模塊對貨幣交易數據進行運算處理；

采用備份節(jié)點模塊實時備份主節(jié)點模塊的運算節(jié)點，并在判斷主節(jié)點模塊出現故障時，

采用備份節(jié)點模塊替換主節(jié)點模塊對貨幣交易數據進行運算處理。

10.一種數據同步的控制裝置，其特征在于，包括：

至少一個處理器；

至少一個存儲器，用于存儲至少一個程序；

當所述至少一個程序被所述至少一個處理器執(zhí)行，使得所述至少一個處理器實現權利要求6-9任一項所述的一種數據同步的控制方法。