Redis 和 MySQL 双写不一致问题

本文涉及的产品
RDS MySQL Serverless 基础系列,0.5-2RCU 50GB
Redis 开源版,标准版 2GB
推荐场景:
搭建游戏排行榜
云数据库 RDS MySQL,集群系列 2核4GB
推荐场景:
搭建个人博客
简介: Redis 和 MySQL 双写不一致问题

一、问题描述:


我的一个商品有 11 个库存,在一次活动中进行秒杀。


如果有 3 个线程:


  1. 第一个线程直接消费库存,剩余库存为 11 回写到数据库和缓存 stock = 10


  1. 第二个线程查询缓存库存为 10 ,消费库存回写到数据库和缓存 stock = 9


  1. 第三个线程查询缓存库存为 10 ,消费库存回写到数据库和缓存 stock = 9


  1. 第一个线程回写库存到缓存提交成功。如下图所示


image.png


二、解决方案


在读写缓存之前,增加一个 redis 的读写锁。


image.png


读写锁的特征:


  1. 读读并行


  1. 读写互斥


这样就可以巧妙的解决查询缓存数据不一致的问题,而且 lock 具备互斥性,也可以解决 缓存击穿问题。


看看我的代码(初稿,待优化):


注解定义,主要是定义缓存 key , 超时时间 timeOut 单位:毫秒,操作类型分为:read, write, delete 三种。


@Target({ElementType.METHOD, ElementType.ANNOTATION_TYPE})
@Retention(RetentionPolicy.RUNTIME)
@Documented
public @interface MultiCache {
    String key() default "";
    long timeOut() default 2000;
    String op() default "read"; //read, write, delete
}


aop 拦截,我主要是利用 aop 的方式来对缓存操作进行封装,方便复用。 分为两个步骤:


1、定义 Pointcut,具体见 multiCache() 方法;


2、定义 Around,具体见 multiCacheSupport(ProceedingJoinPoint pjp) 方法实现,涵盖了 readdeletewrite 缓存的三个操作处理。


@Pointcut("@annotation(io.zhengsh.redis.annotation.MultiCache)")
    public void multiCache() {
        // Pointcut
    }
    @Around("multiCache()")
    public Object multiCacheSupport(ProceedingJoinPoint pjp) throws Throwable {
        MethodSignature ms = (MethodSignature) pjp.getSignature();
        Method method = ms.getMethod();
        MultiCache multiCache = method.getAnnotation(MultiCache.class);
        String mkey = generateKey(multiCache.key(), pjp);
        try {
            if ("read".equals(multiCache.op())) {
                String retVal = multiCacheService.read(mkey);
                if (retVal != null && !"".equals(retVal.trim())) {
                    return JSON.parseObject(retVal, method.getReturnType());
                }
            }
            Object proceed = pjp.proceed();
            multiCacheService.write(mkey, "delete".equals(multiCache.op()) ? "" : JSON.toJSONString(proceed));
            return proceed;
        } catch (Throwable ex) {
            logger.info("multiCache err key: {}", mkey, ex);
            throw ex;
        }
    }


使用实例:两个方法介绍


1、createOrder 主要是用来创建订单, 消费库存(代码模拟)。缓存是一个删除操作


2、querySku 主要是用来查询库存信息,将查询出来的结果返回给客户端。


@MultiCache(key = "'order.seckill:'+ #orderDto.skuNo", timeOut = 10000, op = "delete")
    @GetMapping("/createOrder")
    public OrderDto createOrder(OrderDto orderDto) {
        //1.参数教研
        if (orderDto.getQuantity() == null || orderDto.getQuantity() < 1) {
            throw new RuntimeException("unknown error");
        }
        String key = String.format("order.stock:%s", orderDto.getSkuNo());
        Serializable serializable = redisTemplate.opsForValue().decrement(key, orderDto.getQuantity());
        if (serializable == null) {
            throw new RuntimeException("unknown error");
        }
        Integer stock = Optional.of(Integer.parseInt(String.valueOf(redisTemplate.opsForValue().get(key)))).orElse(0);
        OrderDto resultDto = new OrderDto();
        resultDto.setSkuNo(orderDto.getSkuNo());
        if (stock >= 0) {
            resultDto.setQuantity(orderDto.quantity);
        } else {
            resultDto.setQuantity(-1);
        }
        return resultDto;
    }
    @MultiCache(key = "'order.seckill:'+ #skuNo", timeOut = 10000)
    @GetMapping("/querySku/{skuNo}")
    public List<SkuDto> querySku(@PathVariable(value = "skuNo") String skuNo) {
        Serializable serializable = redisTemplate.opsForValue().get(String.format("order.stock:%s", skuNo));
        SkuDto skuDto1 = new SkuDto(skuNo, Optional.of(Integer.parseInt(String.valueOf(serializable))).orElse(0));
        return Arrays.asList(skuDto1, new SkuDto("SKU00008", -1));
    }


三、总结


Redis 和 MySQL 产生的原因主要是因为在分布式系统,多线程并发操作的时候出现,我的解决方式就是通过分布式读写锁 + 锁有限期 实现排队解决。


相关实践学习
基于Redis实现在线游戏积分排行榜
本场景将介绍如何基于Redis数据库实现在线游戏中的游戏玩家积分排行榜功能。
云数据库 Redis 版使用教程
云数据库Redis版是兼容Redis协议标准的、提供持久化的内存数据库服务,基于高可靠双机热备架构及可无缝扩展的集群架构,满足高读写性能场景及容量需弹性变配的业务需求。 产品详情:https://www.aliyun.com/product/kvstore &nbsp; &nbsp; ------------------------------------------------------------------------- 阿里云数据库体验:数据库上云实战 开发者云会免费提供一台带自建MySQL的源数据库&nbsp;ECS 实例和一台目标数据库&nbsp;RDS实例。跟着指引,您可以一步步实现将ECS自建数据库迁移到目标数据库RDS。 点击下方链接,领取免费ECS&amp;RDS资源,30分钟完成数据库上云实战!https://developer.aliyun.com/adc/scenario/51eefbd1894e42f6bb9acacadd3f9121?spm=a2c6h.13788135.J_3257954370.9.4ba85f24utseFl
相关文章
|
13天前
|
NoSQL Java 关系型数据库
Liunx部署java项目Tomcat、Redis、Mysql教程
本文详细介绍了如何在 Linux 服务器上安装和配置 Tomcat、MySQL 和 Redis,并部署 Java 项目。通过这些步骤,您可以搭建一个高效稳定的 Java 应用运行环境。希望本文能为您在实际操作中提供有价值的参考。
76 26
|
1月前
|
缓存 NoSQL 关系型数据库
Redis和Mysql如何保证数据⼀致?
在项目中,为了解决Redis与Mysql的数据一致性问题,我们采用了多种策略:对于低一致性要求的数据,不做特别处理;时效性数据通过设置缓存过期时间来减少不一致风险;高一致性但时效性要求不高的数据,利用MQ异步同步确保最终一致性;而对一致性和时效性都有高要求的数据,则采用分布式事务(如Seata TCC模式)来保障。
64 14
|
1月前
|
存储 NoSQL 关系型数据库
MySQL和Redis的区别
**MySQL和Redis的区别** MySQL和Redis都是流行的数据存储解决方案,但它们在设计、用途和特性上有显著区别。理解这些区别有助于选择合适的数据库来满足不同的应用需求。本文将详细介绍MySQL和Redis的区别,包括它们的架构、使用场景、性能和其他关键特性。 ### 一、基本概述 **MySQL**: MySQL是一个关系型数据库管理系统(RDBMS),使用结构化查询语言(SQL)进行数据管理。它支持事务、复杂查询和多种存储引擎,广泛应用于各种Web应用、企业系统和数据分析项目。 **Redis**: Redis是一个基于内存的键值数据库,通常被称为NoSQL数
71 4
|
1月前
|
SQL NoSQL 关系型数据库
2024Mysql And Redis基础与进阶操作系列(13)作者——LJS[你个小黑子这都还学不会嘛?你是真爱粉嘛?真是的 ~;以后请别侮辱我家鸽鸽]
MYSQL日志之详解如何配置查看二进制、查询及慢查询日志;备份与恢复等具体详解步骤;举例说明、注意点及常见报错问题所对应的解决方法
2024Mysql And Redis基础与进阶操作系列(13)作者——LJS[你个小黑子这都还学不会嘛?你是真爱粉嘛?真是的 ~;以后请别侮辱我家鸽鸽]
|
13天前
|
关系型数据库 MySQL 数据库
Python处理数据库:MySQL与SQLite详解 | python小知识
本文详细介绍了如何使用Python操作MySQL和SQLite数据库,包括安装必要的库、连接数据库、执行增删改查等基本操作,适合初学者快速上手。
89 15
|
7天前
|
SQL 关系型数据库 MySQL
数据库数据恢复—Mysql数据库表记录丢失的数据恢复方案
Mysql数据库故障: Mysql数据库表记录丢失。 Mysql数据库故障表现: 1、Mysql数据库表中无任何数据或只有部分数据。 2、客户端无法查询到完整的信息。
|
14天前
|
关系型数据库 MySQL 数据库
数据库数据恢复—MYSQL数据库文件损坏的数据恢复案例
mysql数据库文件ibdata1、MYI、MYD损坏。 故障表现:1、数据库无法进行查询等操作;2、使用mysqlcheck和myisamchk无法修复数据库。
|
18天前
|
SQL 关系型数据库 MySQL
MySQL导入.sql文件后数据库乱码问题
本文分析了导入.sql文件后数据库备注出现乱码的原因,包括字符集不匹配、备注内容编码问题及MySQL版本或配置问题,并提供了详细的解决步骤,如检查和统一字符集设置、修改客户端连接方式、检查MySQL配置等,确保导入过程顺利。
|
26天前
|
关系型数据库 MySQL 数据库
GBase 数据库如何像MYSQL一样存放多行数据
GBase 数据库如何像MYSQL一样存放多行数据
|
1月前
|
SQL 关系型数据库 MySQL
12 PHP配置数据库MySQL
路老师分享了PHP操作MySQL数据库的方法,包括安装并连接MySQL服务器、选择数据库、执行SQL语句(如插入、更新、删除和查询),以及将结果集返回到数组。通过具体示例代码,详细介绍了每一步的操作流程,帮助读者快速入门PHP与MySQL的交互。
39 1