[發明專利]一種分布式場景下數據一致性檢驗方法及系統

在審

• 申請號: 202210877164.7
• 申請日: 2022-07-25
• 公開（公告）號: CN115292383A
• 公開（公告）日: 2022-11-04
• 發明（設計）人: 王新健;李慶;陳堯;華震;張明強
• 申請（專利權）人: 浪潮云信息技術股份公司
• 主分類號: G06F16/2458
• 分類號: G06F16/2458;G06F16/27
• 代理公司: 濟南信達專利事務所有限公司 37100
• 代理人: 姜鵬

1.一種分布式場景下數據一致性檢驗方法，其特征在于：所述分布式場景下數據一致性檢驗方法包括以下步驟：

數據生產請求階段負責獲取數據生成范圍，獲得數據生成理論值；

保證子環節的數據一致性，進行數據流轉；

數據生成及持久化，獲得數據生成實際值；

進行理論值與實際值進行對比，進行數據生成準確性判斷。

2.根據權利要求1所述的一種分布式場景下數據一致性檢驗方法，其特征在于：數據生產請求階段，用于系統A接收請求生成訂單a在本月的賬單，首先將本次請求作為一個整體存入高效存儲服務器中，采用Redis內存數據庫進行存儲，記錄請求id，此處由于不同時間可能存在不同的價格、折扣等問題，本月賬單請求需要拆分成按天賬單子請求；

發送一次子請求將生成一條賬單并將上述請求id的賬單生成理論值+1，采用Redis中String數據類型的INCR方法，并將本次賬單請求id、請求時間記錄到MySQL數據庫賬單請求表中。

3.根據權利要求2所述的一種分布式場景下數據一致性檢驗方法，其特征在于：上述子請求采用異步消息隊列的方式發送賬單請求，請求到達系統B：B1、B2等，對訂單數據進行檢驗，并獲取訂單價格信息，通過異常捕獲記錄異常數據。

4.根據權利要求3所述的一種分布式場景下數據一致性檢驗方法，其特征在于：上述子請求攜帶請求id信息經過多個環節的數據流轉后到達數據生成系統C，系統C對生成的賬單數據進行入庫持久化操作，并對Redis中請求id的實際值進行累計，采用Redis中String數據類型的INCR方法。

5.根據權利要求4所述的一種分布式場景下數據一致性檢驗方法，其特征在于：上述賬單生成場景相對特殊數據產生理論值和實際值均為變量，系統D通過定時任務的方式定時將賬單產生的理論值與實際值進行對比，按照當前業務場景一次賬單請求在10分鐘以內完成，以10分鐘作為時間周期，查詢MySQL數據庫賬單請求表中請求時間在1小時內請求id，根據請求id查詢Redis中賬單實際值和理論值，檢驗并記錄到賬單請求表中；

通過賬單請求表數據產生理論值、實際值可以直觀判斷賬單生成正確性，如果發現實際值和理論值存在差距，結合過程2進行異常分析，進行數據最終一致性補救處理。

6.一種如上述權利要求1-5任意一項所述的分布式場景下數據一致性檢驗系統，其特征在于：所述檢驗系統由數據生產模塊、數據流轉模塊、數據生成模塊以及數據檢驗模塊構成；

數據生產模塊，用于數據生產請求階段負責獲取數據生成范圍，獲得數據生成理論值；

數據流轉模塊，用于保證子環節的數據一致性，進行數據流轉；

數據生成模塊，用于數據生成及持久化，獲得數據生成實際值；

數據檢驗模塊，用于進行理論值與實際值進行對比，進行數據生成準確性判斷。

7.根據權利要求6所述的一種分布式場景下數據一致性檢驗系統，其特征在于：所述數據生產模塊用于系統A接收請求生成訂單a在本月的賬單，首先將本次請求作為一個整體存入高效存儲服務器中，采用Redis內存數據庫進行存儲，記錄請求id，此處由于不同時間可能存在不同的價格、折扣等問題，本月賬單請求需要拆分成按天賬單子請求；

發送一次子請求將生成一條賬單并將上述請求id的賬單生成理論值+1，采用Redis中String數據類型的INCR方法，并將本次賬單請求id、請求時間記錄到MySQL數據庫賬單請求表中。

8.根據權利要求7所述的一種分布式場景下數據一致性檢驗系統，其特征在于：所述數據流轉模塊用于上述子請求采用異步消息隊列的方式發送賬單請求，請求到達系統B：B1、B2等，對訂單數據進行檢驗，并獲取訂單價格信息，通過異常捕獲記錄異常數據。