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

news2024/12/23 22:20:11

目录

什么是缓存双写一致

更新缓存还是删除缓存?

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

场景描述

解决方案:延时双删策略

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

场景描述

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

​编辑


什么是缓存双写一致

只要用缓存,就可能会涉及到缓存与数据库双存储双写,你只要是双写,就一定会有数据一致性的问题。我们需要保证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里面的缓存是脏数据

时间线程A线程B出现的问题
t1请求A进行写操作,删除缓存后,工作正在进行中......

A还更新完mysql,致B读到了旧值


线程B遵守回写机制,把旧值写回redis,导致其它请求读取的还是旧值,A白干了。

t2

缓存中读取不到,立刻读mysal,由于A还没有对mysal更新完,读到的是旧值。


 还把从mysgl读取的旧值,写回了redis

t3更新mysql数据库的值,overredis是被B写回的旧值
mysql是被A更新的新值
出现了,数据不一致问题。

解决方案:延时双删策略

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

为什么要sleep一段时间? 

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

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

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

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

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

场景描述

时间线程A线程B出现的问题
t1删除数据库中的值

t2缓存中立刻命中,此时B读取的是缓存旧值。A还没有来得及删除缓存的值导致B缓存命中读到旧值。
t3更新缓存的数据,over

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

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

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

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

为什么要引入MQ

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

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.coloradmin.cn/o/972902.html

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈,一经查实,立即删除!

相关文章

如何合并为pdf文件?合并为pdf文件的方法

在数字化时代,人们越来越依赖电子文档进行信息交流和存储。合并为PDF成为一种常见需求,它能将多个文档合而为一,方便共享和管理。无论是合并多个单页文档,还是将多页文档合并,操作都变得简单高效。那么。如何合并为pdf…

哈夫曼编码实现文件的压缩和解压

程序示例精选 哈夫曼编码实现文件的压缩和解压 如需安装运行环境或远程调试,见文章底部个人QQ名片,由专业技术人员远程协助! 前言 这篇博客针对《哈夫曼编码实现文件的压缩和解压》编写代码,代码整洁,规则&#xff0…

【Sentinel】核心API-Entry与Context

文章目录 一、Entry1、Entry的声明2、使用API自定义资源3、基于SentinelResource注解标记资源 二、Context1、Context介绍2、Context的初始化3、AbstractSentinelInterceptor4、ContextUtil 一、Entry 1、Entry的声明 默认情况下,Sentinel会将controller中的方法作…

关于人工智能的担忧

人工智能的快速发展引发了一系列关于其潜在风险和担忧的讨论。以下是一些常见的人们对人工智能的担忧: 失业问题:人工智能的出现可能会导致很多工作岗位的消失,特别是那些需要重复性劳动的工作。人们担心机器取代人类工作将导致大规模失业和社…

W5500-EVB-PICO进行MQTT连接订阅发布教程(十二)

前言 上一章我们用开发板通过SNTP协议获取网络协议,本章我们介绍一下开发板通过配置MQTT连接到服务器上,并且订阅和发布消息。 什么是MQTT? MQTT是一种轻量级的消息传输协议,旨在在物联网(IoT)应用中实现设…

计算机毕业设计 社区买菜系统 Vue+SpringBoot+MySQL

作者主页:Designer 小郑 作者简介:Java全栈软件工程师一枚,来自浙江宁波,负责开发管理公司OA项目,专注软件前后端开发、系统定制、远程技术指导。CSDN学院、蓝桥云课认证讲师,全栈领域优质创作者。 项目内容…

JavaScript中的原型链(prototype chain)

聚沙成塔每天进步一点点 ⭐ 专栏简介⭐ JavaScript中的原型链⭐ 写在最后 ⭐ 专栏简介 前端入门之旅:探索Web开发的奇妙世界 记得点击上方或者右侧链接订阅本专栏哦 几何带你启航前端之旅 欢迎来到前端入门之旅!这个专栏是为那些对Web开发感兴趣、刚刚踏…

如何访问GitHub

1、手动修改hosts 1.1、查找到最新的GitHub的hosts信息 通过链接:https://raw.hellogithub.com/hosts 进行查找最新的GitHub的hosts信息 1.2、查找到hosts文件位置 先找到 hosts 文件的位置,不同操作系统,hosts 文件的存储位置也不同&…

量化:基于RSRS的市场择时复现

文章目录 资源研报解读概念Q&ARSRS指标构建交易逻辑 资源 《阻力支撑相对强度RSRS研究报告》 链接:https://pan.baidu.com/s/1EhtoC25WSO7WpNiyZpcKYA 提取码:2023 合吾~~~祝投资顺利愉快! 研报复现系列(5)基于阻力…

Dev-C++中,不使用include <string>也可以用string name1, name2; 为什么?

Dev-C中&#xff0c;不使用 include <string> 也可以用 string name1, name2; 为什么&#xff1f; 例如&#xff1a; #include <iostream> //#include <string> using namespace std; int main() { string s1, s2; cout << "请输入两个…

“深入探究SpringMVC的工作原理与入门实践“

目录 引言1. 什么是SpringMVC?1.1. 模型1.2. 视图1.3. 控制器 2. SpringMVC的工作流程2.1. 客户端发送请求2.2. DispatcherServlet的处理2.3. 处理器映射器的使用2.4. 处理器的执行2.5. 视图解析器的使用2.6. 视图的渲染 3. SpringMVC的核心组件4. 弹簧MVC总结 引言 SpringMV…

Java 多线程系列Ⅳ(单例模式+阻塞式队列+定时器+线程池)

多线程案例 一、设计模式&#xff08;单例模式工厂模式&#xff09;1、单例模式2、工厂模式 二、阻塞式队列1、生产者消费者模型2、阻塞对列在生产者消费者之间的作用3、用标准库阻塞队列实现生产者消费者模型4、模拟实现阻塞队列 三、定时器1、标准库中的定时器2、模拟实现定时…

WinXP 蓝屏死机,并报代码0x0000007B的错误

蓝屏死机&#xff0c;并报代码0x0000007B的错误&#xff0c;通常情况都是硬盘的存储控制器驱动加载错误导致故障。导致驱动加载错误的情况&#xff0c;可能有以下三种情况&#xff1a; 1、无法自动识别硬盘控制器 使用非正版的操作系统光盘&#xff08;进过修改或者加强的Wind…

doris多租户资源隔离及权限管理

Doris 的多租户和资源隔离方案&#xff0c;主要目的是为了多用户在同一 Doris 集群内进行数据操作时&#xff0c;减少相互之间的干扰&#xff0c;能够将集群资源更合理的分配给各用户。 该方案主要分为两部分&#xff0c;一是集群内节点级别的资源组划分&#xff0c;二是针对单…

明星录制祝福视频:传递温情与关怀的独特方式

在当今社交媒体和数字化时代&#xff0c;明星录制祝福视频已经成为一种新颖而独特的方式&#xff0c;用来表达温馨祝福、分享喜悦&#xff0c;或者为特殊的时刻增添一份特别的意义。无论是生日、结婚、毕业&#xff0c;还是节日、活动等&#xff0c;明星录制的祝福视频能够让人…

VUVLO电压监测器的工作原理、应用及性能分析 | 百能云芯

在现代电子设备中&#xff0c;电压监测是确保稳定性和可靠性的关键。VUVLO电压监测器是一种重要的电子元件&#xff0c;它的作用是监测电源电压&#xff0c;并在电压低于或高于设定值时触发相应的操作。在本文中&#xff0c;我们将深入探讨VUVLO电压监测器的工作原理、应用领域…

Windows下搭建MavLink通信协议环境,并用C++程序测试

搭建环境 git克隆 git clone https://github.com/mavlink/mavlink.git --recursive安装python的future库 pip install future使用可视化工具生成mavlink库 XML是选择消息格式&#xff0c;也可以自定义Out是输出路径Language是生成的语言&#xff0c;我这里是CProtocol是协议…

Linux--I/O复用之select

目录 一&#xff1a;概念 二&#xff1a;使用 三&#xff1a;参数介绍&#xff1a; 1.ndfs&#xff1a; 2.fd_set类型&#xff1a; 3.readfds&#xff1a; 4.writefds&#xff1a; 5.exceptfds&#xff1a; 6.timeout&#xff1a; 7.返回值&#xff1a; 四&#xff1…

1.2 互联网概述

思维导图&#xff1a; 主要内容 &#xff1a; 这段话描述了“互联网”的基本概念和组成。首先&#xff0c;强调了该段文本主要是关于计算机网络的讨论&#xff0c;而不是关于电信网络或有线电视网络。 接下来&#xff0c;描述了计算机网络的基本构成&#xff0c;由结点&…

23062网络编程day8

将dict.txt导入到数据库中&#xff08;单词一列&#xff0c;意思一列&#xff09; #include <myhead.h> int main(int argc, const char *argv[]) {//打开数据库sqlite3 *db;if(sqlite3_open("./dict.db",&db) ! SQLITE_OK){fprintf(stderr,"sqlite3…