[發明專利]緩存數據刷新方法及分布式系統

在審

• 申請號: 202011484476.9
• 申請日: 2020-12-16
• 公開（公告）號: CN112597195A
• 公開（公告）日: 2021-04-02
• 發明（設計）人: 余佳齊;孫健
• 申請（專利權）人: 中國建設銀行股份有限公司
• 主分類號: G06F16/2455
• 分類號: G06F16/2455;G06F16/27
• 代理公司: 北京三友知識產權代理有限公司 11127
• 代理人: 賈磊;李輝

本說明書實施例公開了一種緩存數據刷新方法及分布式系統，對本地緩存使用兩級哈希表結構進行數據存儲。第一級哈希表中以類型標識作為鍵值，以第二級數據表的鍵值作為數據值；第二級哈希表的鍵值基于數據記錄在數據庫中的主鍵生成，第二級哈希表的數據值對應緩存的單條數據記錄。分布式緩存采用哈希槽結構進行數據存儲，哈希槽內數據值的鍵值基于類型標識以及數據記錄在數據庫中的主鍵生成，數據值對應緩存的單條數據記錄，哈希槽內數據集合的標記字段基于鍵值中的類型標識生成，以使相同類型標識下的鍵值及數據記錄存儲至同一數據集合中。基于上述緩存數據存儲結構，可以大幅提高各級緩存數據刷新的效率以及一致性。

技術領域

本說明書涉及數據處理技術領域，特別地，涉及一種緩存數據刷新方法及分布式系統。

背景技術

目前主流的分布式系統都會用到緩存功能，緩存會重復訪問的數據，提高系統響應速度，并且可以減輕系統的負載。當前金融機構通常采用本地緩存、分布式緩存兩級緩存，其中，本地緩存、分布式緩存的優先級依次降低。數據庫為業務系統以及各級緩存提供原始數據。如每臺服務器(AP)都可以配置本地緩存，該緩存優先級最高，服務器執行數據處理時優先從本地緩存查詢數據，存在則直接返回結果。如果本地緩存不存在時，則可以進一步從分布式緩存中查詢，如果還是沒有，則直接查詢數據庫。如果從數據庫中查詢到數據，則可以將查詢到的數據分別寫入本地緩存和分布式緩存。

但目前常用的多級緩存系統只能實現單條數據的緩存刷新，采用該目前的緩存刷新方式，在業務系統自身執行數據刷新或者與其他業務系統進行數據同步時，需要比較新舊數據，找出增刪改了哪些數據，然后逐一調用接口，刷新變化的參數，數據刷新操作較為復雜繁瑣，且易出現漏刷數據或者錯誤刷新的情況。同時，分布式系統各節點處理的數據量非常龐大，使得新舊數據的比較需要消耗較長的時間，且逐一刷新數據也需要消耗較長的時間。因此，目前亟需一種更加簡單高效的數據刷新方法。

發明內容

本說明書實施例的目的在于提供一種緩存數據刷新方法及分布式系統，可以大幅提高分布式系統中各級緩存數據刷新的效率以及一致性。

本說明書提供一種緩存數據刷新方法及分布式系統是包括如下方式實現的：

一種緩存數據刷新方法，應用于分布式系統，所述分布式系統包括數據庫、分布式緩存、通知中心以及至少一個應用服務器。所述應用服務器中布設有本地緩存，所述應用服務器與所述通知中心建立通信連接。其中，所述本地緩存采用兩級哈希表結構進行數據存儲；第一級哈希表中以類型標識作為鍵值，以第二級數據表的鍵值作為數據值；第二級哈希表的鍵值基于數據記錄在數據庫中的主鍵生成。分布式緩存采用哈希槽結構進行數據存儲；其中，哈希槽內數據值的鍵值基于類型標識以及數據記錄在數據庫中的主鍵生成，哈希槽內數據集合的標記字段基于鍵值中的類型標識生成，以使相同類型標識下的鍵值及數據記錄存儲至同一數據集合中。所述方法包括如下步驟。所述數據提供方在確定對數據庫的目標數據記錄更新操作成功后，向所述分布式緩存發送數據更新指令，所述數據更新指令包括目標數據記錄以及所述目標數據記錄的目標類型標識、在數據庫中的目標主鍵，以使所述分布式緩存將所述目標類型標識以及目標主鍵所對應的數據記錄更新為所述目標數據記錄。以及，所述數據提供方向通知中心發送數據更新通知，所述數據更新通知包括所述目標數據記錄的目標類型標識、在數據庫中的目標主鍵；以使各應用服務器在接收到通知中心的消息后，從所述分布式緩存中讀取所述目標類型標識以及目標主鍵所對應的數據記錄，并基于讀取的數據記錄對本地緩存中所述目標類型標識以及目標主鍵對應的數據記錄進行更新處理。

本說明書提供的所述方法的另一些實施例中，所述數據提供方通過異步的方式向通知中心發送數據更新通知；并在接收到通知中心反饋的消息廣播成功響應后，向所述分布式緩存發送數據更新指令。