秒杀技术实现核心思想是:运用缓存减少数据库瞬间的访问压力
读取商品详细信息:运用缓存,当用户点击抢购时减少缓存中的库存数量,当库存数为0时或活动期结束时,同步到数据库
产生的秒杀预订单:也不会立刻写到数据库中,而是先写到缓存,当用户付款成功后再写入数据库
秒杀由B端存入MYSQL,设置定时任务,每隔一段时间就从MYSQL中将符合条件的数据从MYSQL中查询出来并存入缓存中,redis以Hash类型进行数据存储(namespace=时间,key=商品id,value=商品信息)。
注意:为每个商品维护一个队列List,该List的长度就是每个商品的库存数,借助redis队列,保证库存原子性操作,避免超卖问题
(重复抢单)解决重复抢单问题(redis的incr):(即使多线程同时请求,redis是单线程的,也没问题)
一个用户最多只允许一个排队信息存在
一个用户最多只有一个未支付订单
Long userQueueCount = redisTemplate.boundHashOps("UserQueueCount").increment(username, 1);
if (userQueueCount > 1) {
//重复抢单
throw new RuntimeException("重复抢单!!!");
}
(保证执行顺序,传递参数 [用户信息/时间/商品id ])创建redis排队队列,存储用户信息
//存入redis中,list排队(左存右取)
redisTemplate.boundListOps("SeckillOrderQueue").leftPush(seckillStatus);
(单独查询状态)用户查询秒杀订单状态队列
//再次维护一个队列,方便用户查询自己的秒杀订单状态
//用户抢单状态-->用于用户查询
redisTemplate.boundHashOps("UserQueueStatus").put(username, seckillStatus);
(提高效率)多线程异步执行创建订单
threadCreateOrderTask.createOrder();
@Async
public void createOrder() {
//... ...
}
多线程下单(订单创建)
5.1 redis队列,保证了订单顺序,传递的了参数
//获取Redis中排队用户信息
SeckillStatus seckillStatus = (SeckillStatus)redisTemplate.boundListOps("SeckillOrderQueue").rightPop();
if (seckillStatus == null) {
//没有秒杀订单
return;
}
//获取订单信息
//略
5.2 redis队列,避免超卖问题,结构:商品id,对应商品库存
//先从SeckillGoodsQueue中获取商品的库存队列信息( 在判断库存之前执行 )
Object rightPop = redisTemplate.boundListOps("SeckillGoodsQueue_" +seckillStatus.getGoodsId()).rightPop();
//如果没有获取到商品的库存队列,没有库存,清空排队信息,终止该方法
if (rightPop == null) {
//清理掉排队信息
redisTemplate.boundHashOps("UserQueueCount").delete(username);//用户重复抢单
redisTemplate.boundHashOps("UserQueueStatus").delete(username);//用户秒杀状态
System.out.println("没有获取到商品的库存队列,没有库存,清空排队信息... ...");
return;
}
5.3 redis中存储了库存,获取判断库存
(获取时间段的商品列表中的某一个具体的商品【id:库存】)
//判断库存(获取时间段的商品列表中的某一个具体的商品【id:库存】)
SeckillGoods seckillGoods = (SeckillGoods) redisTemplate.boundHashOps(SECKILL_KEY + time).get(id);
if (seckillGoods == null || seckillGoods.getStockCount() <= 0) {
throw new RuntimeException("卖完了!");
}
//创建订单
SeckillOrder seckillOrder = new SeckillOrder();
seckillOrder.setSeckillId(id);
seckillOrder.setMoney(seckillGoods.getCostPrice());
seckillOrder.setUserId(username);
seckillOrder.setCreateTime(new Date());
seckillOrder.setStatus("0");
5.4 订单保存 / 状态修改
//保存订单到Redis,每人只能秒杀一次(订单保存)
redisTemplate.boundHashOps("SeckillOrder_").put(username, seckillOrder);
//修改用户抢单状态
seckillStatus.setStatus(2);//待付款状态 seckillStatus.setMoney(Float.valueOf(seckillGoods.getCostPrice().toString()));
seckillStatus.setOrderId(seckillOrder.getId());
redisTemplate.boundHashOps("UserQueueStatus").put(username, seckillStatus);
5.5 库存递减,redis队列长度作为库存量判断,内存中的数据不准确
//库存递减
seckillGoods.setStockCount(seckillGoods.getStockCount() - 1);
/** 库存不精确解决方案:应该获取redis中的真实长度,但是不方便获取,因此可以获取redis队列的长度。内存中的数据不可信*/
//获取到秒杀商品的库存队列,长度就是剩余库存数,最准确的库存数
Long size = redisTemplate.boundListOps("SeckillGoodsQueue_" +seckillGoods.getGoodsId()).size();
//当前购买的商品就是最后一件:redis中该商品记录移除
//内存中库存数,不准确 :if (seckillGoods.getStockCount() <= 0) {
if (size <= 0) {
//同步库存数量(将队列的长度同步到seckillGoods对象中)
seckillGoods.setStockCount(size.intValue());
//将数据同步到Mysql中(库存为0了)
seckillGoodsMapper.updateByPrimaryKeySelective(seckillGoods);
//移除Redis中该商品的数据
redisTemplate.boundHashOps(SECKILL_KEY + time).delete(id);
} else {
//将库存数据更新到Redis(更新库存递减之后的商品信息)
redisTemplate.boundHashOps(SECKILL_KEY + time).put(id, seckillGoods);
}
文章浏览阅读819次。用于切换当前用户身份到其他用户身份,变更时须输入所要变更的用户帐号与密码。用于切换当前用户身份到其他用户身份。用户:指定要切换身份的目标用户。变更帐号为root并传入。su(选项)(参数)_linux su命令
文章浏览阅读2.1k次。 root@ubuntu:/home/gap/jdk8u# make WARNING: You have the following ALT_ variables set:ALT_OUTPUTDIR=/home/gap/buildALT_ variables are deprecated and will be ignored. Please clean your envi..._langtools: langtools-only
文章浏览阅读9.4k次,点赞13次,收藏120次。超详细,半天让你使用好yolov8代码_yolov8环境配置
文章浏览阅读296次。题目:一张名为workersalary的表,要求查询出全部信息,并且salary最高的三个人按升序排列在结果的最开头,其余的人按原有顺序排列。这个sql如何写?解答:(1)题意理解假如原先的表是这样的namesalaryLiuYi2000ChenEr1000ZhangSan5000LiSi4000WangWu8000ZhaoLiu6000SunQi7000ZhouBa3000题目要求变成这样nam..._sql面试必会6题经典oracle必问的面试题
文章浏览阅读1.1k次,点赞8次,收藏9次。有关LoRA模型的原理_下面哪个参数用来控制lora适配器的矩阵大小
文章浏览阅读241次。![](http://my-blog-to-use.oss-cn-beijing.aliyuncs.com/18-9-10/56385654.jpg)## 前言相信大家对 ZooKeeper 应该不算陌生。但是你真的了解 ZooKeeper 是个什么东西吗?如果别人/面试官让你给他讲讲 ZooKeeper 是个什么东西,你能回答到什么地步呢?我本人曾经使用过 ZooKeeper 作为...
文章浏览阅读3.9w次,点赞26次,收藏32次。Jupyter NoteBook 中使用 cv2.imshow 显示图片有两种办法:用 cv2.imshow时加入cv2.destroyAllWindows()用 plt.imshow() 代替 cv2.imshow1. cv2.imshow加入 cv2.destroyAllWindows() 后可以解决 crash 或者图片显示不出来的问题。import cv2%matplot..._jupyter cv2.imshow
文章浏览阅读40次。在Android手机中内置了一款高性能webkit内核浏览器,在SDK中封装为一个叫做WebView组件。一、使用WebView1.加入权限 <uses-permission android:name="android.permission.INTERNET" />2.创建一个webView通过布局 <WebView ...
文章浏览阅读581次。Python部落(python.freelycode.com)组织翻译,禁止转载,欢迎转发。Scribus是一个强大的开源页面布局应用程序,它是由开源社区自2001年开发的程序。据项目网站可知,Scribus是为Linux,FreeBSD,PC-BSD,NetBSD,OpenBSD,Solaris和程序提供 CMYK颜色,专色,ICC颜色管理和PDF创建的程序。该网站还支持应用程序的高级功能,如矢..._python绘制饼图保存本地
文章浏览阅读475次。《计算机科学导论》期末考试试题(B卷)班级:姓名:学号:成绩:一、单项选择题1. 用一个字节表示无符号整数,其最大值是十进制数()。A. 256B. 255C. 127D. 1282. 一个完整的计算机系统应包括()。A. 运算器、控制器和存储器B. 主机和应用程序C. 硬件系统和软件系统D. 主机和外部设备3. 微机中的CPU是指()。A. 内存和运算器B. 输入设备和输出设备C. 存储器和控..._计算机科学导论期末题
文章浏览阅读1.8k次,点赞3次,收藏3次。本次将讲述mybatis的配置,主要的配置是基于mybatis的配置文件来进行配置的,其配置文件并不复杂,如下面的例子: _
文章浏览阅读65次。http://forums.sdn.sap.com/thread.jspa?tstart=0&threadID=798957&messageID=5120111 ..._datasource的enhancement