Redis--延时双删策略

延时双删策略的核心目的是解决在高并发环境下可能出现的短暂不一致性问题。让我们来详细看一下在极端并发情况下,为什么需要延时双删。

更复杂的并发场景

假设我们有如下更复杂的并发场景:

  1. 用户A将库存从100更新为50,并删除缓存。
  2. 用户B在用户A删除缓存之后读取缓存,发现缓存为空,然后从数据库中读取数据并写入缓存。
  3. 用户C在用户A删除缓存之前,读取缓存并写入缓存旧数据100。
步骤1:用户A更新数据库并第一次删除缓存
// 用户A更新数据库
String sqlUpdateQuery = "UPDATE inventory SET stock = 50 WHERE product_id = 1";
updateDatabase(sqlUpdateQuery);// 第一次删除缓存
redis.del("product_1_stock");

步骤2:用户B读取缓存(缓存为空)并加载数据

// 用户B读取缓存,发现缓存为空,从数据库加载数据
String stock = redis.get("product_1_stock");
if (stock == null) {stock = loadStockFromDatabase(1); // 从数据库加载数据redis.set("product_1_stock", stock); // 将数据写入缓存
}
步骤3:用户C在用户A删除缓存之前读取缓存
  1. 用户A将库存从100更新为50,并删除缓存。
  2. 用户C在缓存删除之前读取缓存中的旧数据100,并在某个时刻将其重新写入缓存。

问题

用户C在缓存删除之前读取到了旧数据100,并将其写入缓存。如果用户C的写入操作晚于用户A的第一次删除操作,那么缓存中会重新出现旧数据100。

示例代码

Java代码示例
import redis.clients.jedis.Jedis;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;public class DelayedDoubleDeletionExample {private static Jedis redis = new Jedis("localhost", 6379);private static String dbUrl = "jdbc:mysql://localhost:3306/mydb";private static String dbUser = "user";private static String dbPassword = "password";// 更新数据库public static void updateDatabase(String sqlUpdateQuery) {try (Connection conn = DriverManager.getConnection(dbUrl, dbUser, dbPassword);PreparedStatement pstmt = conn.prepareStatement(sqlUpdateQuery)) {pstmt.executeUpdate();conn.commit();} catch (SQLException e) {e.printStackTrace();}}// 从数据库加载库存数据public static String loadStockFromDatabase(int productId) {String stock = null;String query = "SELECT stock FROM inventory WHERE product_id = ?";try (Connection conn = DriverManager.getConnection(dbUrl, dbUser, dbPassword);PreparedStatement pstmt = conn.prepareStatement(query)) {pstmt.setInt(1, productId);ResultSet rs = pstmt.executeQuery();if (rs.next()) {stock = rs.getString("stock");}} catch (SQLException e) {e.printStackTrace();}return stock;}// 更新数据库并处理缓存(包含延时双删)public static void updateDatabaseAndCache(String sqlUpdateQuery, String cacheKey, long delayInMillis) {// 更新数据库updateDatabase(sqlUpdateQuery);// 第一次删除缓存redis.del(cacheKey);// 延时try {Thread.sleep(delayInMillis);} catch (InterruptedException e) {e.printStackTrace();}// 第二次删除缓存redis.del(cacheKey);}public static void main(String[] args) {String sqlUpdateQuery = "UPDATE inventory SET stock = 50 WHERE product_id = 1";String cacheKey = "product_1_stock";long delayInMillis = 2000; // 2秒延时// 模拟用户A更新数据库并执行延时双删new Thread(() -> {updateDatabaseAndCache(sqlUpdateQuery, cacheKey, delayInMillis);}).start();// 模拟用户B读取缓存new Thread(() -> {// 延时模拟用户B读取数据的操作延时try {Thread.sleep(1000); // 延时1秒} catch (InterruptedException e) {e.printStackTrace();}String stock = redis.get(cacheKey);if (stock == null) {stock = loadStockFromDatabase(1); // 从数据库加载数据redis.set(cacheKey, stock); // 将数据写入缓存}System.out.println("User B read stock: " + stock);}).start();// 模拟用户C读取缓存并写入旧数据new Thread(() -> {// 延时模拟用户C在用户A删除缓存之前读取数据的操作延时try {Thread.sleep(500); // 延时0.5秒} catch (InterruptedException e) {e.printStackTrace();}String stock = redis.get(cacheKey);if (stock == null) {// 假设此时用户C读取到了旧数据100(模拟旧数据的写入)redis.set(cacheKey, "100"); // 将旧数据写入缓存}System.out.println("User C read stock and wrote back old data: 100");}).start();}
}

解释

  1. 用户A更新数据库并第一次删除缓存

    • updateDatabaseAndCache方法更新数据库中的库存数据并删除缓存。
  2. 用户B读取缓存并加载数据

    • 用户B在缓存为空时,从数据库加载数据(正确的50)并写入缓存。
  3. 用户C在缓存删除之前读取缓存并写入旧数据

    • 用户C读取缓存时缓存为空,然后假设用户C读取到的是旧数据100,并将其写入缓存。

结果

  • 数据库中的数据:50
  • 缓存中的数据:100

延时双删的作用

为了避免用户C在用户A第一次删除缓存后写入的旧数据造成缓存和数据库数据不一致,用户A在延时后再次删除缓存:

// 第二次删除缓存
redis.del(cacheKey);

通过第二次删除缓存,可以确保即使有其他线程在用户A第一次删除缓存后写入旧数据,延时后缓存仍会被清除,确保缓存和数据库数据最终一致。

总结

延时双删策略在高并发环境下,通过在第一次删除缓存后延时一段时间进行第二次删除缓存,确保缓存和数据库中的数据一致,避免并发操作带来的数据不一致问题。

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

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

相关文章

用Nuitka打包 Python,效果竟如此惊人!

目录 为什么选择Nuitka? Nuitka的工作原理 Nuitka的工作流程大致如下: 安装Nuitka 实战案例 示例代码 打包程序 运行可执行文件 进阶技巧 优化选项 多文件项目 打包第三方库 使用Python开发一个程序后,将Python脚本打包成独立可执…

Milvus向量数据库:处理和分析大规模向量数据

目录 一 Milvus概述 性能 可扩展性 易用性 二 Milvus的核心技术 1 向量索引 HNSW IVF PQ 2 GPU加速 3 分布式架构 分布式 三 深入了解Milvus的技术细节 1 存储机制 持久化存储 内存存储 2 数据导入与导出 批量导入 实时导入 3 高可用性与容灾机制 数据副本…

由浅入深,走进深度学习(2)

今天分享的学习内容主要就是神经网络里面的知识啦,用到的框架就是torch 在这里我也是对自己做一个学习记录,如果不符合大家的口味,大家划走就可以啦 可能没有什么文字或者原理上的讲解,基本上都是代码,但是我还是想说…

深度神经网络——决策树的实现与剪枝

概述 决策树 是一种有用的机器学习算法,用于回归和分类任务。 “决策树”这个名字来源于这样一个事实:算法不断地将数据集划分为越来越小的部分,直到数据被划分为单个实例,然后对实例进行分类。如果您要可视化算法的结果&#xf…

Web开发的未来:深入Symfony框架的全方位指南

Symfony是一款强大的PHP框架,用于开发高性能的Web应用。它提供了一套完整的工具和API,帮助开发者构建从简单的博客到复杂的企业级应用。本文将全面介绍Symfony框架的基本概念、使用方法、主要作用以及注意事项。 一、Symfony框架简介 1. Symfony的起源 …

58.最后一个单词的长度

给你一个字符串 s,由若干单词组成,单词前后用一些空格字符隔开。返回字符串中 最后一个 单词的长度。 单词 是指仅由字母组成、不包含任何空格字符的最大 子字符串 。 示例 1: 输入:s "Hello World" 输出&#xff…

数据结构5---矩阵和广义表

一、矩阵的压缩存储 特殊矩阵:矩阵中很多值相同的元素并且它们的分布有一定的规律。 稀疏矩阵:矩阵中有很多零元素。压缩存储的基本思想是: (1)为多个值相同的元素只分配一个存储空间; (2)对零元素不分配存储空间。 1、特殊矩阵的压缩存储 (1)对称矩…

【机器学习】必会降维算法之:随机投影(Random Projection)

随机投影(Random Projection) 1、引言2、随机投影(Random Projection)2.1 定义2.2 核心原理2.3 应用场景2.4 实现方式2.5 算法公式2.6 代码示例 3、总结 1、引言 小屌丝:鱼哥,降维算法还没讲完呢。 小鱼&a…

浙江保融科技2025实习生校招校招笔试分享

笔试算法题一共是有4道,第一道是手搓模拟实现一个ArrayList,第二道是判断字符串是否回文,第三道是用代码实现1到2种设计模式。 目录 一.模拟实现ArrayList 二.判断字符串是否回文 ▐ 解法一 ▐ 解法二 ▐ 解法三 三.代码实现设计模式 一…

网络协议安全:TCP/IP协议栈的安全问题和解决方案

「作者简介」:北京冬奥会网络安全中国代表队,CSDN Top100,就职奇安信多年,以实战工作为基础对安全知识体系进行总结与归纳,著作适用于快速入门的 《网络安全自学教程》,内容涵盖Web安全、系统安全等12个知识域的一百多个知识点,持续更新。 这一章节我们需要知道TCP/IP每…

大模型扫盲系列——大模型实用技术介绍_大模型底层技术是哪些

Gemma模型架构和参数计算 近期,大模型相关的技术和应用层出不穷,各个方向的论文百花齐放,底层的核心技术是大家公认的精华部分。本文从技术的角度聚焦大模型的实战经验,总结大模型从业者关注的具体方向以及相关发展,帮…

干货 | 如何进行群体DNA甲基化分析

目前,针对群体的研究基本上还是以重测序为主,基于对遗传多样性丰富的自然群体中的个体进行全基因组重测序,研究物种遗传进化多样性,结合准确的目标性状的表型数据及统计方法进行全基因组关联分析,可对动植物复杂农艺性…

网络性能测试工具 iperf

简介 Iperf 是一个网络性能测试工具,可以测试最大TCP和UDP带宽性能,具有多种参数和UDP特性,可以根据需要调整,可以报告带宽、延迟抖动和数据包丢失。 官网地址:iPerf - Download iPerf3 and original iPerf pre-comp…

shell 脚本批量导入、导出docker images

目录: 需要将运行中的docker 容器批量出,并在新的主机上批量导入。 创建批量导出脚本 export_docker_images.sh #!/bin/bash# 检查 Docker 是否在运行 if ! docker info > /dev/null 2>&1; thenecho "Docker 似乎没有运行。请确保 Dock…

MEME使用-motif分析(生物信息学工具-24)

01 背景 Motif分析是一种在生物信息学和计算生物学中广泛应用的技术,用于识别DNA、RNA或蛋白质序列中具有生物学功能的短保守序列模式(motif)。这些motif通常与特定的生物学功能相关,如DNA中的转录因子结合位点、RNA中的剪接位点…

最新Springboot小程序医院核酸检测服务系统

采用技术 最新Springboot小程序医院核酸检测服务系统的设计与实现~ 开发语言:Java 数据库:MySQL 技术:SpringBootMyBatis 工具:IDEA/Ecilpse、Navicat、Maven 页面展示效果 管理员页面 医护人员管理 普通管理员管理 接种进…

稳定安全生产设备日志采集工具

免费试用下载: Gitee下载 最新版本 优势: A. 开箱即用. 解压直接运行.不需额外安装. B. 批管理设备. 设备配置均在后台管理. C. 无人值守 客户端自启动,自更新. D. 稳定安全. 架构简单,内存占用小,通过授权访问.

vector oj题 和 位运算

知识点1: lowbit(x) 简介:众所周知,lowbit()操作是算法竞赛中的高级技巧,特别是高级数据结构,线段树的核心,还有什么二进制与位运算题目,而本文就用最通俗易懂的话,来教会大家lowbi…

mysql手工命令备份与自动备份

1、手工备份数据库数据 进入命令目录:cd /usr/local/mysql/bin,确保该目录下有mysqldump 然后在命令行 输入 mysqldump -u root -p dbname > dbname_backup_20240612.sql 注意,这里的dbname 是指你想要备份的数据库的名字。 通过这个命…

go-zero 安装

1.安装goctl 工具 go install github.com/zeromicro/go-zero/tools/goctllatest 2.安装protoc goctl env check --install --verbose --force 3.创建项目总目录 gozero_stusy (此目录为总目录,下面有多个服务,每个服务一个目录 比如 use…