1. 从一次线上事故说起缓存与数据库不一致的代价那天晚上十一点报警群突然炸了。运营同事反馈后台显示某个热门商品的库存明明还有几百件但用户在前端下单时却频频提示“库存不足”。技术团队紧急介入排查发现商品详情页的库存数据是从Redis缓存中读取的而这个缓存值已经十几个小时没有更新了数据库里的真实库存早已售罄。一次简单的促销活动因为缓存与数据库的数据不一致直接导致了大量用户下单失败、投诉激增最终以运营手动补偿优惠券、技术连夜修复告终。这个事故的根源就是我们今天要深入探讨的核心问题如何保证缓存和数据库的一致性。这绝不是个例。只要你的系统引入了缓存无论是Redis、Memcached这类分布式缓存还是Caffeine、Guava Cache这类本地缓存就必然会面临“双写”带来的数据一致性问题。缓存是为了追求极致的读取性能用空间换时间数据库则是数据的持久化权威存储。当一份数据有两个副本缓存和DB时任何更新操作都必须考虑先更新谁、后更新谁以及失败后如何处理。处理不当轻则出现短时间的脏数据重则像我们遇到的引发业务逻辑错误和资损。网上关于这个问题的讨论很多方案也五花八门从“先更新数据库再删除缓存”到各种复杂的异步补偿机制。但很多文章要么只讲理想情况要么给出的方案在并发场景下漏洞百出。这篇文章我将结合自己多年在电商、社交等高频场景下的实战和踩坑经验为你系统性地拆解缓存一致性的本质、主流方案的优缺点、高并发下的陷阱以及如何根据你的业务场景选择最合适的策略。我们的目标不是寻找一个“银弹”而是建立一套清晰的决策框架让你在面对具体问题时能做出最合理的选择。2. 理解一致性的本质我们到底在追求什么在深入方案之前我们必须先对齐认知什么是“一致性”在缓存语境下一致性通常不是指ACID中的“C”Consistency而是指“缓存数据与数据库数据在某个时间点或时间段内的吻合程度”。根据业务容忍度的不同我们可以将其分为几个层次强一致性任何时刻任何用户读取到的缓存数据都绝对等同于数据库中的最新数据。这通常意味着每次数据更新后都必须让缓存失效或同步更新并且在缓存更新完成前阻塞所有对该数据的读请求。这在分布式系统中实现成本极高往往会完全牺牲缓存带来的性能收益。最终一致性这是互联网业务中最常接受的一致性级别。它允许在数据更新后缓存与数据库存在一个短暂的不一致窗口期但保证在没有任何新的更新操作后经过一段时间所有副本的数据最终会达到一致的状态。我们的核心工作就是通过各种技术手段将这个“不一致窗口期”缩到最短并控制其影响范围。弱一致性系统不保证缓存数据何时会与数据库一致甚至不保证最终一定会一致。除非是某些对数据准确性要求极低的场景如文章阅读数的大致统计否则一般不会采用。对于绝大多数业务如用户信息、商品价格、库存等我们追求的都是最终一致性。我们的目标不是消除不一致而是管理不一致让它发生得尽可能少窗口期尽可能短并且在发生时有兜底和修复机制。明确了这一点我们才能心平气和地讨论下面的方案因为它们都是在性能与一致性之间寻找最佳平衡点。3. 经典双写策略剖析先更新数据库还是先操作缓存当需要更新一条数据时我们面临两个基本操作更新数据库DB和更新缓存Cache。它们的顺序组合构成了最基础的几种策略。让我们逐一分析并重点揭示在并发读写下隐藏的陷阱。3.1 策略一先更新缓存再更新数据库这个策略非常危险强烈不推荐。它的流程是更新缓存为新值。再更新数据库。问题在于如果步骤2更新数据库失败那么缓存中已经是脏数据新值而数据库还是旧值。后续所有的读请求都会命中这个错误的缓存且这个脏数据没有自动修复的机制除非缓存过期或被人为清除。数据就“永远”不一致了。因为数据库是我们的权威数据源任何以可能破坏权威数据源正确性的操作作为第一步的策略风险都极高。3.2 策略二先更新数据库再更新缓存这是很多人直觉上认为合理的做法先保证权威存储正确再同步缓存。流程为更新数据库为新值。更新缓存为新值。看起来没问题但在并发环境下会翻车。考虑如下时序线程A更新数据库将库存从100改为99。线程B更新数据库将库存从99改为98。线程B更新缓存缓存设置为98。线程A更新缓存缓存错误地设置为99。最终数据库库存是98而缓存却是更旧的99。问题根源在于“更新缓存”这个操作不是原子的且后发起的线程可能先完成。这在高并发写场景下必然会发生。注意即使你给缓存操作加锁也只能保证单个Key的更新序列化但无法解决上述“后发起的写请求先更新完缓存”的问题。锁能保证顺序执行但不能保证顺序完成。3.3 策略三先删除缓存再更新数据库Cache-Aside中的写策略这就是经典的Cache-Aside旁路缓存模式中的写操作。流程为删除缓存中的对应数据。更新数据库。这个策略避免了策略二中“更新缓存”的竞态条件因为它第一步执行的是删除del这是一个幂等操作。即使并发执行最终效果都是缓存被清空。但它引入了另一个经典问题缓存缺失旧数据回填。考虑如下时序线程A要更新数据先删除缓存。此时线程B来读取数据发现缓存缺失Cache Miss。线程B从数据库读取旧数据。线程B将读取到的旧数据回填到缓存。线程A完成数据库更新。结果数据库是新值缓存却被回填了旧值导致不一致。这个不一致会持续到缓存过期或下一次更新。虽然发生这个时序需要一定的条件读操作发生在删除缓存后、更新数据库前这个狭窄的时间窗口内但在高并发场景下这个窗口被击中的概率并不低。3.4 策略四先更新数据库再删除缓存推荐方案这是目前最主流、最被推荐的方案也被称为“Cache-Aside with Delayed Deletion”或“Facebook的论文方案”。流程为更新数据库为新值。删除缓存中的对应数据。为什么它更好让我们分析一下它可能出问题的场景场景缓存恰好自动失效。假设在更新之前缓存刚好过期了。线程A来读取数据发现缓存失效准备去数据库查。线程B来更新数据先更新了数据库然后删除了缓存此时缓存本就是空的删除无影响。线程A执行数据库查询读到了线程B更新后的新数据并将其回填到缓存。结果数据库是新值缓存也是新值状态一致。这是一个好结果。场景删除缓存失败。这是该策略最大的风险点。如果第二步删除缓存失败缓存里保留的就是旧数据。因此该策略必须配套一个健全的“删除重试机制”我们会在第5节详细讨论。对比策略三策略四将不一致的风险窗口从“更新数据库”期间可能较长转移到了“删除缓存”期间通常非常短。并且即使删除缓存失败我们面对的也是一个“旧缓存”问题而不是策略一中“永远错误的缓存”问题。旧缓存数据可以通过设置合理的TTL过期时间来最终修复为我们的重试机制争取了时间。结论在基础的同步双写策略中“先更新数据库再删除缓存”是综合来看最好的选择。它简单有效问题边界清晰即删除失败。我们后续的所有高级方案都是在这个基础之上针对其短板删除失败、缓存缺失回填旧数据进行加固和优化。4. 应对高并发挑战延时双删与读写锁的权衡“先更新数据库再删除缓存”策略在普通并发下表现良好但在超高并发场景下我们之前提到的“缓存缺失回填旧数据”问题虽然概率低仍可能发生。此外在数据库主从架构下如果读从库存在延迟还会导致另一个问题从库读到旧数据并回填缓存。为此业界衍生出一些增强方案。4.1 延时双删策略延时双删是一个“以空间换时间一致性”的补救性思路。它在“先更新数据库再删除缓存”的基础上增加了一次延迟的删除操作。基本流程第一次删除缓存可选目的是让后续读请求直接击穿到数据库降低旧数据回填概率。更新数据库。第二次删除缓存。等待一个短暂的时间例如几百毫秒到1秒。执行第三次删除缓存。为什么需要第三步的等待和删除它的目标是为了清除掉在“更新数据库”之后、“第二次删除缓存”之前可能被其他读请求回填到缓存中的旧数据。等待的时间需要大于“数据库主从同步延迟”与“一次读请求执行耗时查询DB回填Cache”之和。伪代码示例Javapublic void updateData(Key key, Value newValue) { // 1. 首次删除可选 cache.del(key); // 2. 更新数据库 db.update(key, newValue); // 3. 立即二次删除 cache.del(key); // 4. 提交一个延迟任务 delayQueue.add(new DelayTask(key, 1000)); // 延迟1秒 } // 延迟任务执行体 class DelayTask { public void run() { // 5. 延迟第三次删除 cache.del(key); } }延时双删的优缺点优点能有效缓解因主从延迟或并发读导致的短期不一致问题。缺点延迟等待降低了吞吐量写请求的响应时间增加了。延迟时间难以评估设置太短可能没效果设置太长则影响性能。这个时间需要根据实际系统压力和数据量动态评估甚至需要监控。并非银弹在极端高频的“写后立即读”场景下仍然可能有不一致窗口。我的实战建议延时双删适用于写操作不那么频繁但对一致性要求较高且存在主从延迟的场景。例如用户重要资料的修改。在实施时可以将延迟删除任务放入消息队列或线程池异步执行避免阻塞主流程。同时务必监控延迟任务的堆积情况。4.2 基于分布式锁的强一致性方案如果你追求的是强一致性或者业务场景完全无法容忍任何旧数据如金融账户余额那么就需要引入分布式锁将并发的读写操作串行化。基本流程以写优先为例写请求到来针对该数据键Key获取一个分布式锁。获取锁后执行“更新数据库再删除缓存”。释放锁。读请求到来同样尝试获取该键的分布式锁。如果获取成功说明没有正在进行的写操作则查询缓存若缓存不存在则查数据库并回填。如果获取失败说明有写操作正在进行则可以选择阻塞等待直到获取锁或者直接读数据库牺牲一些性能保证强一致。优缺点优点实现了强一致性逻辑清晰。缺点性能损耗巨大分布式锁的获取、释放本身就是开销更重要的是它将并发操作串行化完全牺牲了缓存的高并发读优势。这相当于用缓存的价格复杂度买到了数据库的性能串行。复杂度高需要引入和维护分布式锁组件如Redis Redlock、ZooKeeper并妥善处理锁超时、死锁等问题。可用性风险锁服务如果出现故障会影响所有相关读写操作。注意在99%的业务场景下为缓存一致性引入分布式锁都是过度设计。它带来的性能下降和复杂度提升往往远超数据短暂不一致带来的业务风险。请务必谨慎评估。选型决策参考场景特征推荐策略原因读多写少容忍秒级不一致先更新数据库再删除缓存简单可靠配合TTL和重试能满足大部分场景。写后读频繁存在主从延迟延时双删针对性解决主从延迟和并发读回填问题。写操作极其频繁如秒杀库存考虑直接操作数据库或采用更复杂队列此时缓存更新可能成为瓶颈需重新评估缓存价值。金融、交易等强一致场景分布式锁或直接弃用缓存业务要求压倒一切性能成为次要考虑。5. 确保操作可靠性重试机制与异步补偿无论选择哪种策略都必须面对一个现实网络和服务不是100%可靠的。“更新数据库”或“删除缓存”都可能失败。对于“先更新数据库再删除缓存”这个推荐策略我们必须保证“删除缓存”这一步最终能成功否则就会留下脏数据。这就需要一套健全的失败重试与异步补偿机制。5.1 同步重试的陷阱最简单的想法是在应用代码里进行同步重试public void updateWithRetry(Key key, Value value) { db.update(key, value); int maxRetries 3; for (int i 0; i maxRetries; i) { try { cache.del(key); break; // 成功则退出 } catch (Exception e) { if (i maxRetries - 1) { throw new RuntimeException(删除缓存最终失败, e); } Thread.sleep(100 * (i 1)); // 延迟递增 } } }这非常糟糕。首先它阻塞了用户请求增加了响应时间。其次如果重试多次后仍然失败你是抛出异常导致整个更新事务回滚还是放任缓存不一致前者影响主流程后者导致数据错误。同步重试不可取。5.2 基于消息队列的异步重试正确的做法是将“删除缓存”这个动作异步化、解耦。最成熟的方案是借助消息队列。流程应用服务在事务内更新数据库。在事务提交后立即向消息队列发送一条“删除缓存”的消息。这一步必须确保成功通常与数据库事务绑定如本地消息表或使用支持事务的消息队列如RocketMQ。一个独立的“缓存删除消费者”服务监听队列消费消息并执行删除操作。如果消费者删除成功则确认消息。如果消费者删除失败网络抖动、Redis故障消息队列会根据重试策略如指数退避重新投递这条消息直到成功。优势解耦主流程写DB不受缓存删除成功与否的影响响应快。可靠消息队列保证了消息的持久化和至少一次投递At Least Once只要消费者逻辑幂等就能保证最终删除。削峰即使短时间内有大量更新消息队列也能缓冲避免压垮缓存服务。技术选型参考RocketMQ支持事务消息可以很好地保证“DB事务提交”和“发送删除消息”的原子性。Kafka高吞吐但需要自行实现类似“事务”的语义如两阶段提交配合本地事务表。Redis Streams如果缓存本身就是Redis可以用其自带的Streams作为轻量级队列。5.3 基于数据库日志Binlog的异步淘汰这是另一个非常优雅且解耦彻底的方案不依赖于业务代码发送消息而是通过监听数据库的变更日志来触发缓存删除。以MySQL Canal Redis为例的流程业务代码只需更新数据库完全不用关心缓存。MySQL 的 Binlog 会记录所有数据变更。Canal一个阿里开源的数据库增量日志解析组件伪装成MySQL的从库实时订阅并解析Binlog。Canal 将解析出的数据变更表名、主键、操作类型发送给消息队列如RocketMQ/Kafka。一个独立的缓存清理服务消费这些消息根据“表名主键”的规则去删除Redis中对应的缓存。优势彻底解耦业务代码零侵入缓存维护成为独立的基础设施。通用性强无论业务逻辑如何变化只要数据库有变更缓存就能被同步清理。这对于遗留系统改造尤其友好。保证顺序Binlog本身是有序的可以保证缓存清理的顺序与数据库变更顺序一致对于某些顺序敏感的场景很重要。挑战架构复杂度引入了Canal、消息队列、消费者服务等多个组件运维成本增加。延迟从DB变更到缓存清理整个链路的延迟比直接删除要高通常在毫秒到百毫秒级需要监控。消息过滤需要仔细设计规则避免误删或漏删缓存。方案对比表特性业务代码同步删除消息队列异步重试Binlog异步淘汰可靠性低失败即不一致高依赖消息队列可靠性极高依赖Binlog和消息队列性能影响高阻塞主流程低异步化无业务代码无感知架构复杂度低中高实时性实时近实时取决于队列消费速度近实时取决于Binlog解析和消费速度适用场景对一致性要求不高的简单应用绝大多数分布式应用大型复杂系统微服务架构需要统一缓存治理6. 特殊场景与进阶考量缓存模式与数据分片除了通用的双写策略在一些特殊场景下我们需要采用不同的缓存模式或者对一致性有更精细化的控制。6.1 Write-Through 与 Write-Behind 模式我们之前讨论的Cache-Aside是“懒加载”模式由应用代码主动管理缓存。还有两种由缓存组件本身管理的模式Write-Through直写应用将数据写入缓存缓存组件同步地将数据写入数据库然后才返回成功。一致性最好写操作完成时缓存和数据库都是最新的。性能最差每次写都有数据库IO。适用场景写操作很少但对一致性要求极高的场景。很多本地缓存如Caffeine的CacheWriter接口可以实现此模式。Write-Behind写回应用将数据写入缓存缓存组件立即返回成功。随后缓存组件异步地、批量地将数据更新到数据库。一致性最弱存在数据丢失风险缓存宕机。性能最好写操作极快。适用场景写入吞吐量极大且能容忍一定数据丢失的场景如点击流、日志收集。需要缓存组件支持如某些商业版Redis模块。对于大多数业务系统Cache-Aside在灵活性和性能上取得了最佳平衡因此最为流行。6.2 针对热点Key与大数据量的策略热点Key更新对于像“秒杀库存”这样的热点Key频繁的“更新DB删除Cache”操作本身可能成为瓶颈甚至引发缓存击穿大量请求在缓存删除瞬间同时涌向数据库。策略可以考虑在缓存层面进行原子递减如Redis的DECR然后异步同步到数据库。这实际上将数据库降级为“备份存储”牺牲了一定的一致性异步同步延迟来换取极高的并发处理能力。这需要非常精细的业务容忍度评估和补偿对账机制。大Value或复杂结构更新如果缓存的是一个庞大的JSON对象或聚合数据每次更新都删除整个缓存可能浪费带宽且重新构建缓存开销大。策略可以考虑使用Hash结构存储只更新或删除发生变化的字段。或者采用版本号Version机制更新数据时生成新版本号写入DB并让缓存Key包含版本号。读请求时先查最新版本号再用版本化Key去查缓存。这样旧版本的缓存数据可以自然淘汰实现了更细粒度的更新。6.3 缓存与数据库的事务协调在分布式系统中更新数据库和操作缓存可能涉及分布式事务问题。例如一个业务需要更新两个数据库记录并清理对应的两个缓存如何保证这四个操作的整体一致性刚性方案引入Seata等分布式事务框架将缓存操作纳入分布式事务管理。代价是性能损耗巨大复杂度高通常不推荐。柔性方案最终一致性这是更主流的选择。可以采用“本地消息表”或“事务消息”模式。在数据库事务中将要清理的缓存Key记录到一张本地消息表。事务提交后一个后台任务扫描这张表将消息发送到MQ由消费者清理缓存。或者使用RocketMQ的事务消息在DB事务提交前后进行消息的发送和确认。核心思想是保证DB事务与“发送缓存清理消息”这个动作的原子性而缓存清理本身通过MQ的重试机制保证最终成功。7. 实战中的经验、监控与兜底理论方案最终要落地离不开具体的实践、监控和兜底措施。以下是我从多次实战中总结出的关键点。7.1 缓存Key的设计与TTL设置Key设计要唯一且可追溯Key最好包含业务前缀、数据类型和唯一标识如user:info:123。这样在通过Canal等工具清理缓存时可以很容易地根据表名和主键生成对应的Key进行删除。必须设置TTL过期时间这是保证最终一致性的最后一道防线。即使你的删除缓存逻辑失败了数据也会在TTL到期后自动失效下一次读取会从数据库加载正确数据。TTL的时间需要根据业务容忍度和数据变更频率来设定通常从几分钟到几小时不等。考虑设置随机过期对于大批量同时创建的缓存如果TTL相同会导致它们在相近的时间点同时失效引发“缓存雪崩”。可以在基础TTL上增加一个随机值如基础TTL random(0, 300)s。7.2 必不可少的监控与告警没有监控的方案就是“裸奔”。你必须建立以下监控缓存删除失败监控监控消息队列中“缓存删除”消息的消费延迟和失败率。如果失败率持续升高或出现大量积压立即告警。缓存与DB一致性巡检开发一个低频的离线巡检任务定期如每天一次抽样对比热点数据在缓存和数据库中的值记录不一致的数据和比例。这能帮你发现逻辑漏洞或未被覆盖到的场景。缓存命中率监控如果采用了“先更新DB再删除Cache”策略删除后的一段时间内缓存命中率会有一个瞬时下跌。监控这个指标可以帮助你评估删除操作的效果和影响范围。7.3 人工兜底与应急方案再完善的系统也可能出问题必须有预案提供缓存清理管理后台运营或运维人员可以通过输入业务ID手动清理指定缓存。这是处理紧急不一致问题最直接的手段。制定降级策略在缓存集群完全不可用或一致性出现大面积问题时可以考虑降级。例如在应用配置中心设置一个开关打开后所有读请求直接走数据库绕过缓存。虽然性能下降但保证了数据正确性。定期同步与核对对于核心财务、库存等数据除了实时同步还应建立T1的对账机制确保数据的最终正确性。保证缓存和数据库的一致性是一个在性能、复杂度、一致性之间不断权衡的艺术。没有一劳永逸的完美方案只有最适合当前业务场景的解决方案。从简单的“先更新数据库再删除缓存”配合重试机制开始随着业务复杂度和并发量的提升逐步引入消息队列、Binlog同步等更解耦、更可靠的组件。时刻牢记监控和兜底让整个系统在出现问题时也能快速发现、快速恢复。
1. 从一次线上事故说起缓存与数据库不一致的代价那天晚上十一点报警群突然炸了。运营同事反馈后台显示某个热门商品的库存明明还有几百件但用户在前端下单时却频频提示“库存不足”。技术团队紧急介入排查发现商品详情页的库存数据是从Redis缓存中读取的而这个缓存值已经十几个小时没有更新了数据库里的真实库存早已售罄。一次简单的促销活动因为缓存与数据库的数据不一致直接导致了大量用户下单失败、投诉激增最终以运营手动补偿优惠券、技术连夜修复告终。这个事故的根源就是我们今天要深入探讨的核心问题如何保证缓存和数据库的一致性。这绝不是个例。只要你的系统引入了缓存无论是Redis、Memcached这类分布式缓存还是Caffeine、Guava Cache这类本地缓存就必然会面临“双写”带来的数据一致性问题。缓存是为了追求极致的读取性能用空间换时间数据库则是数据的持久化权威存储。当一份数据有两个副本缓存和DB时任何更新操作都必须考虑先更新谁、后更新谁以及失败后如何处理。处理不当轻则出现短时间的脏数据重则像我们遇到的引发业务逻辑错误和资损。网上关于这个问题的讨论很多方案也五花八门从“先更新数据库再删除缓存”到各种复杂的异步补偿机制。但很多文章要么只讲理想情况要么给出的方案在并发场景下漏洞百出。这篇文章我将结合自己多年在电商、社交等高频场景下的实战和踩坑经验为你系统性地拆解缓存一致性的本质、主流方案的优缺点、高并发下的陷阱以及如何根据你的业务场景选择最合适的策略。我们的目标不是寻找一个“银弹”而是建立一套清晰的决策框架让你在面对具体问题时能做出最合理的选择。2. 理解一致性的本质我们到底在追求什么在深入方案之前我们必须先对齐认知什么是“一致性”在缓存语境下一致性通常不是指ACID中的“C”Consistency而是指“缓存数据与数据库数据在某个时间点或时间段内的吻合程度”。根据业务容忍度的不同我们可以将其分为几个层次强一致性任何时刻任何用户读取到的缓存数据都绝对等同于数据库中的最新数据。这通常意味着每次数据更新后都必须让缓存失效或同步更新并且在缓存更新完成前阻塞所有对该数据的读请求。这在分布式系统中实现成本极高往往会完全牺牲缓存带来的性能收益。最终一致性这是互联网业务中最常接受的一致性级别。它允许在数据更新后缓存与数据库存在一个短暂的不一致窗口期但保证在没有任何新的更新操作后经过一段时间所有副本的数据最终会达到一致的状态。我们的核心工作就是通过各种技术手段将这个“不一致窗口期”缩到最短并控制其影响范围。弱一致性系统不保证缓存数据何时会与数据库一致甚至不保证最终一定会一致。除非是某些对数据准确性要求极低的场景如文章阅读数的大致统计否则一般不会采用。对于绝大多数业务如用户信息、商品价格、库存等我们追求的都是最终一致性。我们的目标不是消除不一致而是管理不一致让它发生得尽可能少窗口期尽可能短并且在发生时有兜底和修复机制。明确了这一点我们才能心平气和地讨论下面的方案因为它们都是在性能与一致性之间寻找最佳平衡点。3. 经典双写策略剖析先更新数据库还是先操作缓存当需要更新一条数据时我们面临两个基本操作更新数据库DB和更新缓存Cache。它们的顺序组合构成了最基础的几种策略。让我们逐一分析并重点揭示在并发读写下隐藏的陷阱。3.1 策略一先更新缓存再更新数据库这个策略非常危险强烈不推荐。它的流程是更新缓存为新值。再更新数据库。问题在于如果步骤2更新数据库失败那么缓存中已经是脏数据新值而数据库还是旧值。后续所有的读请求都会命中这个错误的缓存且这个脏数据没有自动修复的机制除非缓存过期或被人为清除。数据就“永远”不一致了。因为数据库是我们的权威数据源任何以可能破坏权威数据源正确性的操作作为第一步的策略风险都极高。3.2 策略二先更新数据库再更新缓存这是很多人直觉上认为合理的做法先保证权威存储正确再同步缓存。流程为更新数据库为新值。更新缓存为新值。看起来没问题但在并发环境下会翻车。考虑如下时序线程A更新数据库将库存从100改为99。线程B更新数据库将库存从99改为98。线程B更新缓存缓存设置为98。线程A更新缓存缓存错误地设置为99。最终数据库库存是98而缓存却是更旧的99。问题根源在于“更新缓存”这个操作不是原子的且后发起的线程可能先完成。这在高并发写场景下必然会发生。注意即使你给缓存操作加锁也只能保证单个Key的更新序列化但无法解决上述“后发起的写请求先更新完缓存”的问题。锁能保证顺序执行但不能保证顺序完成。3.3 策略三先删除缓存再更新数据库Cache-Aside中的写策略这就是经典的Cache-Aside旁路缓存模式中的写操作。流程为删除缓存中的对应数据。更新数据库。这个策略避免了策略二中“更新缓存”的竞态条件因为它第一步执行的是删除del这是一个幂等操作。即使并发执行最终效果都是缓存被清空。但它引入了另一个经典问题缓存缺失旧数据回填。考虑如下时序线程A要更新数据先删除缓存。此时线程B来读取数据发现缓存缺失Cache Miss。线程B从数据库读取旧数据。线程B将读取到的旧数据回填到缓存。线程A完成数据库更新。结果数据库是新值缓存却被回填了旧值导致不一致。这个不一致会持续到缓存过期或下一次更新。虽然发生这个时序需要一定的条件读操作发生在删除缓存后、更新数据库前这个狭窄的时间窗口内但在高并发场景下这个窗口被击中的概率并不低。3.4 策略四先更新数据库再删除缓存推荐方案这是目前最主流、最被推荐的方案也被称为“Cache-Aside with Delayed Deletion”或“Facebook的论文方案”。流程为更新数据库为新值。删除缓存中的对应数据。为什么它更好让我们分析一下它可能出问题的场景场景缓存恰好自动失效。假设在更新之前缓存刚好过期了。线程A来读取数据发现缓存失效准备去数据库查。线程B来更新数据先更新了数据库然后删除了缓存此时缓存本就是空的删除无影响。线程A执行数据库查询读到了线程B更新后的新数据并将其回填到缓存。结果数据库是新值缓存也是新值状态一致。这是一个好结果。场景删除缓存失败。这是该策略最大的风险点。如果第二步删除缓存失败缓存里保留的就是旧数据。因此该策略必须配套一个健全的“删除重试机制”我们会在第5节详细讨论。对比策略三策略四将不一致的风险窗口从“更新数据库”期间可能较长转移到了“删除缓存”期间通常非常短。并且即使删除缓存失败我们面对的也是一个“旧缓存”问题而不是策略一中“永远错误的缓存”问题。旧缓存数据可以通过设置合理的TTL过期时间来最终修复为我们的重试机制争取了时间。结论在基础的同步双写策略中“先更新数据库再删除缓存”是综合来看最好的选择。它简单有效问题边界清晰即删除失败。我们后续的所有高级方案都是在这个基础之上针对其短板删除失败、缓存缺失回填旧数据进行加固和优化。4. 应对高并发挑战延时双删与读写锁的权衡“先更新数据库再删除缓存”策略在普通并发下表现良好但在超高并发场景下我们之前提到的“缓存缺失回填旧数据”问题虽然概率低仍可能发生。此外在数据库主从架构下如果读从库存在延迟还会导致另一个问题从库读到旧数据并回填缓存。为此业界衍生出一些增强方案。4.1 延时双删策略延时双删是一个“以空间换时间一致性”的补救性思路。它在“先更新数据库再删除缓存”的基础上增加了一次延迟的删除操作。基本流程第一次删除缓存可选目的是让后续读请求直接击穿到数据库降低旧数据回填概率。更新数据库。第二次删除缓存。等待一个短暂的时间例如几百毫秒到1秒。执行第三次删除缓存。为什么需要第三步的等待和删除它的目标是为了清除掉在“更新数据库”之后、“第二次删除缓存”之前可能被其他读请求回填到缓存中的旧数据。等待的时间需要大于“数据库主从同步延迟”与“一次读请求执行耗时查询DB回填Cache”之和。伪代码示例Javapublic void updateData(Key key, Value newValue) { // 1. 首次删除可选 cache.del(key); // 2. 更新数据库 db.update(key, newValue); // 3. 立即二次删除 cache.del(key); // 4. 提交一个延迟任务 delayQueue.add(new DelayTask(key, 1000)); // 延迟1秒 } // 延迟任务执行体 class DelayTask { public void run() { // 5. 延迟第三次删除 cache.del(key); } }延时双删的优缺点优点能有效缓解因主从延迟或并发读导致的短期不一致问题。缺点延迟等待降低了吞吐量写请求的响应时间增加了。延迟时间难以评估设置太短可能没效果设置太长则影响性能。这个时间需要根据实际系统压力和数据量动态评估甚至需要监控。并非银弹在极端高频的“写后立即读”场景下仍然可能有不一致窗口。我的实战建议延时双删适用于写操作不那么频繁但对一致性要求较高且存在主从延迟的场景。例如用户重要资料的修改。在实施时可以将延迟删除任务放入消息队列或线程池异步执行避免阻塞主流程。同时务必监控延迟任务的堆积情况。4.2 基于分布式锁的强一致性方案如果你追求的是强一致性或者业务场景完全无法容忍任何旧数据如金融账户余额那么就需要引入分布式锁将并发的读写操作串行化。基本流程以写优先为例写请求到来针对该数据键Key获取一个分布式锁。获取锁后执行“更新数据库再删除缓存”。释放锁。读请求到来同样尝试获取该键的分布式锁。如果获取成功说明没有正在进行的写操作则查询缓存若缓存不存在则查数据库并回填。如果获取失败说明有写操作正在进行则可以选择阻塞等待直到获取锁或者直接读数据库牺牲一些性能保证强一致。优缺点优点实现了强一致性逻辑清晰。缺点性能损耗巨大分布式锁的获取、释放本身就是开销更重要的是它将并发操作串行化完全牺牲了缓存的高并发读优势。这相当于用缓存的价格复杂度买到了数据库的性能串行。复杂度高需要引入和维护分布式锁组件如Redis Redlock、ZooKeeper并妥善处理锁超时、死锁等问题。可用性风险锁服务如果出现故障会影响所有相关读写操作。注意在99%的业务场景下为缓存一致性引入分布式锁都是过度设计。它带来的性能下降和复杂度提升往往远超数据短暂不一致带来的业务风险。请务必谨慎评估。选型决策参考场景特征推荐策略原因读多写少容忍秒级不一致先更新数据库再删除缓存简单可靠配合TTL和重试能满足大部分场景。写后读频繁存在主从延迟延时双删针对性解决主从延迟和并发读回填问题。写操作极其频繁如秒杀库存考虑直接操作数据库或采用更复杂队列此时缓存更新可能成为瓶颈需重新评估缓存价值。金融、交易等强一致场景分布式锁或直接弃用缓存业务要求压倒一切性能成为次要考虑。5. 确保操作可靠性重试机制与异步补偿无论选择哪种策略都必须面对一个现实网络和服务不是100%可靠的。“更新数据库”或“删除缓存”都可能失败。对于“先更新数据库再删除缓存”这个推荐策略我们必须保证“删除缓存”这一步最终能成功否则就会留下脏数据。这就需要一套健全的失败重试与异步补偿机制。5.1 同步重试的陷阱最简单的想法是在应用代码里进行同步重试public void updateWithRetry(Key key, Value value) { db.update(key, value); int maxRetries 3; for (int i 0; i maxRetries; i) { try { cache.del(key); break; // 成功则退出 } catch (Exception e) { if (i maxRetries - 1) { throw new RuntimeException(删除缓存最终失败, e); } Thread.sleep(100 * (i 1)); // 延迟递增 } } }这非常糟糕。首先它阻塞了用户请求增加了响应时间。其次如果重试多次后仍然失败你是抛出异常导致整个更新事务回滚还是放任缓存不一致前者影响主流程后者导致数据错误。同步重试不可取。5.2 基于消息队列的异步重试正确的做法是将“删除缓存”这个动作异步化、解耦。最成熟的方案是借助消息队列。流程应用服务在事务内更新数据库。在事务提交后立即向消息队列发送一条“删除缓存”的消息。这一步必须确保成功通常与数据库事务绑定如本地消息表或使用支持事务的消息队列如RocketMQ。一个独立的“缓存删除消费者”服务监听队列消费消息并执行删除操作。如果消费者删除成功则确认消息。如果消费者删除失败网络抖动、Redis故障消息队列会根据重试策略如指数退避重新投递这条消息直到成功。优势解耦主流程写DB不受缓存删除成功与否的影响响应快。可靠消息队列保证了消息的持久化和至少一次投递At Least Once只要消费者逻辑幂等就能保证最终删除。削峰即使短时间内有大量更新消息队列也能缓冲避免压垮缓存服务。技术选型参考RocketMQ支持事务消息可以很好地保证“DB事务提交”和“发送删除消息”的原子性。Kafka高吞吐但需要自行实现类似“事务”的语义如两阶段提交配合本地事务表。Redis Streams如果缓存本身就是Redis可以用其自带的Streams作为轻量级队列。5.3 基于数据库日志Binlog的异步淘汰这是另一个非常优雅且解耦彻底的方案不依赖于业务代码发送消息而是通过监听数据库的变更日志来触发缓存删除。以MySQL Canal Redis为例的流程业务代码只需更新数据库完全不用关心缓存。MySQL 的 Binlog 会记录所有数据变更。Canal一个阿里开源的数据库增量日志解析组件伪装成MySQL的从库实时订阅并解析Binlog。Canal 将解析出的数据变更表名、主键、操作类型发送给消息队列如RocketMQ/Kafka。一个独立的缓存清理服务消费这些消息根据“表名主键”的规则去删除Redis中对应的缓存。优势彻底解耦业务代码零侵入缓存维护成为独立的基础设施。通用性强无论业务逻辑如何变化只要数据库有变更缓存就能被同步清理。这对于遗留系统改造尤其友好。保证顺序Binlog本身是有序的可以保证缓存清理的顺序与数据库变更顺序一致对于某些顺序敏感的场景很重要。挑战架构复杂度引入了Canal、消息队列、消费者服务等多个组件运维成本增加。延迟从DB变更到缓存清理整个链路的延迟比直接删除要高通常在毫秒到百毫秒级需要监控。消息过滤需要仔细设计规则避免误删或漏删缓存。方案对比表特性业务代码同步删除消息队列异步重试Binlog异步淘汰可靠性低失败即不一致高依赖消息队列可靠性极高依赖Binlog和消息队列性能影响高阻塞主流程低异步化无业务代码无感知架构复杂度低中高实时性实时近实时取决于队列消费速度近实时取决于Binlog解析和消费速度适用场景对一致性要求不高的简单应用绝大多数分布式应用大型复杂系统微服务架构需要统一缓存治理6. 特殊场景与进阶考量缓存模式与数据分片除了通用的双写策略在一些特殊场景下我们需要采用不同的缓存模式或者对一致性有更精细化的控制。6.1 Write-Through 与 Write-Behind 模式我们之前讨论的Cache-Aside是“懒加载”模式由应用代码主动管理缓存。还有两种由缓存组件本身管理的模式Write-Through直写应用将数据写入缓存缓存组件同步地将数据写入数据库然后才返回成功。一致性最好写操作完成时缓存和数据库都是最新的。性能最差每次写都有数据库IO。适用场景写操作很少但对一致性要求极高的场景。很多本地缓存如Caffeine的CacheWriter接口可以实现此模式。Write-Behind写回应用将数据写入缓存缓存组件立即返回成功。随后缓存组件异步地、批量地将数据更新到数据库。一致性最弱存在数据丢失风险缓存宕机。性能最好写操作极快。适用场景写入吞吐量极大且能容忍一定数据丢失的场景如点击流、日志收集。需要缓存组件支持如某些商业版Redis模块。对于大多数业务系统Cache-Aside在灵活性和性能上取得了最佳平衡因此最为流行。6.2 针对热点Key与大数据量的策略热点Key更新对于像“秒杀库存”这样的热点Key频繁的“更新DB删除Cache”操作本身可能成为瓶颈甚至引发缓存击穿大量请求在缓存删除瞬间同时涌向数据库。策略可以考虑在缓存层面进行原子递减如Redis的DECR然后异步同步到数据库。这实际上将数据库降级为“备份存储”牺牲了一定的一致性异步同步延迟来换取极高的并发处理能力。这需要非常精细的业务容忍度评估和补偿对账机制。大Value或复杂结构更新如果缓存的是一个庞大的JSON对象或聚合数据每次更新都删除整个缓存可能浪费带宽且重新构建缓存开销大。策略可以考虑使用Hash结构存储只更新或删除发生变化的字段。或者采用版本号Version机制更新数据时生成新版本号写入DB并让缓存Key包含版本号。读请求时先查最新版本号再用版本化Key去查缓存。这样旧版本的缓存数据可以自然淘汰实现了更细粒度的更新。6.3 缓存与数据库的事务协调在分布式系统中更新数据库和操作缓存可能涉及分布式事务问题。例如一个业务需要更新两个数据库记录并清理对应的两个缓存如何保证这四个操作的整体一致性刚性方案引入Seata等分布式事务框架将缓存操作纳入分布式事务管理。代价是性能损耗巨大复杂度高通常不推荐。柔性方案最终一致性这是更主流的选择。可以采用“本地消息表”或“事务消息”模式。在数据库事务中将要清理的缓存Key记录到一张本地消息表。事务提交后一个后台任务扫描这张表将消息发送到MQ由消费者清理缓存。或者使用RocketMQ的事务消息在DB事务提交前后进行消息的发送和确认。核心思想是保证DB事务与“发送缓存清理消息”这个动作的原子性而缓存清理本身通过MQ的重试机制保证最终成功。7. 实战中的经验、监控与兜底理论方案最终要落地离不开具体的实践、监控和兜底措施。以下是我从多次实战中总结出的关键点。7.1 缓存Key的设计与TTL设置Key设计要唯一且可追溯Key最好包含业务前缀、数据类型和唯一标识如user:info:123。这样在通过Canal等工具清理缓存时可以很容易地根据表名和主键生成对应的Key进行删除。必须设置TTL过期时间这是保证最终一致性的最后一道防线。即使你的删除缓存逻辑失败了数据也会在TTL到期后自动失效下一次读取会从数据库加载正确数据。TTL的时间需要根据业务容忍度和数据变更频率来设定通常从几分钟到几小时不等。考虑设置随机过期对于大批量同时创建的缓存如果TTL相同会导致它们在相近的时间点同时失效引发“缓存雪崩”。可以在基础TTL上增加一个随机值如基础TTL random(0, 300)s。7.2 必不可少的监控与告警没有监控的方案就是“裸奔”。你必须建立以下监控缓存删除失败监控监控消息队列中“缓存删除”消息的消费延迟和失败率。如果失败率持续升高或出现大量积压立即告警。缓存与DB一致性巡检开发一个低频的离线巡检任务定期如每天一次抽样对比热点数据在缓存和数据库中的值记录不一致的数据和比例。这能帮你发现逻辑漏洞或未被覆盖到的场景。缓存命中率监控如果采用了“先更新DB再删除Cache”策略删除后的一段时间内缓存命中率会有一个瞬时下跌。监控这个指标可以帮助你评估删除操作的效果和影响范围。7.3 人工兜底与应急方案再完善的系统也可能出问题必须有预案提供缓存清理管理后台运营或运维人员可以通过输入业务ID手动清理指定缓存。这是处理紧急不一致问题最直接的手段。制定降级策略在缓存集群完全不可用或一致性出现大面积问题时可以考虑降级。例如在应用配置中心设置一个开关打开后所有读请求直接走数据库绕过缓存。虽然性能下降但保证了数据正确性。定期同步与核对对于核心财务、库存等数据除了实时同步还应建立T1的对账机制确保数据的最终正确性。保证缓存和数据库的一致性是一个在性能、复杂度、一致性之间不断权衡的艺术。没有一劳永逸的完美方案只有最适合当前业务场景的解决方案。从简单的“先更新数据库再删除缓存”配合重试机制开始随着业务复杂度和并发量的提升逐步引入消息队列、Binlog同步等更解耦、更可靠的组件。时刻牢记监控和兜底让整个系统在出现问题时也能快速发现、快速恢复。
)
