[發(fā)明專利]基于數(shù)據(jù)庫的數(shù)據(jù)系統(tǒng)及處理方法

有效

• 申請?zhí)枺?/td>: 202010799320.3
• 申請日: 2020-08-11
• 公開（公告）號: CN111930843B
• 公開（公告）日: 2023-07-28
• 發(fā)明（設計）人: 趙森;馮澤盛
• 申請（專利權）人: 中國工商銀行股份有限公司
• 主分類號: G06F16/27
• 分類號: G06F16/27;G06F16/25;G06F9/54;G06F11/14
• 代理公司: 北京三友知識產權代理有限公司 11127
• 代理人: 王濤;單曉雙

本發(fā)明提供了一種基于數(shù)據(jù)庫的數(shù)據(jù)系統(tǒng)及處理方法，所述系統(tǒng)包含數(shù)據(jù)訪問代理組件、消息隊列組件、數(shù)據(jù)同步組件和N個數(shù)據(jù)節(jié)點；所述數(shù)據(jù)訪問代理組件用于根據(jù)接收到的交易請求進行路由分析，獲得執(zhí)行所述交易請求的數(shù)據(jù)節(jié)點，將所述交易請求對應的查詢語句寫入所述數(shù)據(jù)節(jié)點；以及，通過切面攔截所述數(shù)據(jù)節(jié)點已處理的所述查詢語句，將所述查詢語句推送至所述消息隊列組件；所述消息隊列組件用于接收所述數(shù)據(jù)訪問代理組件提供的所述查詢語句并存儲；所述數(shù)據(jù)同步組件用于通過所述消息隊列組件獲得所述查詢語句，于預設的其他數(shù)據(jù)節(jié)點執(zhí)行所述查詢語句并完成數(shù)據(jù)同步；各所述數(shù)據(jù)節(jié)點的環(huán)境配置和數(shù)據(jù)基礎一致，N為大于1的整數(shù)。

技術領域

本發(fā)明涉及大數(shù)據(jù)領域，可用于金融領域或其他領域，尤指一種基于數(shù)據(jù)庫的數(shù)據(jù)系統(tǒng)及處理方法。

背景技術

RTO(Recovery?Time?Object)是指災難發(fā)生后，從信息系統(tǒng)宕機導致業(yè)務停頓之刻開始，到信息系統(tǒng)恢復至可以支持各部門運作，業(yè)務恢復運營之時，此兩點之間的時間段成為RTO。在目前互聯(lián)網(wǎng)信息系統(tǒng)的高可用架構設計中，因數(shù)據(jù)存儲層數(shù)據(jù)庫產品的固有機制，其RTO一般在30分鐘左右(一個數(shù)據(jù)庫物理主節(jié)點故障后，其數(shù)據(jù)庫備用節(jié)點還需要30分鐘方可對外提供服務)，無法滿足信息系統(tǒng)下重要交易RTO小于10分鐘的要求。因此信息系統(tǒng)在數(shù)據(jù)庫系統(tǒng)產品高可用基礎上(整體RTO可以保證在30分鐘)，還需要在應用處理層針對重點交易進行代碼級的定制化雙寫操作(將數(shù)據(jù)寫入另一個數(shù)據(jù)庫主節(jié)點，非現(xiàn)有數(shù)據(jù)庫的備用節(jié)點)以保證一個數(shù)據(jù)庫主節(jié)點發(fā)生故障時可以在10分鐘內切換到另一個數(shù)據(jù)庫主節(jié)點提供服務。

但上述解決方案需要依賴應用處理層針對交易進行代碼級的定制化操作，一來應用雙寫造成服務時長增加，同時一旦交易范圍有變化，則每次都需要開發(fā)人員手動修改一遍并進行測試，存在開發(fā)測試工作量持續(xù)投入的問題，因此急需一種系統(tǒng)級的方法及方案解決上述問題。

發(fā)明內容

本發(fā)明目的在于提供一種基于數(shù)據(jù)庫的數(shù)據(jù)系統(tǒng)及處理方法解決了現(xiàn)有互聯(lián)網(wǎng)信息系統(tǒng)通過代碼級的應用雙寫策略存在不靈活、開發(fā)測試成本持續(xù)投入的問題。

為達上述目的，本發(fā)明所提供的一種基于數(shù)據(jù)庫的數(shù)據(jù)系統(tǒng)，所述系統(tǒng)包含數(shù)據(jù)訪問代理組件、消息隊列組件、數(shù)據(jù)同步組件和N個數(shù)據(jù)節(jié)點；所述數(shù)據(jù)訪問代理組件用于根據(jù)接收到的交易請求進行路由分析，獲得執(zhí)行所述交易請求的數(shù)據(jù)節(jié)點，將所述交易請求對應的查詢語句寫入所述數(shù)據(jù)節(jié)點；以及，通過切面攔截所述數(shù)據(jù)節(jié)點已處理的所述查詢語句，將所述查詢語句推送至所述消息隊列組件；所述消息隊列組件用于接收所述數(shù)據(jù)訪問代理組件提供的所述查詢語句并存儲；所述數(shù)據(jù)同步組件用于通過所述消息隊列組件獲得所述查詢語句，于預設的其他數(shù)據(jù)節(jié)點執(zhí)行所述查詢語句并完成數(shù)據(jù)同步；各所述數(shù)據(jù)節(jié)點的環(huán)境配置和數(shù)據(jù)基礎一致，N為大于1的整數(shù)。

在上述基于數(shù)據(jù)庫的數(shù)據(jù)系統(tǒng)中，優(yōu)選的，所述數(shù)據(jù)訪問代理組件還包含決策模塊；所述決策模塊用于分析所述交易請求在所述數(shù)據(jù)節(jié)點的執(zhí)行情況獲得執(zhí)行策略；所述執(zhí)行策略包含：當所述數(shù)據(jù)節(jié)點已處理完所述查詢語句，通過切面攔截所述查詢語句，將所述查詢語句推送至所述消息隊列組件；當所述數(shù)據(jù)節(jié)點未能處理完所述查詢語句，將所述交易請求退回至交易發(fā)起方并反饋提示信息。

在上述基于數(shù)據(jù)庫的數(shù)據(jù)系統(tǒng)中，優(yōu)選的，所述決策模塊包含：通過分布式事務同步機制分析所述交易請求在所述數(shù)據(jù)節(jié)點的執(zhí)行情況獲得執(zhí)行策略。

在上述基于數(shù)據(jù)庫的數(shù)據(jù)系統(tǒng)中，優(yōu)選的，所述數(shù)據(jù)訪問代理組件包含登記模塊，所述登記模塊用于將所述交易請求對應的查詢語句寫入所述數(shù)據(jù)節(jié)點的節(jié)點流水表，并于所述節(jié)點流水表中記錄所述數(shù)據(jù)節(jié)點為待登記狀態(tài)；以及，當所述數(shù)據(jù)節(jié)點通過所述查詢語句獲取所述交易請求后，將所述節(jié)點流水表中所述數(shù)據(jù)節(jié)點改為已登記狀態(tài)。

在上述基于數(shù)據(jù)庫的數(shù)據(jù)系統(tǒng)中，優(yōu)選的，所述數(shù)據(jù)同步組件還包含流水表更新模塊，所述流水表更新模塊用于在其他數(shù)據(jù)節(jié)點完成數(shù)據(jù)同步后，將所述節(jié)點流水表中其他數(shù)據(jù)節(jié)點設為已登記狀態(tài)。