Redis学习笔记-如何解决缓存和数据库的数据不一致

本文涉及的产品
云数据库 Redis 版,社区版 2GB
推荐场景:
搭建游戏排行榜
简介: Redis学习笔记-如何解决缓存和数据库的数据不一致

只要在业务中使用缓存,就必然会面对缓存和数据库之间的一致性保证问题了,这也是 Redis 缓存应用中的必答题,如果某些业务场景数据不一致,就会导致严重的错误,比如某个商品库存信息在 Redis 中和数据库中不一致,这就会导致用户下单操作出现严重错误,这个是在业务上无法接受的,这篇文章来学习一下 Redis 缓存和数据库不一致。

1.笔记图

2.数据一致性是啥意思?


不符合下面这两种情况就属于缓存和数据库的数据不一致:

  • 缓存中有数据,缓存的数据值需要和数据库中的值相同
  • 缓存中没有数据,数据库中的值必须是最新值

3.写回策略

  • 同步直写:写请求发给缓存的同时,也会发给后端数据库进行处理,等到缓存和数据库都写完数据,才给客户端返回,同步直写策略优先保证数据可靠性,增加了缓存的响应延迟
  • 异步写回:优先提供快速响应,所有写请求都先在缓存中处理,等到这些增改的数据要被从缓存中淘汰出来时,缓存将它们写回后端数据库,使用这种策略时,如果数据还没有写回数据库,就发生了故障,数据库就没有最新的数据了

4.Redis缓存类型

  • 只读缓存:所有的数据写请求,会直接发往后端的数据库,如果 Redis 已经缓存了相应的数据,应用需要把这些缓存的数据删除,当应用再次读取这些数据时,会发生缓存缺失,应用会把这些数据从数据库中读出来,并写到缓存中
  • 读写缓存
  • 读写缓存除了读请求会发送到缓存,写请求也会发送到缓存
  • 在使用读写缓存时,最新的数据在 Redis 中,一旦出现掉电或宕机,内存中的数据可能就会丢失

5.数据不一致情况

  • 如果有数据需要删改时,假设先删除缓存数据成功了,再删改数据库数据失败了,再次访问数据时,缓存中没有数据,就会读到数据库中的旧数据
  • 假设先删改数据库数据成功了,再删除缓存数据失败了,数据库中的值是新值,缓存中的值是旧值,其他并发请求会访问到缓存中的旧值

  • 更新数据库和删除缓存值的过程中,无论这两个操作的执行顺序谁先谁后,只要有一个操作失败了,就会导致客户端读取到旧值

  • 即使删改数据库和删除缓存这两个操作执行时都没有失败,当有大量并发请求时,应用还是有可能读到不一致的数据

6.缓存和数据库数据操作原子性

  • 要想保证缓存和数据库中的数据一致,就要采用同步直写策略,需要同时更新缓存和数据库
  • 如果发生删改操作,应用既要更新数据库,也要在缓存中删除数据。两个操作如果无法保证原子性(要么都完成,要么都没完成),就会出现数据不一致问题了
  • 同步直写策略要在业务应用中使用事务机制,来保证缓存和数据库的更新具有原子性
  • 缓存和数据者要么一起更新,要么都不更新,返回错误信息,进行重试

7.解决数据不一致问题

  • 重试机制

  • 可以把要删除的缓存值或者是要更新的数据库值暂存到消息队列中(如Kafka),当没有成功删除缓存值或者是更新数据库值时,从消息队列中重新读取这些值,再次进行删除或更新
  • 如重试超过一定次数没有成功,就需要向业务层发送报错信息
  • 情况一:先删除缓存,再更新数据库
  • 问题描述

  • 假设线程 A 删除缓存值后,还没有来得及更新数据库(比如说有网络延迟),
    线程 B 就开始读取数据了,线程 B 会发现缓存缺失,就只能去数据库读取

  • 线程 B 读取到了旧值

  • 线程 B 是在缓存缺失的情况下读取的数据库,它还会把旧值写入缓存,这可能会导致其他线程从缓存中读到旧值
  • 解决办法延迟双删
  • 在线程 A 更新完数据库值以后,可以让它 sleep 一小段时间,再进行一次缓存删除操作
  • 加上 sleep 的这段时间,就是为了让线程 B 能够先从数据库读取数据,再把缺失的数据写入缓存,线程 A 再进行删除
  • 线程 A sleep 的时间,就需要大于线程 B 读取数据再写入缓存的时间,这个 sleep 时间需要根据业务统计下线程读数据和写缓存的操作时间,以此为基础来进行估算
  • 伪代码:
redis.delKey(X)
db.update(X)
Thread.sleep(N)
redis.delKey(X)

  • 情况二:先删除缓存,再更新数据库

  • 问题描述:如线程 A 删除数据库中的值,没来得及删除缓存值,线程 B 就开始读取数据了,线程 B 查询缓存时,发现缓存命中,会读取旧值
  • 解决办法
  • 删除缓存值或更新数据库失败而导致数据不一致,你可以使用重试机制确保删除或更新操作成功
  • 在删除缓存值、更新数据库的这两步操作中,有其他线程的并发读操作,导致其他线程读取到旧值,应对方案是延迟双删

相关实践学习
基于Redis实现在线游戏积分排行榜
本场景将介绍如何基于Redis数据库实现在线游戏中的游戏玩家积分排行榜功能。
云数据库 Redis 版使用教程
云数据库Redis版是兼容Redis协议标准的、提供持久化的内存数据库服务,基于高可靠双机热备架构及可无缝扩展的集群架构,满足高读写性能场景及容量需弹性变配的业务需求。 产品详情:https://www.aliyun.com/product/kvstore     ------------------------------------------------------------------------- 阿里云数据库体验:数据库上云实战 开发者云会免费提供一台带自建MySQL的源数据库 ECS 实例和一台目标数据库 RDS实例。跟着指引,您可以一步步实现将ECS自建数据库迁移到目标数据库RDS。 点击下方链接,领取免费ECS&RDS资源,30分钟完成数据库上云实战!https://developer.aliyun.com/adc/scenario/51eefbd1894e42f6bb9acacadd3f9121?spm=a2c6h.13788135.J_3257954370.9.4ba85f24utseFl
相关文章
|
4天前
|
关系型数据库 MySQL 数据库
实时计算 Flink版产品使用合集之支持将数据写入 OceanBase 数据库吗
实时计算Flink版作为一种强大的流处理和批处理统一的计算框架,广泛应用于各种需要实时数据处理和分析的场景。实时计算Flink版通常结合SQL接口、DataStream API、以及与上下游数据源和存储系统的丰富连接器,提供了一套全面的解决方案,以应对各种实时计算需求。其低延迟、高吞吐、容错性强的特点,使其成为众多企业和组织实时数据处理首选的技术平台。以下是实时计算Flink版的一些典型使用合集。
23 5
|
4天前
|
关系型数据库 MySQL API
实时计算 Flink版产品使用合集之可以通过mysql-cdc动态监听MySQL数据库的数据变动吗
实时计算Flink版作为一种强大的流处理和批处理统一的计算框架,广泛应用于各种需要实时数据处理和分析的场景。实时计算Flink版通常结合SQL接口、DataStream API、以及与上下游数据源和存储系统的丰富连接器,提供了一套全面的解决方案,以应对各种实时计算需求。其低延迟、高吞吐、容错性强的特点,使其成为众多企业和组织实时数据处理首选的技术平台。以下是实时计算Flink版的一些典型使用合集。
79 0
|
6天前
|
关系型数据库 数据库 数据安全/隐私保护
关系型数据库的数据完整性保障
【5月更文挑战第9天】关系型数据库的数据完整性保障
9 1
|
1天前
|
存储 监控 前端开发
关系型数据库数据输入验证
【5月更文挑战第12天】
34 5
|
1天前
|
存储 关系型数据库 数据库
关系型数据库的数据完整性约束
【5月更文挑战第12天】关系型数据库的数据完整性约束
11 2
|
1天前
|
消息中间件 缓存 监控
中间件如果缓存中存在所需的数据(缓存命中)
【5月更文挑战第12天】中间件如果缓存中存在所需的数据(缓存命中)
21 3
|
1天前
|
存储 缓存 监控
|
1天前
|
数据库 数据库管理
理解数据库的ACID原则:确保数据完整性与一致性的基石
【5月更文挑战第20天】ACID原则是数据库事务处理的核心,包括原子性、一致性、隔离性和持久性。原子性保证事务操作全完成或全不完成,保持数据完整;一致性确保事务前后数据库保持一致性状态,不破坏完整性约束;隔离性防止并发事务相互影响,通过锁等技术实现;持久性则保证事务提交后的修改永久保存,即使系统故障也能恢复。这些原则确保了数据的可靠性和安全性。
|
3天前
|
NoSQL Shell MongoDB
NoSQL数据使用指令和引擎连接数据库实例
【5月更文挑战第8天】本文介绍了MongoDB的本地使用和常用操作,包括通过mongo shell连接数据库、显示数据库和集合,以及副本集设置。最后提到了MongoDB的日志功能和顶点集的使用,如capped collection的创建和管理。
47 3
|
4天前
|
存储 SQL Oracle
关系型数据库文件方式存储DATA FILE(数据文件)
【5月更文挑战第11天】关系型数据库文件方式存储DATA FILE(数据文件)
15 3