[發明專利]基于數據庫Binlog的分布式緩存更新方法及裝置

在審

• 申請號: 202110788368.9
• 申請日: 2021-07-13
• 公開（公告）號: CN113448977A
• 公開（公告）日: 2021-09-28
• 發明（設計）人: 張鵬鵬;張順;鄭小虎;鄭澤奇
• 申請（專利權）人: 中國銀行股份有限公司
• 主分類號: G06F16/23
• 分類號: G06F16/23;G06F16/2455
• 代理公司: 北京三友知識產權代理有限公司 11127
• 代理人: 谷敬麗;薛平

本發明公開了一種基于數據庫Binlog的分布式緩存更新方法及裝置，涉及分布式系統技術領域，其中該方法包括：監聽Binlog日志文件并讀取日志文件內容；所述日志文件內容中包括數據庫中間件在數據發生變更時記錄到Binlog日志文件的內容；從日志文件內容中檢測出發生變更的數據；從發生變更的數據中篩選出變更的熱點數據，將變更的熱點數據寫入到分布式緩存中。本發明可以實現數據庫中間件存儲的熱點數據與分布式緩存存儲的熱點數據一致，提升了分布式緩存數據更新的時效性。

技術領域

本發明涉及分布式系統技術領域，尤其涉及一種基于數據庫Binlog的分布式緩存更新方法及裝置。

背景技術

本部分旨在為權利要求書中陳述的本發明實施例提供背景或上下文。此處的描述不因為包括在本部分中就承認是現有技術。

熱點數據通常保存在數據庫中間件中，避免數據丟失，但因數據庫中間件性能無法滿足熱點數據高并發讀寫的需求，業內常規做法是將熱點數據從數據庫中間件同步到分布式緩存中，熱點數據讀寫過程如下：

1)在獲取熱點數據時，優先從分布式緩存中獲取，如果獲取到熱點數據時則結束，否則進行下一步；

2)從數據庫中間件中獲取熱點數據；

3)將數據庫中獲取的熱點數據寫到分布式緩存中，同時設置一個過期時間，在過期時間之前熱點數據獲取均從分布式緩存中獲取，過期時間之后再重復1-3步驟。

從上面獲取熱點數據的流程可以看出，分布式緩存不具備自動更新數據的能力，即無法感知數據庫中間件數據的變更，導致數據庫中間件存儲的熱點數據與分布式緩存存儲的熱點數據不一致。

發明內容

本發明實施例提供一種基于數據庫Binlog的分布式緩存更新方法，用以實現數據庫中間件存儲的熱點數據與分布式緩存存儲的熱點數據一致，該方法包括：

監聽Binlog日志文件并讀取日志文件內容；所述日志文件內容中包括數據庫中間件在數據發生變更時記錄到Binlog日志文件的內容；

從日志文件內容中檢測出發生變更的數據；

從發生變更的數據中篩選出變更的熱點數據，將變更的熱點數據寫入到分布式緩存中。

本發明實施例還提供一種基于數據庫Binlog的分布式緩存更新裝置，用以實現數據庫中間件存儲的熱點數據與分布式緩存存儲的熱點數據一致，該裝置包括：

數據庫中間件Binlog監聽單元，用于監聽Binlog日志文件并讀取日志文件內容；所述日志文件內容中包括數據庫中間件在數據發生變更時記錄到Binlog日志文件的內容；

日志文件解析單元，用于從日志文件內容中檢測出發生變更的數據；

分布式緩存數據寫入單元，用于從發生變更的數據中篩選出變更的熱點數據，將變更的熱點數據寫入到分布式緩存中。

本發明實施例還提供一種計算機設備，包括存儲器、處理器及存儲在存儲器上并可在處理器上運行的計算機程序，所述處理器執行所述計算機程序時實現上述基于數據庫Binlog的分布式緩存更新方法。

本發明實施例還提供一種計算機可讀存儲介質，所述計算機可讀存儲介質存儲有執行上述基于數據庫Binlog的分布式緩存更新方法的計算機程序。

本發明實施例中，基于數據庫Binlog的分布式緩存更新方案，通過：監聽Binlog日志文件并讀取日志文件內容；所述日志文件內容中包括數據庫中間件在數據發生變更時記錄到Binlog日志文件的內容；從日志文件內容中檢測出發生變更的數據；從發生變更的數據中篩選出變更的熱點數據，將變更的熱點數據寫入到分布式緩存中，可以實現數據庫中間件存儲的熱點數據與分布式緩存存儲的熱點數據一致，提升了分布式緩存數據更新的時效性。

附圖說明