老话新谈之缓存一致性
前言
缓存一致性常见的更新策略也比较多,如先更新数据库再更新缓存,先删缓存再更新数据库等等,我在理解的时候有些混乱,所以这个文章提供了一些理解上的技巧去理解缓存一致性。
为什么会有缓存一致性的问题
- 缓存与数据库是两套中间件,存在网络抖动之类的原因导致没有更新任一方的可能
- 数据库大多都是事务型的中间件,支持错误回滚,缓存大多是非事务型的中间件,这里缓存更新失败了没办法回滚
所以根因是缓存大部分不支持事务无法回滚。
怎么尽量解决缓存一致性的问题
操作二者必定有先后顺序,存在以下两个情况:
- 先操作缓存,再操作数据库。操作缓存成功,数据库更新失败,缓存无法回滚,数据不一致
- 先操作数据库,再操作缓存。操作数据库成功,缓存操作失败,可触发异常回滚数据库,数据一致
根据上述所列,只能先操作数据库,再操作缓存了。
操作缓存也分两种:
- 更新缓存数据,可能并发请求,后一请求更新缓存的数据被前一请求的更新覆盖了,导致数据不一致
- 删除缓存数据,并发请求,二者都使缓存失效,查询请求将数据库数据加载到缓存中,数据一致
根据上述所列,只能使缓存失效,查询请求加载数据到缓存中了。
所以,如果在不加任何重试措施的情况下,先操作数据库,再删除缓存是一个容错较好的方法。
缓存一致性的分类 & 存在的问题
Client 维护缓存 & 数据库的一致性
-
更新缓存 -> 更新数据库
[图片上传失败...(image-446953-1686389497129)]
@startuml
Database Database as DB
entity Cache as Cache
transaction1 -> Cache: update data
transaction1 <-- Cache: update result
transaction1 -> DB: update data
transaction1 <-- DB: update result
@enduml
-
可能出现的数据不一致
数据不一致:更新缓存成功了,更新数据库失败了,有数据不一致的问题,直到缓存超时失效或又一更新请求操作成功都会不一致
-
改进方式
若保证更新数据仅有少数的服务更新,可以将更新数据库请求入队处理,且可加入重试机制。但是队列的加入会增大系统复杂度,并且重试以及缓存更新顺序不一致会加剧数据不一致
- 更新数据库 -> 更新缓存
[图片上传失败...(image-e8b646-1686389497129)]
@startuml
Database Database as DB
entity Cache as Cache
transaction1 -> DB: update data
transaction1 <-- DB: update result
transaction2 -> DB: update data
transaction2 <-- DB: update result
transaction2 -> Cache: update data
transaction2 <-- Cache: update result
transaction1 -> Cache: update data
transaction1 <-- Cache: update result
@enduml
-
可能出现的数据不一致
数据不一致:如 t1 先更新数据库,t2 在 t1 更新缓存前把数据库缓存都更新完了,t1 再更新缓存,这时候缓存上是 t1 的数据,数据库是 t2 的数据
-
改进方式
若保证更新数据仅有少数的服务更新,可以将更新数据库请求入队处理,但是队列更新的引入增大了系统复杂度
-
删除缓存 -> 更新数据库
[图片上传失败...(image-1038e9-1686389497129)]
@startuml
Database Database as DB
entity Cache as Cache
transaction1 -> Cache: delete data
query1 -> DB: select data
query1 -> Cache: insert data
transaction1 -> DB: update result
@enduml
- 可能出现的数据不一致
- 如图所示,更新请求先删除缓存,查询请求从缓存获取不到数据从数据库获取数据(老数据)加载到缓存中,更新请求更新数据库
- 这样的流程会导致查询请求加载老数据到缓存中,后续更新请求更新新数据到数据库中,导致数据不一致
-
改进方式
暂无。
- 更新数据库 -> 删除缓存
[图片上传失败...(image-648517-1686389497129)]
@startuml
Database Database as DB
entity Cache as Cache
query1 -> DB: select data
transaction1 -> DB: update result
transaction1 -> Cache: delete data
query1 -> Cache: insert data
@enduml
-
可能出现的数据不一致
查询请求先拿到数据,在插入缓存前更新请求进来更新数据库并使缓存失效,这个请求比较罕见
- 发生的场景
- 查询请求所在机器请求缓存比更新请求做完的整个流程都要慢
- 发生的概率
- 很低。因为操作缓存一般会比操作数据库要快
- 发生的场景
- 改进方式
- 变更数据记录变更事件
- 步骤
- 更新数据同步记录一个事件在本地内存中
- 查询请求在插入缓存前查询事件,如果存在变更则查数据库获取最新数据
- 如果此数据在查询请求插入缓存过程中一直变更,这里需要先返回当前数据库结果给上游,再开异步任务轮训事件/数据库插入缓存
- 适用场景
- 只适用单节点
- 步骤
- 变更数据记录变更事件
Server 维护缓存 & 数据库的一致性
-
Read though/Write though
- read though
[图片上传失败...(image-f40f89-1686389497129)]
@startuml Database Database as DB entity Cache as Cache query -> repository: select data repository -> cache: get data repository -> DB: get data DB -> repository: return data repository -> cache: update data repository -> query: return data @enduml
- wirte though
[图片上传失败...(image-c23b3e-1686389497129)]
@startuml
Database Database as DB
entity Cache as Cache
transcation -> repository: update data
repository -> cache: update data
repository -> DB: update data
DB -> repository: return result
repository -> transcation: return result
@enduml
- 可能出现的数据不一致
- 程序没有优雅关闭,更新请求先更新了缓存,但还没更新数据库,数据丢失
- 更新缓存成功,更新数据库失败导致的数据不一致
- 适用场景
- 更新数据库极低概率失败
- 程序有优雅关闭功能
- 改进方式
- 暂无
- Write Behind
[图片上传失败...(image-b1768d-1686389497129)]
@startuml
Database Database as DB
entity Cache as Cache
query -> repository: query data
repository -> cache: query data
repository -> DB: query data
DB -> repository: return data
repository -> cache: update data
repository -> query: return data
@enduml
[图片上传失败...(image-2eef9a-1686389497129)]
@startuml
Database Database as DB
entity Cache as Cache
transcation -> repository: update data
repository -> cache: update data
repository -> DB: batch update data
@enduml
- 可能出现的数据不一致
- 程序没有优雅关闭,更新请求先更新了缓存,但还没更新数据库,数据丢失
- 批量更新数据库失败导致的数据不一致
- 适用场景
- 更新数据库极低概率失败
- 程序有优雅关闭功能
- 改进方式
- 暂无
参考
https://coolshell.cn/articles/17416.html
本文首发于cartoon的博客
转载请注明出处:https://cartoonyu.github.io