合秒杀业务

秒杀的主要目的就是获取一个下单资格拥有下单资格就可以去下单支付获取下单资格后的流程就与正常下单流程一样只是没有购物车这一

步总结起来就是秒杀根据库存获取下单资格拥有下单资格进入下单页面选择地址支付方式提交订单然后支付订单

校验下单码只有正确获得下单码的请求才是合法请求校验状态位state

State为null说明非法请求

状态位是在内存中判断效率极高如果售罄直接就返回了不会给服务器造成太大压力

前面条件都成立将秒杀用户加入队列然后直接返回前端轮询秒杀状态查询秒杀结果

2秒杀下单

queue.seckill.user;定义实体UserRecode

记录哪个用户要购买哪个商品

}编写控制器SeckillGoodsApiController

Autowired

PostMapping(auth/seckillOrder/{skuId})

public

seckillOrder(PathVariable(skuId)

Long

AuthContextHolder.getUserId(request);String

skuIdStr

request.getParameter(skuIdStr);if

(!skuIdStr.equals(MD5.encrypt(userId)))

{//请求不合法return

ResultCodeEnum.SECKILL_ILLEGAL);}//校验状态位//产品标识

0秒杀结束String

CacheHelper.get(skuId.toString());if

{//请求不合法return

ResultCodeEnum.SECKILL_ILLEGAL);}if

(1.equals(state))

UserRecode();userRecode.setUserId(userId);userRecode.setSkuId(skuId);//发送消息rabbitService.sendMessage(MqConst.EXCHANGE_DIRECT_SECKILL_USER,

userRecode);}

ResultCodeEnum.SECKILL_FINISH);}return

Result.ok();

com.atguigu.gmall.common.result;import

io.swagger.annotations.ApiModel;

import

io.swagger.annotations.ApiModelProperty;

import

null)result.setData(data);return

result;}public

build(body);result.setCode(resultCodeEnum.getCode());result.setMessage(resultCodeEnum.getMessage());return

result;}public

ResultCodeEnum.SUCCESS);}public

staticT

msg){this.setMessage(msg);return

this;}public

code){this.setCode(code);return

this;}public

ResultCodeEnum.SUCCESS.getCode().intValue())

{return

com.atguigu.gmall.common.result;import

lombok.Getter;/***

正在排队中),SECKILL_NO_PAY_ORDER(212,

请求不合法),SECKILL_ORDER_SUCCESS(218,

优惠券已发放完毕),;private

首先判断产品状态位我们前面不是已经判断过了吗因为产品可能随时售罄mq队列里面可能堆积了十万数据但是已经售罄了那么后续流程就没有必要再走了判断用户是否已经下过订单这个地方就是控制用户重复下单同一个用户只能抢购一个下单资格怎么控制呢很简单我们可以利用setnx控制用户当用户第一次进来时返回true可以抢购以后进入返回false直接返回过期时间可以根据业务自定义这样用户这一段咋们就控制注了获取队列中的商品如果能够获取则商品有库存可以下单。

如果获取的商品id为空则商品售罄商品售罄我们要第一时间通知兄弟节点更新状态位所以在这里发送redis广播将订单记录放入redis缓存说明用户已经获得下单资格秒杀成功秒杀成功要更新库存

Autowired

MqConst.QUEUE_SECKILL_USER,durable

true,autoDelete

MqConst.EXCHANGE_DIRECT_SECKILL_USER),key

public

预下单处理seckillGoodsService.seckillOrder(userRecode.getSkuId(),userRecode.getUserId());}}

catch

手动确认channel.basicAck(message.getMessageProperties().getDeliveryTag(),false);

/***

com.atguigu.gmall.model.activity;Data

public

CacheHelper.get(skuId.toString());if(0.equals(state))

{//已售罄return;}//判断用户是否下单boolean

isExist

redisTemplate.opsForValue().setIfAbsent(RedisConst.SECKILL_USER

userId,

{return;}//获取队列中的商品取List中的一个从右边出来一个如果能够获取则商品存在可以下单String

goodsId

redisTemplate.boundListOps(RedisConst.SECKILL_STOCK_PREFIX

skuId).rightPop();if

发布订阅消息商品已经销售完了redisTemplate.convertAndSend(seckillpush,

skuId:0);//已售罄return;}//订单记录OrderRecode

orderRecode

OrderRecode();orderRecode.setUserId(userId);orderRecode.setSeckillGoods(this.getSeckillGoods(skuId));orderRecode.setNum(1);//生成订单单码orderRecode.setOrderStr(MD5.encrypt(userIdskuId));//订单数据存入ReidsredisTemplate.boundHashOps(RedisConst.SECKILL_ORDERS).put(orderRecode.getUserId(),

orderRecode);//更新库存this.updateStockCount(orderRecode.getSeckillGoods().getSkuId());

}更新库存

RedisConst.SECKILL_STOCK_PREFIX

skuId;//

redisTemplate.opsForList().leftPush(key,seckillGoods.getSkuId());//获取库存//Long

count

this.redisTemplate.boundListOps(RedisConst.SECKILL_STOCK_PREFIX

skuId).size();Long

redisTemplate.boundListOps(stockKey).size();//

减少库存数方式一减少压力!//if

赋值剩余库存数seckillGoods.setStockCount(count.intValue());//

更新的数据库seckillGoodsMapper.updateById(seckillGoods);//

更新缓存redisTemplate.boundHashOps(RedisConst.SECKILL_GOODS).put(seckillGoods.getSkuId().toString(),seckillGoods);//}}

finally

this.redisTemplate.boundHashOps(RedisConst.SECKILL_GOODS).get(skuId.toString());}

减少一个之前9个

redisTemplate.hasKey(RedisConst.SECKILL_USER

userId);if

{//判断用户是否正在排队//判断用户是否抢单成功boolean

isHasKey

redisTemplate.boundHashOps(RedisConst.SECKILL_ORDERS).hasKey(userId);if

(isHasKey)

redisTemplate.boundHashOps(RedisConst.SECKILL_ORDERS).get(userId);//

秒杀成功

ResultCodeEnum.SECKILL_SUCCESS);}}//判断是否下单查询总订单

seckill:orders:users

redisTemplate.boundHashOps(RedisConst.SECKILL_ORDERS_USERS).hasKey(userId);if(isExistOrder)

{String

(String)redisTemplate.boundHashOps(RedisConst.SECKILL_ORDERS_USERS).get(userId);return

ResultCodeEnum.SECKILL_ORDER_SUCCESS);}String

state

CacheHelper.get(skuId.toString());if(0.equals(state))

{//已售罄

ResultCodeEnum.SECKILL_FAIL);}//正在排队中return

Result.build(null,

AuthContextHolder.getUserId(request);return

seckillGoodsService.checkOrder(skuId,

userId);

排队中各种提示非法、已售罄等抢购成功去下单抢购成功已下单显示我的订单

抢购成功页面显示去下单跳转下单确认页面

1.用户抢单的时候先会生成一个下单码后面会先校验用户的下单码只有正确获得下单码的请求才是合法请求然后再校验状态位state状态位是在内存中判断效率极高如果售罄直接就返回了不会给服务器造成太大压力前面条件都成立将秒杀用户加入队列然后直接返回

2.监听队列进行清单首先判断产品状态位我们前面不是已经判断过了吗因为产品可能随时售罄mq队列里面可能堆积了十万数据但是已经售罄了那么后续流程就没有必要再走了

然后判断用户是否已经下过订单这个地方就是控制用户重复下单同一个用户只能抢购一个下单资格我们可以利用setnx控制用户当用户第一次进来时返回true可以抢购以后进入返回false

要控制库存数量不能超卖提供一种解决方案那就我们在导入商品缓存数据时同时将商品库存信息导入队列{list}利用redis队列的原子性保证库存不超卖

然后将订单记录放入redis缓存说明用户已经获得下单资格秒杀成功秒杀成功要更新库存更新Mysql的库存和Redis中的库存

3.前端页面轮训查询订单状态判断用户是否抢单成功下单了Redis生成临时订单数据支付了会删除临时订单抢单成功去下单页面判断用户是否下单查询总订单数据是否支付下单了去我们订单页面判断状态位是否售罄