缓存和数据库双写一致方案讨论解读

什么是缓存双写一致

只要用缓存，就可能会涉及到缓存与数据库双存储双写，你只要是双写，就一定会有数据一致性的问题。我们需要保证redis跟数据库的中的数据保持一致，返回正确的数据。

更新缓存还是删除缓存？

删除缓存，而不是更新缓存

如果更新缓存，在并发写时，可能出现数据不一致。

假设现在同时有请求A和请求B进行更新操作，那么会出现

• （1）线程A更新了数据库
• （2）线程B更新了数据库
• （3）线程B更新了缓存
• （4）线程A更新了缓存

这就出现请求A更新缓存应该比请求B更新缓存早才对，但是因为网络等原因，B却比A更早更新了缓存。这就导致了脏数据，因此不考虑。

如果因为每次数据发生变更，都「无脑」更新缓存，但是缓存中的数据不一定会被「马上读取」，这就会导致缓存中可能存放了很多不常访问的数据，浪费缓存资源。 而且很多情况下，写到缓存中的值，并不是与数据库中的值一一对应的，很有可能是先查询数据库，再经过一系列「计算」得出一个值，才把这个值才写到缓存中。

先删除缓存,再更新数据库

场景描述

A线程先成功删除了redis里面的数据,然后去更新mysql,此时mysql正在更新中,还没有结束。（比如网络延时)B突然出现要来读取缓存数据。此时redis里面的数据是空的,B线程来读取,先去读redis里数据(已经被A线程delete掉了)。

上述场景出现的问题：

1. B从mysql获得了旧值:B线程发现redis里没有(缓存缺失)马上去mysql里面读取,从数据库里面读取来的是旧值
2. B会把获得的旧值写回redis:获得旧值数据后返回前台并回写进redis(刚被A线程删除的旧数据有极大可能又被写回了)

最后：A线程更新完mysql,发现redis里面的缓存是脏数据

解决方案：延时双删策略

可以先对缓存的数据先进行删除一次，再处理好数据库的业务以后睡眠一段时间后再进行一次删除。这就是延迟双删。

为什么要sleep一段时间？

加上sleep的这段时间,就是为了让线程B能够先从数据库读取数据,再把缺失的数据写入缓存,然后,线程A再进行删除。所以,线程A Sleep的时间,就需要大于现场B读取数据再写入缓存的时间。这样一来,其他线程读取数据时,会发生缓存缺失,所以会从数据库中读取最新值。因为这个方案会在第一次删除缓存值后,延迟一段时间再去进行删除,所以我们也把它叫做"延迟双删"

如果直接删掉的话，线程B可能还没写进去redis中，线程A写了，然后线程B再写，覆盖掉了。

休眠多久呢?这个时间怎么确定呢？

1. 在业务程序运行的时候,统计下线程读数据和写缓存的操作时间,自行评估自己的项目的读数据业务逻辑的耗时,以此为基础来进行估算。然后写数据的休眠时间则在读数据业务逻辑的耗时基础上加百毫秒即可
2. 这么做的目的,就是确保读请求结束,写请求可以删除读请求造成的缓存脏数据

先更新数据库，再删除缓存

场景描述

异常原因:假如缓存删除失败或者来不及,导致请求再次访问redis时缓存命中,读取到的是缓存旧值

解决方案：重试机制+引入MQ

• 可以把要删除的缓存值或者是要更新的数据库值暂存到消息队列中(例如使用Kafka/RabbitMQ等)
• 当程序没有能够成功地删除缓存值或者是更新数据库值时,可以从消息队列中重新读取这些值,然后再次进行删除或更新
• 如果能够成功地删除或更新,我们就要把这些值从消息队列中去除,以免重复操作,此时,我们也可以保证数据库和缓存的数据一致了,否则还需要再次进行重试
• 如果重试超过的一定次数后还是没有成功,我们就需要向业务层发送报错信息了,通知运维人员

1. 更新数据库数据
2. 数据库会将操作信息写入binlog日志当中
3. 订阅程序提取出所需要的数据以及key
4. 另起一段非业务代码，获得该信息
5. 尝试删除缓存操作，发现删除失败
6. 将这些信息发送至消息队列
7. 重新从消息队列中获得改数据，重试操作。

为什么要引入MQ

1. 在应用程序将数据更新到数据库后,将更新操作发送到消息队列中,然后再由消息队列异步地触发删除缓存数据的操作
2. 这样做的好处是，即使在更新数据库后发生异常或者网络延迟等问题,数据更新操作也已经被放到消息队列中,并不会导致缓存数据和数据库数据不一致的问题