[發(fā)明專利]一種參數(shù)同步方法和裝置

有效

• 申請?zhí)枺?/td>: 202110423699.2
• 申請日: 2021-04-20
• 公開（公告）號: CN113127564B
• 公開（公告）日: 2023-02-28
• 發(fā)明（設(shè)計）人: 劉建楠;安興朝;趙釗
• 申請（專利權(quán)）人: 建信金融科技有限責(zé)任公司
• 主分類號: G06F16/27
• 分類號: G06F16/27
• 代理公司: 中原信達(dá)知識產(chǎn)權(quán)代理有限責(zé)任公司 11219
• 代理人: 張一軍;李陽

本申請公開了參數(shù)同步方法和裝置，涉及大數(shù)據(jù)技術(shù)領(lǐng)域。該方法包括：接收業(yè)務(wù)參數(shù)同步請求，觸發(fā)參數(shù)同步進(jìn)程；確定業(yè)務(wù)參數(shù)同步請求對應(yīng)的業(yè)務(wù)批次時間，調(diào)用參數(shù)同步引擎，獲取參數(shù)類型狀態(tài)表，以基于業(yè)務(wù)批次時間和參數(shù)類型狀態(tài)表，確定對應(yīng)該業(yè)務(wù)批次的參數(shù)分類記錄；將參數(shù)分類記錄傳輸至各個參數(shù)更新引擎以執(zhí)行更新任務(wù)，進(jìn)而從分布式緩存中提取與參數(shù)分類記錄對應(yīng)的參數(shù)變更數(shù)據(jù)，基于參數(shù)變更數(shù)據(jù)，更新各個參數(shù)更新引擎對應(yīng)的目標(biāo)數(shù)據(jù)庫；響應(yīng)于確定更新任務(wù)的執(zhí)行結(jié)果為部分成功，獲取該業(yè)務(wù)批次中內(nèi)呼狀態(tài)為失敗和不確定的更新任務(wù)，進(jìn)而執(zhí)行參數(shù)同步失敗異步重發(fā)進(jìn)程。可以實現(xiàn)參數(shù)同步的穩(wěn)定性和一致性，提高參數(shù)同步的實時性。

技術(shù)領(lǐng)域

本申請涉及大數(shù)據(jù)技術(shù)領(lǐng)域，尤其涉及一種參數(shù)同步方法和裝置。

背景技術(shù)

銀行核心系統(tǒng)中存在多種類型的公共參數(shù)，不同的應(yīng)用在實際業(yè)務(wù)應(yīng)用中需要依賴相關(guān)的公共參數(shù)，完成交易處理。目前，主要的參數(shù)復(fù)制技術(shù)有數(shù)據(jù)庫同步復(fù)制技術(shù)。其中，數(shù)據(jù)庫同步復(fù)制技術(shù)，通過定時以數(shù)據(jù)庫為維度，進(jìn)行整庫的數(shù)據(jù)遠(yuǎn)程完成拷貝。

在實現(xiàn)本申請過程中，發(fā)明人發(fā)現(xiàn)現(xiàn)有技術(shù)中至少存在如下問題：

目前參數(shù)復(fù)制技術(shù)的數(shù)據(jù)復(fù)制的實時性和性能不好，容易對業(yè)務(wù)交易的處理造成很大影響。

發(fā)明內(nèi)容

有鑒于此，本申請實施例提供一種參數(shù)同步方法和裝置，能夠解決現(xiàn)有的參數(shù)復(fù)制技術(shù)的數(shù)據(jù)復(fù)制的實時性和性能不好，容易對業(yè)務(wù)交易的處理造成很大影響的問題。

為實現(xiàn)上述目的，根據(jù)本申請實施例的一個方面，提供了一種參數(shù)同步方法，包括：

接收業(yè)務(wù)參數(shù)同步請求，觸發(fā)參數(shù)同步進(jìn)程；

確定業(yè)務(wù)參數(shù)同步請求對應(yīng)的業(yè)務(wù)批次時間，調(diào)用參數(shù)同步引擎，獲取參數(shù)類型狀態(tài)表，以基于業(yè)務(wù)批次時間和參數(shù)類型狀態(tài)表，確定對應(yīng)該業(yè)務(wù)批次的參數(shù)分類記錄；

將參數(shù)分類記錄傳輸至各個參數(shù)更新引擎以執(zhí)行更新任務(wù)，進(jìn)而從分布式緩存中提取與參數(shù)分類記錄對應(yīng)的參數(shù)變更數(shù)據(jù)，調(diào)用結(jié)構(gòu)化查詢語言，基于參數(shù)變更數(shù)據(jù)，更新各個參數(shù)更新引擎對應(yīng)的目標(biāo)數(shù)據(jù)庫；

響應(yīng)于確定更新任務(wù)的執(zhí)行結(jié)果為部分成功，獲取該業(yè)務(wù)批次中內(nèi)呼狀態(tài)為失敗和不確定的更新任務(wù)，進(jìn)而執(zhí)行參數(shù)同步失敗異步重發(fā)進(jìn)程。

可選地，確定對應(yīng)該業(yè)務(wù)批次的參數(shù)分類記錄，包括：

獲取業(yè)務(wù)參數(shù)同步請求對應(yīng)的業(yè)務(wù)批次所對應(yīng)的更新任務(wù)集合；

確定參數(shù)類型狀態(tài)表的更新時間；

基于業(yè)務(wù)批次時間、更新時間以及預(yù)設(shè)的超時時間閾值，確定更新任務(wù)集合中的超時更新任務(wù)；

調(diào)用線程池，并發(fā)同步執(zhí)行各超時更新任務(wù)，確定各超時更新任務(wù)的執(zhí)行結(jié)果；

基于各超時更新任務(wù)的執(zhí)行結(jié)果，更新參數(shù)類型狀態(tài)表，進(jìn)而確定更新的參數(shù)類型狀態(tài)表中的參數(shù)分類記錄。

可選地，提取與參數(shù)分類記錄對應(yīng)的參數(shù)變更數(shù)據(jù)，包括：

響應(yīng)于確定分布式緩存中不存在與參數(shù)分類記錄對應(yīng)的參數(shù)變更數(shù)據(jù)，從源數(shù)據(jù)庫中查找并提取參數(shù)變更數(shù)據(jù)。

可選地，更新各個參數(shù)更新引擎對應(yīng)的目標(biāo)數(shù)據(jù)庫，包括：

確定參數(shù)變更數(shù)據(jù)的索引；

基于索引、參數(shù)變更數(shù)據(jù)和目標(biāo)數(shù)據(jù)庫，執(zhí)行結(jié)構(gòu)化查詢語言；

響應(yīng)于確定執(zhí)行結(jié)果異常，判斷執(zhí)行操作類型；

基于執(zhí)行操作類型，確定對應(yīng)的處理方式；