[發(fā)明專利]配置數(shù)據(jù)的同步方法、業(yè)務(wù)數(shù)據(jù)系統(tǒng)、計算機(jī)系統(tǒng)和介質(zhì)

在審

• 申請?zhí)枺?/td>: 202010957928.4
• 申請日: 2020-09-11
• 公開（公告）號: CN112069265A
• 公開（公告）日: 2020-12-11
• 發(fā)明（設(shè)計）人: 楊光宇;高建華;周莉;陳棟
• 申請（專利權(quán)）人: 中國工商銀行股份有限公司
• 主分類號: G06F16/27
• 分類號: G06F16/27;G06F16/23;G06F16/25;G06F9/54
• 代理公司: 中科專利商標(biāo)代理有限責(zé)任公司 11021
• 代理人: 呂朝蕙

本公開提供了一種配置數(shù)據(jù)的同步方法，應(yīng)用于業(yè)務(wù)數(shù)據(jù)系統(tǒng)。業(yè)務(wù)數(shù)據(jù)系統(tǒng)包括：上游系統(tǒng)、配置管理系統(tǒng)、消息中間件和下游系統(tǒng)。該配置數(shù)據(jù)的同步方法方法包括：配置管理系統(tǒng)在上游系統(tǒng)發(fā)生配置項數(shù)據(jù)變化的情況下，生成針對該配置項變化的配置更新消息；配置管理系統(tǒng)將配置更新消息發(fā)送至消息中間件，以由消息中間件將配置更新消息存入分布式消息隊列；以及，下游系統(tǒng)從所述分布式消息隊列中獲取配置更新消息，并基于配置更新消息進(jìn)行配置項數(shù)據(jù)更新。本公開還提供了一種業(yè)務(wù)數(shù)據(jù)系統(tǒng)、計算機(jī)系統(tǒng)和介質(zhì)。本公開提供的配置數(shù)據(jù)的同步方法和業(yè)務(wù)數(shù)據(jù)系統(tǒng)可以應(yīng)用于金融領(lǐng)域以及其他相關(guān)領(lǐng)域的上下游系統(tǒng)的及時性和一致性更新場景。

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

本公開涉及計算機(jī)技術(shù)領(lǐng)域，更具體地，涉及一種配置數(shù)據(jù)的同步方法、業(yè)務(wù)數(shù)據(jù)系統(tǒng)、計算機(jī)系統(tǒng)和介質(zhì)。

背景技術(shù)

業(yè)務(wù)數(shù)據(jù)系統(tǒng)在進(jìn)行配置數(shù)據(jù)管理的過程中，存在子系統(tǒng)眾多，上下游系統(tǒng)對配置數(shù)據(jù)同步時效性、一致性要求高等特點。在現(xiàn)有系統(tǒng)日益復(fù)雜、下游系統(tǒng)日益增多的情況下，針對配置數(shù)據(jù)的以下需求更為顯著：1、數(shù)據(jù)的高時效性，即上游系統(tǒng)的數(shù)據(jù)需要及時至下游系統(tǒng)；2、數(shù)據(jù)的一致性，由于每個下游系統(tǒng)需要的數(shù)據(jù)不同，要保障各個下游系統(tǒng)獲取到自身所需數(shù)據(jù)，并保持各子系統(tǒng)數(shù)據(jù)的一致和準(zhǔn)確。

目前配置數(shù)據(jù)一般由如下方式產(chǎn)生并傳遞：配置管理系統(tǒng)調(diào)用上游系統(tǒng)的接口獲取基礎(chǔ)信息并錄入到配置管理系統(tǒng)中，環(huán)境搭建系統(tǒng)在基礎(chǔ)信息基礎(chǔ)上將配置數(shù)據(jù)維護(hù)至配置管理系統(tǒng)，配置管理系統(tǒng)將配置數(shù)據(jù)每天以批量接口方式下發(fā)給各下游系統(tǒng)，下游系統(tǒng)導(dǎo)入配置數(shù)據(jù)并使用。該方式無法滿足數(shù)據(jù)的高時效性同步，并且在配置管理系統(tǒng)的批量接口出現(xiàn)異常的情況下，數(shù)據(jù)一致性也會受到影響。

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

本公開的一個方面提供了一種配置數(shù)據(jù)的同步方法，應(yīng)用于業(yè)務(wù)數(shù)據(jù)系統(tǒng)。業(yè)務(wù)數(shù)據(jù)系統(tǒng)包括：上游系統(tǒng)、配置管理系統(tǒng)、消息中間件和下游系統(tǒng)。該配置數(shù)據(jù)的同步方法方法包括：配置管理系統(tǒng)在上游系統(tǒng)發(fā)生配置項數(shù)據(jù)變化的情況下，生成針對該配置項變化的配置更新消息；配置管理系統(tǒng)將配置更新消息發(fā)送至消息中間件，以由消息中間件將配置更新消息存入分布式消息隊列；以及，下游系統(tǒng)從所述分布式消息隊列中獲取配置更新消息，并基于配置更新消息進(jìn)行配置項數(shù)據(jù)更新。

可選地，上述方法還包括：上游系統(tǒng)在發(fā)生配置項數(shù)據(jù)變化的情況下，生成變更信息，并將該變更信息發(fā)送至配置管理系統(tǒng)；以及，配置管理系統(tǒng)基于該變更信息進(jìn)行配置項數(shù)據(jù)變更操作。上述生成針對配置項變化的配置更新消息包括：基于配置項數(shù)據(jù)變更操作，生成配置更新消息。其中，配置更新消息包括：配置項標(biāo)識信息、變更操作類型、變更前配置項數(shù)據(jù)和變更后配置項數(shù)據(jù)。

可選地，上述將所述變更信息發(fā)送至所述配置管理系統(tǒng)包括：上游系統(tǒng)將變更信息通過消息中間件發(fā)送至分布式消息隊列，以由配置管理系統(tǒng)從分布式消息隊列獲取變更信息。

可選地，上述配置管理系統(tǒng)將所述配置更新消息發(fā)送至消息中間件，以由消息中間件將配置更新消息存入分布式消息隊列包括：配置管理系統(tǒng)將配置更新消息和針對配置更新消息的主題發(fā)送至消息中間件；以及，消息中間件基于該主題將配置更新消息存入分布式消息隊列。

可選地，上述下游系統(tǒng)從所述分布式消息隊列中獲取所述配置更新消息包括：下游系統(tǒng)通過訂閱所述主題的方式從分布式消息隊列中獲取配置更新消息。

可選地，下游系統(tǒng)存儲有預(yù)置配置項標(biāo)識信息。上述下游系統(tǒng)通過訂閱所述主題的方式從分布式消息隊列中獲取配置更新消息包括：下游系統(tǒng)通過訂閱所述主題的方式從分布式消息隊列中篩選與預(yù)置配置項標(biāo)識信息相匹配的配置更新消息。

可選地，消息中間件為卡夫卡集群。