[發(fā)明專利]一種聯(lián)機交易消息去重方法、裝置、介質(zhì)、產(chǎn)品和設(shè)備

在審

• 申請?zhí)枺?/td>: 202111452832.3
• 申請日: 2021-12-01
• 公開（公告）號: CN114138786A
• 公開（公告）日: 2022-03-04
• 發(fā)明（設(shè)計）人: 張潤;顧家俊;陸曉尉
• 申請（專利權(quán)）人: 中國建設(shè)銀行股份有限公司
• 主分類號: G06F16/22
• 分類號: G06F16/22;G06F16/25;G06Q40/04
• 代理公司: 北京同達信恒知識產(chǎn)權(quán)代理有限公司 11291
• 代理人: 萬曉君

本公開涉及一種聯(lián)機交易消息去重方法、裝置、介質(zhì)、產(chǎn)品和設(shè)備。在鍵值對數(shù)據(jù)庫中緩存消息去重配置列表，利用第一向量表濾波器中的第一比特向量表，來存儲已經(jīng)接收到的聯(lián)機交易消息指定主鍵值對應(yīng)的哈希值。新接收到聯(lián)機交易消息時，從鍵值對數(shù)據(jù)庫中獲得消息去重配置列表，確定對應(yīng)的消息去重索引主鍵。確定主鍵值對應(yīng)的第一哈希值是否已經(jīng)被存儲過，若確定已經(jīng)被存儲過，指示不對新的聯(lián)機交易消息進行處理，實現(xiàn)消息去重。由于鍵值對數(shù)據(jù)庫可以以較低延遲和較快的響應(yīng)速度來提供消息去重配置列表，且向量表濾波器可以實現(xiàn)比特向量表的快速查找，因此，可以有效保證消息去重的時效性。

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

本公開涉及數(shù)據(jù)處理技術(shù)領(lǐng)域，特別涉及一種聯(lián)機交易消息去重方法、裝置、介質(zhì)、產(chǎn)品和設(shè)備。

背景技術(shù)

本部分旨在為權(quán)利要求書中陳述的本公開的實施方式提供背景或上下文。此處的描述不因為包括在本部分中就承認是現(xiàn)有技術(shù)。

隨著信息系統(tǒng)的發(fā)展，聯(lián)機交易系統(tǒng)間的消息交互方式越來越多源化。而隨著區(qū)塊鏈、Kafka分布式消息發(fā)布等技術(shù)的介入，對聯(lián)機交易系統(tǒng)的組建提供了很大的便利，但同時也帶來了消息重復(fù)的問題。例如，假設(shè)區(qū)塊鏈有A、B兩個節(jié)點，一筆聯(lián)機交易的消息送到區(qū)塊鏈A節(jié)點，區(qū)塊鏈會通過共識機制將該消息同步到B節(jié)點，集群模式下A、B兩個節(jié)點都會向下游發(fā)送該消息，由此會造成消息重復(fù)的問題。

對于聯(lián)機交易系統(tǒng)，重復(fù)消息會帶來不必要的誤會。特別是對于賬務(wù)交易，重復(fù)消息可能帶來交易成功率的下降，甚至是錯賬，造成極大的麻煩。

目前的消息去重主要包括以下兩種方案：

第一種方案：

使用數(shù)據(jù)庫唯一約束技術(shù)。系統(tǒng)將接收到的每筆聯(lián)機交易的消息存入數(shù)據(jù)庫中，通過消息的一個屬性或多個屬性，建立消息的主鍵。如消息重復(fù)插入數(shù)據(jù)庫會發(fā)生異常報錯。

使用數(shù)據(jù)庫唯一約束技術(shù)，如果不在系統(tǒng)中增加重復(fù)判斷邏輯，會有數(shù)據(jù)庫系統(tǒng)級別的錯誤日志拋出，如果系統(tǒng)中不對此類異常報錯進行處理，錯誤將直接返回給用戶，對用戶體驗是不友好的。如果系統(tǒng)中加入重復(fù)判斷邏輯，同一系統(tǒng)中的不同聯(lián)機交易主鍵可能會不一樣，一方面造成了代碼量大大增加，增加了開發(fā)者的工作量，另一方面因為代碼分散，對系統(tǒng)的可維護性也會造成影響。同時頻繁地與數(shù)據(jù)庫進行交互，也無法保證聯(lián)機交易消息去重的時效性。

第二種方案：

在系統(tǒng)中給所有的請求的統(tǒng)一資源定位符(URL)加一個攔截器，每次將請求的URL存入會話控制(Session),下次請求時驗證URL的數(shù)據(jù)是否相同，如果相同則拒絕訪問。

但是，基于Session增加攔截器具有一定的局限性，服務(wù)端會同時存在幾種甚至幾十種服務(wù)，若訪問量較大，對服務(wù)端的性能有較高的要求，無法保證聯(lián)機交易消息去重的時效性。同時由于服務(wù)器的內(nèi)存不能在多臺服務(wù)器之間共享，該方案的擴展性會受到影響。

因此，亟需提供一種聯(lián)機交易消息去重機制，在進行消息去重時可以保證時效性。

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

本公開實施例提供一種聯(lián)機交易消息去重方法、裝置、介質(zhì)、產(chǎn)品和設(shè)備，用于解決進行聯(lián)機交易消息去重時效性較差的問題。

第一方面，本公開提供了一種聯(lián)機交易消息去重方法，所述方法包括：

若接收到一條聯(lián)機交易消息，獲取鍵值對數(shù)據(jù)庫緩存的消息去重配置列表，所述消息去重配置列表中包括預(yù)先配置的至少一個聯(lián)機交易類型編號、每個聯(lián)機交易類型編號分別對應(yīng)的至少一個消息去重索引主鍵；

根據(jù)所述聯(lián)機交易消息對應(yīng)的聯(lián)機交易類型，從所述消息去重配置列表中查找對應(yīng)的聯(lián)機交易類型編號對應(yīng)的至少一個消息去重索引主鍵；

根據(jù)查找出的至少一個消息去重索引主鍵，獲得所述聯(lián)機交易消息對應(yīng)的每個主鍵值；