如何保證數據庫與 Redis 緩存的一致性?

在現代互聯網應用中,Redis 緩存幾乎是性能優化的標配。但在使用過程中,一個繞不過去的問題就是:

如何保證 Redis 緩存與數據庫之間的數據一致性?

特別是在高并發場景下,讀寫操作錯位可能導致緩存中出現臟數據,影響業務正確性。

問題背景

我們通常使用 Cache Aside 模式(旁路緩存):

  • :先查緩存,沒有再查數據庫并寫入緩存

  • :更新數據庫,再刪除緩存

這個寫入邏輯看似合理,但卻存在很多坑。一不小心就會導致“緩存臟讀”或“數據回滾”的問題。

方案一:先更新數據庫,再刪除緩存

這是很多開發者最初采用的方式。

🧠 原理:

updateDB(key, newValue)
deleteCache(key)

邏輯非常簡單:先改數據庫,再刪緩存,期待下次讀取會重新從數據庫加載正確數據。

🖼? 圖解:

用戶請求更新數據|
[1] 更新數據庫 (新數據寫入)|
[2] 刪除 Redis 緩存

? 存在問題:

并發場景:
[1] updateDB(key, newValue)    ? 更新成功
[2] deleteCache(key)           ? 失敗,緩存未清除隨后:
[3] 用戶查詢 getCache(key)    → 命中舊緩存 ?

    結果是:

    • 數據庫中是新值

    • 緩存中是舊值,長時間存在

    • 系統返回的是錯誤的數據

    方案二:先刪除緩存,再更新數據庫

    🧠 原理:

    deleteCache(key)
    updateDB(key, newValue)
    

    🖼? 圖解:

    用戶請求更新數據|
    [1] 刪除 Redis 緩存|
    [2] 更新數據庫
    

    ? 存在問題:

    并發場景:
    Time ---------->
    A: deleteCache(new) -------->
    B: getCache(old) ------------>
    B: writeCache(old) ------------>
    A: updateDb() ---------------->
    
    • 線程 A 刪除緩存, 并在之后更新數據庫;

    • 線程 B 在 A 刪除緩存之前讀取了舊緩存,隨后把舊值寫回緩存;

    • 最終緩存中是 舊數據,數據庫是新數據 → ? 數據不一致!

    方案三:延遲雙刪(延遲兜底)

    延遲雙刪(Delayed Double Delete)是對Cache Aside模式的增強,通過兩次刪除緩存操作來減少不一致時間窗口。

    實現步驟

    1. 第一次刪除:在更新數據庫前,先刪除緩存
    2. 更新數據庫:執行實際的數據庫更新操作
    3. 延遲第二次刪除:在數據庫更新完成后,延遲一段時間再次刪除緩存

    public void updateData(Data newData) {// 第一次刪除緩存cache.delete(newData.getId());// 更新數據庫database.update(newData);// 延遲第二次刪除executor.schedule(() -> {cache.delete(newData.getId());}, 500, TimeUnit.MILLISECONDS); // 延遲500ms
    }

    為什么需要延遲

    延遲的目的是為了處理以下場景:
    1. 在第一次刪除后、數據庫更新完成前,可能有請求讀取了舊數據并重新填充緩存
    2. 數據庫主從復制延遲可能導致從庫讀取到舊數據

    通過延遲第二次刪除,可以清除這些潛在的不一致情況。

    延遲時間如何確定

    延遲時間應考慮:
    - 數據庫主從復制延遲時間(通常100-500ms)
    - 業務對一致性的要求程度
    - 系統負載情況

    延遲雙刪的優化與變種

    異步重試機制

    當第二次刪除失敗時,可以采用異步重試機制確保最終一致性:
    ?

    public void deleteWithRetry(String key, int maxRetries) {int retries = 0;while (retries < maxRetries) {try {cache.delete(key);break;} catch (Exception e) {retries++;if (retries >= maxRetries) {// 記錄失敗日志或放入死信隊列log.error("Failed to delete cache after {} retries", maxRetries);break;}Thread.sleep(100 * retries); // 指數退避}}
    }

    方案四:分布式鎖(強一致)

    🧠 原理:

    lock(key)
    deleteCache(key)
    updateDB(key)
    unlock(key)
    

    🖼? 圖解:

    用戶請求更新數據|
    [1] 獲取分布式鎖|
    [2] 刪除緩存|
    [3] 更新數據庫|
    [4] 釋放鎖
    

    ? 優點:

    • 寫操作串行化,強一致;

    • 不會發生并發導致的數據回滾。

    ? 缺點:

    • 實現復雜;

    • 性能開銷大,需保證鎖系統高可用。

    方案五:監聽 Binlog 回刷緩存(如使用 Canal)

    🧠 原理:

    MySQL 更新數據↓
    產生 Binlog↓
    Canal 監聽變更事件↓
    主動刪除或刷新緩存
    

    🖼? 圖解:

    數據庫更新|
    [1] 生成 Binlog|
    [2] Canal 監聽 Binlog|
    [3] 刪除/刷新 Redis 緩存
    

    ? 優點:

    • 非侵入式,一致性強;

    • 精準捕獲變化,自動驅動緩存刷新。

    ? 缺點:

    • 運維成本高;

    • 延遲取決于 Canal 拉取速度。

    各方案對比總結

    方案是否一致并發安全實現復雜度備注
    先更新 DB 再刪緩存? 否簡單常見誤區,不能用
    先刪緩存再更新 DB?? 部分一定程度簡單可配合延遲雙刪使用
    延遲雙刪? 最終一致較高簡單推薦大部分場景
    分布式鎖? 強一致中等對性能影響較大
    Binlog + Canal 回刷緩存? 強一致推薦核心數據系統使用

    總結

    Redis 緩存作為提升系統性能的利器,也帶來了“一致性”的挑戰。掌握各種一致性方案,能讓你在面對不同業務需求時游刃有余。

    🔑 核心思想是:避免緩存與數據庫數據錯位時被讀取或誤寫回緩存。

    本文來自互聯網用戶投稿,該文觀點僅代表作者本人,不代表本站立場。本站僅提供信息存儲空間服務,不擁有所有權,不承擔相關法律責任。
    如若轉載,請注明出處:http://www.pswp.cn/pingmian/86792.shtml
    繁體地址,請注明出處:http://hk.pswp.cn/pingmian/86792.shtml
    英文地址,請注明出處:http://en.pswp.cn/pingmian/86792.shtml

    如若內容造成侵權/違法違規/事實不符,請聯系多彩編程網進行投訴反饋email:809451989@qq.com,一經查實,立即刪除!

    相關文章

    現代 JavaScript (ES6+) 入門到實戰(三):字符串與對象的魔法升級—模板字符串/結構賦值/展開運算符

    在前兩篇&#xff0c;我們升級了變量和函數。今天&#xff0c;我們要給 JavaScript 中最常用的兩種數據類型——字符串&#xff08;String&#xff09;和對象&#xff08;Object&#xff09;——裝備上 ES6 帶來的強大魔法。 準備好告別丑陋的 號拼接和重復的對象屬性賦值了嗎…

    GitLab 備份恢復與配置遷移詳盡教程(實戰版)

    &#x1f6e0; GitLab 備份恢復與配置遷移詳盡教程&#xff08;實戰版&#xff09; &#x1f9f1; 一、環境準備 1.1 檢查版本一致性 恢復目標機 GitLab 版本必須與備份文件所用版本一致或兼容&#xff08;推薦相同版本&#xff09; 查看當前 GitLab 版本&#xff1a; sudo g…

    英飛凌高性能BMS解決方案助力汽車電動化

    隨著電動汽車越來越被大眾接受&#xff0c;車輛電氣化、智能化程度越來越高&#xff0c;如何提高電動汽車的續航里程&#xff0c;同時保障車輛安全可靠持久運行是當前最主要的技術難題之一。而先進的電池管理系統 (BMS)有助于克服電動汽車廣泛普及的關鍵障礙&#xff1a;續航里…

    react + ant-design實現數字對比動畫效果:當新獲取的數字比之前展示的數字多或少2時,顯示“+2”或“-2”的動畫效果

    react ant-design實現數字對比動畫效果&#xff1a;當新獲取的數字比之前展示的數字多或少2時&#xff0c;顯示“2”或“-2”的動畫效果 1. 創建獨立的 AnimatedValue 組件 // components/AnimatedValue/index.jsx import React, { useState, useEffect, useRef } from reac…

    自動化測試--Appium和ADB及常用指令

    1.Appium Appium工具庫&#xff1a; appium server&#xff1a;服務器&#xff08;類似于瀏覽器的驅動&#xff09;&#xff0c;核心進行客戶端命令的接受&#xff0c;完成設備的自動化指令 appium client&#xff1a;客戶端&#xff0c;讓代碼進行調用&#xff0c;發送自動化的…

    2025.6.29總結

    有一點我很好奇&#xff0c;工作后&#xff0c;我該拿什么去衡量自己的進步呢&#xff1f; 在我的大學四年&#xff0c;確實有個量化的標準&#xff0c;讀了多少本書&#xff0c;寫了多少篇總結&#xff0c;多少篇技術博客&#xff0c;多少行代碼&#xff0c;運動了多少公里&a…

    Docker 部署 Kong云原生API網關

    Docker 部署 Kong云原生API網關 本指南提供了在 Docker Compose 上配置 Kong Gateway 的步驟&#xff0c;基于有數據庫模式的配置。本指南中使用的數據庫是 PostgreSQL。 前置條件 準備一臺Ubuntu服務器&#xff1a; 節點IP: 192.168.73.11操作系統&#xff1a; Ubuntu 24…

    深度剖析 Apache Pulsar:架構、優勢與選型指南

    Apache Pulsar 是一款云原生分布式消息流平臺&#xff0c;融合了消息隊列、流處理和存儲能力&#xff0c;采用獨特的“存儲計算分離”架構&#xff08;Broker 無狀態 BookKeeper 持久化存儲&#xff09;。以下從核心特性、對比優勢及適用場景展開分析&#xff1a; 一、Pulsar…

    java 導出word 實現循環表格

    如果是固定的值 用 {{}} 即可 但是如果是循環表格&#xff0c;那么就需要制定模板為如圖 然后在處理表格數據時候&#xff1a; /*** 傳入 節點對象 返回生成的word文檔* param flangeJoint* return* throws IOException*/private XWPFTemplate getXwpfTemplate(CmComplaintEn…

    XIP (eXecute In Place)

    NOR Flash 能直接執行代碼(XIP)而 NAND Flash 不能,根本原因在于它們的物理結構和訪問接口存在本質區別。下面用技術原理 + 現實比喻幫你徹底理解: 1. XIP 是什么? XIP (eXecute In Place) 指代碼不需要從存儲介質復制到 RAM,而是 CPU 直接從存儲介質(如 Flash)中讀取…

    【android bluetooth 協議分析 10】【AVRCP詳解1】【PlaybackStateCompat類如何查看】

    1. 問題 android/app/src/com/android/bluetooth/avrcpcontroller/AvrcpControllerService.java import android.support.v4.media.MediaBrowserCompat.MediaItem; import android.support.v4.media.session.PlaybackStateCompat;private int toPlaybackStateFromJni(int fro…

    【AI學習從零至壹】LLM模型prompt開發及?模型應?

    LLM模型prompt開發及?模型應? ?語?模型 LLM如何構建?個AI對話系統關于模型的訓練 ollama調?LLM模型設置API KEY測試一個對話 prompt提示詞提示詞結構特征提示詞的五大核心價值1. 信息傳遞的精準性2. 輸出質量的可控性3. 用戶意圖的對?性4. 復雜任務的拆解性5. 倫理?險的…

    ubuntu20.04如何給appImage創建快捷方式

    ubuntu20.04如何給appImage創建快捷方式 1. 確保AppImage是可執行的 chmod x /path/to/your/appimage2. 創建.desktop文件 在~/.local/share/applications/目錄下創建一個新的 .desktop 文件&#xff1a; vi ~/.local/share/applications/your-appname.desktop添加以下內容…

    RT-Thread 詳解:國產開源實時操作系統

    一、RT-Thread 概述 定義&#xff1a;RT-Thread 是中國自主研發的開源實時操作系統&#xff08;RTOS&#xff09;&#xff0c;兼具實時性與物聯網&#xff08;IoT&#xff09;特性&#xff0c;支持從資源受限的 MCU&#xff08;如 STM32、ESP32&#xff09;到高性能處理器&…

    Wan2 1-VACE

    簡介 VACE是阿里新開源的視頻編輯/生成框架&#xff0c;號稱能夠執行任意的視頻編輯/生成。總體而言&#xff0c;該模型在整體結構上并沒有太大改變&#xff0c;僅僅是在原Wan2.1模型的基礎上&#xff0c;加了一個接受mask和視頻輸入的controlnet而已。但是這篇文章認為&#…

    基于 opencv+yolov8+easyocr的車牌追蹤識別

    &#xff08;本項目所有代碼打包至我的資源中&#xff0c;大家可在我的文章底部選擇下載&#xff09; 目錄 需求 實現效果 學習視頻 大致思路 代碼實現 資源下載 需求 通過車輛識別技術&#xff0c;識別視頻中每個車輛及其車牌號&#xff0c;車輛應進行追蹤&#xff0c;避免重復…

    sqlserver函數與過程(二)

    過程 SQLserver 過程是具有特定功能&#xff0c;可多次對數據表操作的獨立模塊。返回值通常用return 返回整數 0&#xff0c;1…。(可選&#xff09;也可通過output 參數或select 語句返回結果集。 1.過程的定義 本過程定義了一個過程&#xff0c;輸入一個動態SQL語句&#…

    OpenCV學習3

    1、創建圖像窗口滑動條 OpenCV 4中通過createTrackbar()函數在顯示圖像的窗口上創建滑動條。 int cv::createTrackbar(const String &trackbarname,const String &winname, int *value, int count, TrackbarCallback onChange 0, void *us…

    SRS流媒體服務器之本地測試rtc推流bug

    SRS環境版本 commit 44f0c36b61bc7c3a1d51cb60be0ec184c840f09d Author: winlin <winlinvip.126.com> Date: Wed Aug 2 10:34:41 2023 0800 Release v4.0-r5, 4.0 release5, v4.0.271, 145574 lines. bug1: 無法推流 WebRTC推流必須是HTTPS或者localhost&#xff1a;Ht…

    物理服務器是指的什么?作用有哪些?-哈爾濱云前沿

    物理服務器是一種基于傳統硬件架構構建的服務器&#xff0c;物理服務器是具有處理器、硬盤和網絡接口等硬件組件的獨立服務器&#xff0c;可以用于托管和存儲數據服務&#xff0c;&#xff0c;是計算機網絡的核心組件之一&#xff0c;本文就來詳細了解一下物理服務器。 物理服務…