[發明專利]一種基于分布式環境的數據處理方法和裝置

有效

• 申請號: 202110352535.5
• 申請日: 2021-03-31
• 公開（公告）號: CN112988800B
• 公開（公告）日: 2022-09-27
• 發明（設計）人: 李華宏;邢磊
• 申請（專利權）人: 建信金融科技有限責任公司
• 主分類號: G06F16/2453
• 分類號: G06F16/2453;G06F16/23;G06F16/27;G06Q40/04
• 代理公司: 中原信達知識產權代理有限責任公司 11219
• 代理人: 王安娜;王志遠

本發明公開了一種基于分布式環境的數據處理方法和裝置，涉及分布式系統的數據處理技術領域。該方法的一具體實施方式包括：響應于日切發起節點發起的日切指令，更新配置中心的營業日期；在配置中心成功更新營業日期后，響應于日切指令，更新一個或多個路由節點的本地內存日期，其中，本地內存日期為存儲在路由節點的內存中的營業日期；通過一個或多個路由節點，按照一個或多個路由節點的本地內存日期處理交易請求。該實施方式能夠將獲取營業日期花費的時間降到完全忽略不計，減少了交易時長，還能夠避免單點故障風險，實現了一致性的日期切換。

技術領域

本發明涉及分布式系統的數據處理技術領域，尤其涉及一種基于分布式環境的數據處理方法和裝置。

背景技術

對于銀行業，賬務的時效性和準確性是最基本的要求。時效性要求日清日結，準確性要求銀行系統進行總分借貸平衡的檢查。銀行業7*24小時不間斷服務，日期切換時點的確定是實現日清日結和借貸平衡檢查的關鍵。因此，分布式環境下如何實現日切，成為一個技術難點。

現有提供的分布式環境下的日切方案，采用集中式存儲當前營業日期。日終批處理節點是唯一的日期切換寫入節點，其他業務處理節點每次處理交易都需要執行至少一次遠程查詢，對于一筆復雜的交易會發生多次遠程查詢，增加了交易時長，并且集中式存儲也帶來單點故障的風險。

發明內容

有鑒于此，本發明實施例提供一種基于分布式環境的數據處理方法和裝置，能夠將獲取營業日期花費的時間降到完全忽略不計，減少了交易時長，還能夠避免單點故障風險，實現了一致性的日期切換。

為實現上述目的，根據本發明實施例的一個方面，提供了一種基于分布式環境的數據處理方法。

本發明實施例的基于分布式環境的數據處理方法，包括：響應于日切發起節點發起的日切指令，更新配置中心的營業日期；在所述配置中心成功更新營業日期后，響應于所述日切指令，更新一個或多個路由節點的本地內存日期，其中，所述本地內存日期為存儲在路由節點的內存中的營業日期；通過所述一個或多個路由節點，按照所述一個或多個路由節點的本地內存日期處理交易請求。

可選地，所述方法還包括：根據所述路由節點對應的日期有效時間，判斷所述路由節點的本地內存日期是否失效，其中，所述日期有效時間為本地內存日期的有效時間；若是，則從所述配置中心讀取所述營業日期，并利用所述營業日期更新所述路由節點的本地內存日期。

可選地，所述方法還包括：若到達所述日切指令對應的重新發起時間，重新發起所述日切指令，其中，所述日切指令對應的重新發起時間大于所述日期有效時間。

可選地，在重新發起所述日切指令之前，所述方法還包括：獲取日期更新成功的路由節點和日期更新失敗的路由節點；判斷所述日期更新成功的路由節點與所述日期更新失敗的路由節點的節點數量比值是否大于預設的比值閾值；若是，則確定所述日切發起節點放棄重新發起所述日切指令；若否，則確定所述日切發起節點重新發起所述日切指令。

可選地，所述重新發起所述日切指令，包括：通過所述日切發起節點向所述日期更新失敗的路由節點重新發起所述日切指令，以便于所述日期更新失敗的路由節點響應于所述日切指令進行日期更新。

可選地，所述方法還包括：若所述路由節點符合以下選項中至少一項：更新日期失敗的次數超過預設次數閾值、在預設時間內更新日期失敗，則確定所述路由節點為異常節點，返回所述異常節點的運維故障處理信息，以及觸發運維告警信息。

可選地，所述更新日期失敗包括：響應于所述日切指令更新日期失敗、從所述配置中心讀取所述營業日期失敗。

可選地，所述方法還包括：若存在新啟動的路由節點，則從所述配置中心讀取所述營業日期，并將所述營業日期存儲至所述新啟動的路由節點的內存中，以便所述新啟動的路由節點按照所述營業日期處理交易請求。