跳到主要内容
极客日志极客日志面向AI+效率的开发者社区
首页博客我的书AI学习GitHub 精选镜像AI 生图工具UI配色美学关于
搜索内容 / 工具 / 仓库 / 镜像...⌘K搜索
注册
博客列表
Javajava算法

MySQL 与 Redis 如何保证双写一致性

探讨了分布式系统中 MySQL 与 Redis 双写一致性的问题及解决方案。核心观点是强一致性代价高,通常追求最终一致性。介绍了 Cache-Aside(旁路缓存)、Write-Through(穿透读写)、Write-Behind(异步写回)三种模式。针对 Cache-Aside 的并发风险,提出了延迟双删、消息队列异步删除以及基于 Binlog 同步的进阶方案。建议大多数场景首选 Cache-Aside 配合删除缓存,对一致性要求高或业务规模大时采用 Binlog 同步方案,并务必设置缓存过期时间作为兜底。

信号故障发布于 2026/3/29更新于 2026/9/1159 浏览
MySQL 与 Redis 如何保证双写一致性

MySQL 与 Redis 如何保证双写一致性

前言

在分布式环境下,要实现强一致性(在任何时刻读取的数据都是最新的)是极其困难且代价高昂的,通常会严重牺牲性能。因此,在实践中,我们通常追求最终一致性,即允许在短暂的时间内数据不一致,但通过一些手段保证数据最终会保持一致。

一、基础概念:为什么会有不一致?

在一个包含 MySQL(作为可靠数据源)和 Redis(作为缓存)的系统中,所有的写操作(增、删、改)都必须同时处理这两个地方。

文章配图

这个过程中,任何一步失败或延迟都会导致不一致:

  1. 写 MySQL 成功,写 Redis 失败:导致 Redis 中是旧数据。
  2. 写 Redis 成功,写 MySQL 失败:导致 Redis 中是'脏数据',数据库中不存在。
  3. 并发读写:一个线程在更新数据库,但还没更新缓存时,另一个线程读取了旧的缓存数据。

二、核心策略与模式

解决双写一致性有多种策略,我们需要根据业务场景(对一致性的要求、读写的比例等)进行选择。

策略一:Cache-Aside Pattern(旁路缓存模式)

这是最常用、最经典的缓存模式。核心原则是:应用程序直接与数据库和缓存交互,缓存不作为写入的必经之路。

  • 读流程:

    1. 收到读请求。
    2. 首先查询 Redis,如果数据存在(缓存命中),直接返回。
    3. 如果 Redis 中没有数据(缓存未命中),则从 MySQL 中查询。
    4. 将从 MySQL 查询到的数据写入 Redis(以便后续读取),然后返回数据。
  • 写流程:

    1. 收到写请求。
    2. 更新 MySQL 中的数据。
    3. 删除 Redis 中对应的缓存。

为什么是删除(Invalidate)缓存,而不是更新缓存? 这是一个关键设计点!

  • 性能:如果更新缓存,每次数据库写操作都要伴随一次缓存写操作,如果该数据并不经常被读取,那么这次缓存写入就是浪费资源的。
  • 并发安全:在并发写场景下,更新缓存的顺序可能与更新数据库的顺序不一致,导致缓存中是旧数据。而删除操作是幂等的,更为安全。

Cache-Aside 如何保证一致性? 它通过'先更新数据库,再删除缓存'来尽力保证。但它依然存在不一致的窗口期:

  1. 线程 A 更新数据库。
  2. 线程 B 读取数据,发现缓存不存在,从数据库读取旧数据(因为 A 还没提交或刚提交)。
  3. 线程 B 将旧数据写入缓存。
  4. 线程 A 删除缓存。

这种情况发生的概率较低,因为通常数据库写操作(步骤 1)会比读操作(步骤 2)耗时更长(因为涉及锁、日志等),所以步骤 2 在步骤 1 之前完成的概率很小。但这是一种理论上的可能。

策略二:Write-Through / Read-Through Pattern(穿透读写模式)

在这种模式下,缓存层(或一个独立的服务)自己负责与数据库交互。对应用来说,它只与缓存交互。

  • 写流程:应用写入缓存,缓存组件写入数据库。只有两个都成功后才会返回成功。
同步地
  • 读流程:应用读取缓存,如果未命中,缓存组件自己从数据库加载并填充缓存,然后返回。
  • 优点:逻辑对应用透明,一致性比 Cache-Aside 更好。 缺点:性能较差,因为每次写操作都必然涉及一次数据库写入。通常需要成熟的缓存中间件支持。

    策略三:Write-Behind Pattern(异步写回模式)

    Write-Through 的异步版本。应用写入缓存后立即返回,缓存组件在之后某个时间点(例如攒够一批数据或定时)批量异步地更新到数据库。

    优点:写性能极高。 缺点:有数据丢失风险(缓存宕机),一致性最弱。适用于允许少量数据丢失的场景,如计数、点赞等。

    三、保证最终一致性的进阶方案

    为了弥补 Cache-Aside 模式中的缺陷,我们可以引入一些额外的机制。

    方案一:延迟双删

    针对 Cache-Aside 中提到的'先更新数据库,再删除缓存'可能带来的并发问题,可以引入一个延迟删除。

    1. 线程 A 更新数据库。
    2. 线程 A 删除缓存。
    3. 线程 A 休眠一个特定的时间(如 500ms - 1s)。
    4. 线程 A 再次删除缓存。

    第二次删除是为了清理掉在第 1 次删除后、其他线程可能写入的旧数据。这个休眠时间需要根据业务读写耗时来估算。

    优点:简单有效,能很大程度上解决并发读写导致的不一致。 缺点:降低了写入吞吐量,休眠时间难以精确设定。

    方案二:通过消息队列异步删除

    为了解耦和重试,可以将删除缓存的操作作为消息发送到消息队列(如 RocketMQ, Kafka)。

    1. 更新数据库。
    2. 向消息队列发送一条删除缓存的消息。
    3. 消费者消费该消息,执行删除 Redis 的操作。如果删除失败,消息会重试。

    这保证了删除缓存的操作至少会被执行一次,大大提高了可靠性。

    方案三:通过数据库 Binlog 同步(最优解)

    这是目前最成熟、对业务侵入性最小、一致性最好的方案。其核心是利用 MySQL 的二进制日志(Binlog)进行增量数据同步。

    工作原理:

    1. 业务系统正常写入 MySQL。
    2. 由一个中间件(如 Canal, Debezium)伪装成 MySQL 的从库,订阅 Binlog。
    3. 中间件解析 Binlog,获取数据的变更详情(增、删、改)。
    4. 中间件根据变更,调用 Redis 的 API 来更新或删除对应的缓存。

    文章配图

    优点:

    • 业务无侵入:业务代码只关心写数据库,完全不知道缓存的存在。
    • 高性能:数据库和缓存的同步是异步的,不影响主业务链路的性能。
    • 强保证:由于基于 Binlog,它能保证只要数据库变了,缓存最终一定会被同步。顺序也与数据库一致。

    缺点:

    • 架构复杂,需要维护额外的同步组件。
    • 同步有毫秒级到秒级的延迟。

    四、总结与最佳实践选择

    策略一致性保证性能复杂度适用场景
    Cache-Aside + 删除最终一致性(有微弱不一致风险)高低绝大多数场景的首选,读多写少
    Cache-Aside + 延迟双删更好的最终一致性中低对一致性要求稍高,且能接受一定延迟的写操作
    Write-Through强一致性中中写多读少,且对一致性要求非常高的场景
    Binlog 同步最终一致性(推荐)高高大型、高要求项目的最佳实践,对业务无侵入

    通用建议:

    1. 首选方案:对于大多数应用,从 Cache-Aside(先更新数据库,再删除缓存) 开始。它简单、有效,在大多数情况下已经足够。
    2. 进阶保障:如果 Cache-Aside 的不一致窗口无法接受,可以引入延迟双删或消息队列异步删除来增强。
    3. 终极方案:当业务发展到一定规模,对一致性和系统解耦有更高要求时,投入资源搭建基于 Binlog 的异步同步方案。这是业界证明最可靠的方案。
    4. 设置合理的过期时间:无论如何,都给 Redis 中的缓存设置一个过期时间(TTL)。这是一个安全网,即使同步逻辑出现问题,旧数据也会自动失效,最终从数据库加载新数据,保证最终一致性。
    5. 业务容忍度:最重要的是,与产品经理确认业务对一致性的容忍度。很多时候,1-2 秒内的数据不一致用户是感知不到的,不需要为此付出巨大的架构和性能代价。

    目录

    1. MySQL 与 Redis 如何保证双写一致性
    2. 前言
    3. 一、基础概念:为什么会有不一致?
    4. 二、核心策略与模式
    5. 策略一:Cache-Aside Pattern(旁路缓存模式)
    6. 策略二:Write-Through / Read-Through Pattern(穿透读写模式)
    7. 策略三:Write-Behind Pattern(异步写回模式)
    8. 三、保证最终一致性的进阶方案
    9. 方案一:延迟双删
    10. 方案二:通过消息队列异步删除
    11. 方案三:通过数据库 Binlog 同步(最优解)
    12. 四、总结与最佳实践选择

    更多推荐文章

    查看全部
    • Stable Yogi 皮衣穿搭工具:生成历史保存与本地图片批量导出
    • Django 基于 Echarts+Python 的图书零售监测系统设计与实现
    • SpringBoot 核心模块 Java 源码规模统计
    • LLaMA Factory 微调古汉语特化大模型
    • 基于 Next.js 和 Wagmi 构建支持 TokenP 钱包登录的 DApp 前端
    • OpenClaw 安装与飞书机器人配置实战指南
    • VSCode 扩展工具 Copilot MCP 使用教程
    • Python GUI 可视化设计工具 tkinter-helper 介绍
    • LangChain 0.2 构建 RAG 应用
    • MCP 协议详解:与 Function Call 的区别及使用方式
    • Python Flask 实战:将本地学生成绩系统升级为在线 Web 应用
    • 大模型的起源、现状与未来趋势解析
    • ABB 机器人虚拟示教器基础操作与编程指南
    • AI 产品经理成长指南:核心能力与实战学习路线
    • Web Worker:前端多线程的隐形引擎
    • Moltbot:让 Claude 从聊天工具转变为可落地 AI Bot
    • Windows WSL Ubuntu 部署 OpenClaw 接入飞书与百炼模型实战
    • Python 与 PyCharm 虚拟环境搭建及实战指南
    • 鸣潮 QQ 机器人部署指南:集成大语言模型与游戏功能
    • C++大模型 SDK 开发:SSE 流式协议解析与 httplib 实现原理

    相关免费在线工具

    • Keycode 信息

      查找任何按下的键的javascript键代码、代码、位置和修饰符。 在线工具,Keycode 信息在线工具,online

    • Escape 与 Native 编解码

      JavaScript 字符串转义/反转义;Java 风格 \uXXXX(Native2Ascii)编码与解码。 在线工具,Escape 与 Native 编解码在线工具,online

    • JavaScript / HTML 格式化

      使用 Prettier 在浏览器内格式化 JavaScript 或 HTML 片段。 在线工具,JavaScript / HTML 格式化在线工具,online

    • JavaScript 压缩与混淆

      Terser 压缩、变量名混淆,或 javascript-obfuscator 高强度混淆(体积会增大)。 在线工具,JavaScript 压缩与混淆在线工具,online

    • 加密/解密文本

      使用加密算法(如AES、TripleDES、Rabbit或RC4)加密和解密文本明文。 在线工具,加密/解密文本在线工具,online

    • Gemini 图片去水印

      基于开源反向 Alpha 混合算法去除 Gemini/Nano Banana 图片水印,支持批量处理与下载。 在线工具,Gemini 图片去水印在线工具,online