当前位置: 首页 > news >正文

分布式秒杀方案--java

前提:先把商品详情和秒杀商品缓存redis中,减少对数据库的访问(可使用定时任务)
秒杀商品无非就是那几步(前面还可能会有一些判断,如用户是否登录,一人一单,秒杀时间验证等)
1一人一单
2.判断库存
3.减库存
4.创建订单

秒杀需要解决的问题?

1.解决超卖问题

1.1这样秒杀肯定会出现超卖的情况,所以必须加锁。加锁无非就两种锁,乐观锁和悲观锁。
悲观锁:直接在1前上锁即可,这里使用redisson里的可重入锁

        // 获取分布式锁对象RLock lock = redissonClient.getLock("seckillLock");try {//等待5秒获取锁,执行60秒还是没有释放锁就强制释放boolean b = lock.tryLock(5L, 60L, TimeUnit.SECONDS);if (b){SeckillProductVo  seckillProductVo = seckillProductService.find(time, seckillId);//1.保证库存足够if (seckillProductVo.getStockCount()<=0){return Result.error(SeckillCodeMsg.SECKILL_STOCK_OVER);}//下面两个方法必须写在一起避免事务未提交,未扣减库存就释放锁//2.扣减库存//3.生成订单orderInfo=orderInfoService.doSeckill(phone,seckillProductVo);}} catch (InterruptedException e) {e.printStackTrace();} finally {lock.unlock();}

1.2乐观锁:这个就不需要用代码演示了
1一人一单
2.判断库存
3.减库存
4.创建订单

在3.减库存的时候mysql语句 and 库存>0即可,MySQL会有自己的行锁。所以每次只会执行一次修改操作。以上两个方法都不会造成超卖
但是却未能解决秒杀问题,原因高并发请求都进入了数据库来查库,会造成数据库崩溃或阻塞其它mysql的执行。

2.重复下单问题,如何解决?

2.1 在4.创建订单后,把用户的唯一标识,id或phone存入redis的set中 key->{phone1,phone2}
redisTemplate.opsForSet().isMember(orderKey,phone)返回true或false
流程变成 1.一人一单 2.判断库存 3.减库存 4.创建订单 5.redisTemplate.opsForSet().add(orderKey,phone);

2.2 但是这样并不能完全解决重复下单,比如用户同时点了两次请求。极端条件下,a线程进入步骤1的判断,从1到4 需要进行很多操作,当a线程未走到5时,b线程就进来了这样也会造成重复下单。所以必须使用数据库的唯一索引进行解决,把用户唯一标识和秒杀商品唯一标识做成唯一索引即可解决
在这里插入图片描述
也就是在 4.创建订单 的时候会出现报错,3库存减掉之后数据回滚即可。
然而redis里的库存却和数据库的就不一样了,redis是无法被回滚的。后面会使用cannal对数据库和redis的库存进行同步。。。
有些人可能会说了,2.1没有解决重复问题,为什么不直接用2.2解决?2.1在大部分情况下都能解决,避免有人多次点击秒杀对数据造成压力,所以2.1和2.2一起使用才是最佳的选择

3.流量控制
3.1 必须把请求拦截在数据库之外,如果库存只有10个,也只有10个线程能最终到达数据库就是一个比较理想的方案
所以把数据库的秒杀商品库存存入redis中,进行预售,只有redis里能执行-1操作才能进入service,这样就极大的减少了请求到service层中

3.2 如果同一个秒杀时间段有多个商品 如100个秒杀商品,每个秒杀商品的库存为10个,那么就会有10*100个请求到达数据库,如果是淘宝的双11显然秒杀的商品会更多。那么我们就需要进行流量的削峰控制。
在这里插入图片描述
从controller中拦截消息,service取消息的时候慢慢拿,mq能够占时的让一部分请求存储在里面排队处理,service根据自己的处理能力去拿。有些人可能会说排队处理不是很慢?在controller中发完消息这个请求已经可以算是结束了,用户不会立即看到抢购结果。后面经过
在这里插入图片描述

在这里插入图片描述
最终方案
在这里插入图片描述

http://www.lryc.cn/news/159337.html

相关文章:

  • 高频golang面试题:简单聊聊内存逃逸?
  • 【2023年数学建模国赛C题解题思路】
  • Jenkins+Allure+Pytest的持续集成
  • yo!这里是进程控制
  • 多线程快速入门
  • Redis 7 第七讲 哨兵模式(sentinal)架构篇
  • laravel框架系列(一),Dcat Admin 安装
  • Linux:工具(vim,gcc/g++,make/Makefile,yum,git,gdb)
  • 小节1:Python字符串打印
  • 2023国赛C题解题思路代码及图表:蔬菜类商品的自动定价与补货决策
  • 数据可视化工具中的显眼包:奥威BI自带方案上阵
  • LeetCode算法心得——生成特殊数字的最少操作(贪心找规律)
  • 【2023高教社杯】B题 多波束测线问题 问题分析、数学模型及参考文献
  • 如何处理异步编程中的回调地狱问题?
  • 什么是Lambda表达式?
  • 公式trick备忘录
  • 向量数据库Milvus Cloud核心组件再升级,主打就是一个低延迟、高准确度
  • ELK框架Logstash配合Filebeats和kafka使用
  • 后端面试话术集锦第 十二 篇:java基础部分面试话术
  • 【广州华锐互动】电厂三维数字孪生大屏的功能和优势
  • es6解构用法
  • a_bogus 音 算法还原大赏
  • 【计算机网络】UDP协议详解
  • 2023-9-8 满足条件的01序列
  • 获取街道、乡镇级的地图geoJson数据,使用echarts绘制地图
  • DBMS_RESOURCE_MANAGER
  • 通俗讲解傅里叶变换
  • 数据结构——带头双向循环链表
  • MySQL大数据量高速迁移,500GB只需1个小时
  • kafka复习:(25)kafka stream