在现代互联网应用中,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;本文就来详细了解一下物理服务器。 物理服务…