[發明專利]一種熔斷限額數據同步方法和裝置

在審

• 申請號: 202110350495.0
• 申請日: 2021-03-31
• 公開（公告）號: CN112860804A
• 公開（公告）日: 2021-05-28
• 發明（設計）人: 全嫣;段文淵;王巖
• 申請（專利權）人: 中國工商銀行股份有限公司
• 主分類號: G06F16/27
• 分類號: G06F16/27;G06Q20/10;G06Q20/40
• 代理公司: 北京三友知識產權代理有限公司 11127
• 代理人: 任默聞;王濤

本申請涉及互聯網金融技術領域，提供了一種熔斷限額數據同步方法和裝置，其中，該方法包括：在累計限額增加的情況下，確定雙寫開關是否為開狀態；在所述雙寫開關為開狀態的情況下，調用目標數據庫的限額服務，根據限額的增加額對所述目標數據庫的分片庫中的數據進行更新，再根據限額的增加額對指令庫中的數據進行更新；在所述雙寫開關為關狀態的情況下，將限額的累加額更新至所述指令庫中。通過上述方案解決了現有的采用隊列的方式進行數據的同步所存在的資源消耗大、改造不徹底、同步時效低和系統穩定性的問題，達到提高同步效率、減少時延、降低資源占用的技術效果。

技術領域

本申請屬于互聯網金融技術領域，尤其涉及一種熔斷限額數據同步方法和裝置。

背景技術

目前通過企業網銀進行轉賬匯款、代發工資等操作，都是依賴的后臺指令庫。然而，隨著數據量的不斷增加，會導致指令庫的異常，這樣將影響企業網銀的相關交易。

企業網銀熔斷解耦的目的是為了實現ebbc專屬產品群組和指令庫解耦，從而保證在指令庫異常期間，ebbc專屬產品群組仍舊可以正常對外提供服務，以提升專屬產品群組的容災能力。企業客戶交易限額信息的表數據一般是存儲在F-EBANKC(企業網上銀行)的指令庫中，而企業網銀交易邏輯是讀取該數據庫的限額信息。為實現熔斷解耦，達到一旦企網指令庫出現異常無法讀取限額信息，但部分交易還能正常進行的目的，正式開啟熔斷機制前，需要將客戶交易的限額累計數據從企網(F-EBANKC)指令oracle數據庫同步到F-EBBCBASE(企業電子銀行業務)的mysql分片數據庫中。等到異常情況發生時，企業網銀轉賬匯款、代發工資等交易可以通過讀取、記錄F-EBBCBASE的maysql分片數據庫中的數據，保證交易的正常進行。

目前，熔斷前限額數據的同步機制是：先在原企業網銀(F-EBANKC)指令庫上部署CDC(Change Data Capture，變動數據捕獲)同步工具；然后，申請新容器，并在容器上搭建KAFKA數據同步服務環境。在F-EBANKC側，對原有的限額數據記錄代碼進行修改，新增數據推送線程，同時保留原有代碼中對限額數據記錄在指令庫中的處理代碼。在F-EBBCBASE側，修改原有限額數據記錄方式代碼，新增限額數據拉取線程，同時增加集團數據分片路由判斷的代碼。然后，開啟CDC同步開關，將前臺交易新增限額數據送至KAFKA的消息隊列中。同時，F-EBBCBASE拉取線程按照表維度啟動線程從KAFKA拉取最新限額信息，并更新對應分片，完成同步。

然而，當前的企業網銀面臨著眾多的分布式架構轉型、群組拆分等改造，對于數據同步的改造需求逐步增多。但當前的限額同步機制只考慮到指令庫和F-EBBCBASE分片庫的同步，對于企業網銀其他未拆分的群組沒有進行考慮和部署，沒有可復用性，后遺癥較多，一旦有新的群組被拆分出來，則面臨重新設計方案或者大量修改方案的風險。進一步的，這種同步方式需要申請CDC和KAFKA相關資源，申請相關同步線程容器，新增推送線程、拉取線程。如果后期企業網銀新增其他群組需要進行數據同步時，此數據同步方案可能被作廢，造成資源浪費。同時生產運營期間需要對新增的CDC和KAFKA環境進行監控和維護，增加了生產運營的維護成本。且這種同步方式的需要被同步的限額數據量非常大，且KAFKA的工作機制存在性能瓶頸，導致數據同步會有延遲，無法達到實時精確的效果。

針對上述問題，目前尚未提出有效的解決方案。

發明內容

本申請目的在于提供一種熔斷限額數據同步方法和裝置，可以解決現有的熔斷限額數據同步機制所存在的資源消耗大、改造不徹底、同步時效低和系統穩定性不足的問題。

本申請提供一種熔斷限額數據同步方法和裝置是這樣實現的：

一種熔斷限額數據同步方法，所述方法包括：

在累計限額增加的情況下，確定雙寫開關是否為開狀態；