@Override@Transactionalpublic Order seckill(User user, GoodsVo goods) {ValueOperations valueOperations = redisTemplate.opsForValue();//秒杀商品表减库存SeckillGoods seckillGoods = seckillGoodsService.getOne(new QueryWrapper<SeckillGoods>().eq("goods_id", goods.getId()));seckillGoods.setStockCount(seckillGoods.getStockCount() - 1);
//        seckillGoodsService.updateById(seckillGoods);//修改后的秒杀商品表减库存boolean seckillGoodsResult = seckillGoodsService.update(new UpdateWrapper<SeckillGoods>().setSql("stock_count=" + "stock_count-1").eq("goods_id", goods.getId()).gt("stock_count", 0));if (seckillGoods.getStockCount() < 1) {//判断是否还有库存valueOperations.set("isStockEmpty:" + goods.getId(), "0");return null;}//生成订单Order order = new Order();order.setUserId(user.getId());order.setGoodsId(goods.getId());order.setDeliveryAddrId(0L);order.setGoodsName(goods.getGoodsName());order.setGoodsCount(1);order.setGoodsPrice(seckillGoods.getSeckillPrice());order.setOrderChannel(1);order.setStatus(0);order.setCreateDate(new Date());orderMapper.insert(order);//生成秒杀订单//生成秒杀订单SeckillOrder seckillOrder = new SeckillOrder();seckillOrder.setOrderId(order.getId());seckillOrder.setUserId(user.getId());seckillOrder.setGoodsId(goods.getId());seckillOrderService.save(seckillOrder);//存入缓存redisTemplate.opsForValue().set("order:" + user.getId() + ":" + goods.getId(), JsonUtil.object2JsonStr(seckillOrder));return order;}

@RequestMapping("/seckill")
public class SeckillController {@Autowiredprivate IGoodsService goodsService;@Autowiredprivate ISeckillOrderService seckillOrderService;@Autowiredprivate IOrderService orderService;@Autowiredprivate RedisTemplate redisTemplate;@RequestMapping(value = "/doSeckill", method = RequestMethod.POST)@ResponseBodypublic RespBean doSeckill(User user, Long goodsId) {if (user == null) {return RespBean.error(RespBeanEnum.SESSION_ERROR);}GoodsVo goods = goodsService.findGoodsVoByGoodsId(goodsId);//判断库存if (goods.getStockCount() < 1) {return RespBean.error(RespBeanEnum.EMPTY_STOCK);}//判断是否重复抢购// SeckillOrder seckillOrder = seckillOrderService.getOne(new 
QueryWrapper<SeckillOrder>().eq("user_id",//       user.getId()).eq(//       "goods_id",//       goodsId));String seckillOrderJson = (String) 
redisTemplate.opsForValue().get("order:" + user.getId() + ":" + goodsId);if (!StringUtils.isEmpty(seckillOrderJson)) {return RespBean.error(RespBeanEnum.REPEATE_ERROR);}Order order = orderService.seckill(user, goods);if (null != order) {return RespBean.success(order);}return RespBean.error(RespBeanEnum.ERROR);}
}

@Data
@AllArgsConstructor
@NoArgsConstructor
public class SeckillMessage {private User user;private Long goodsId;
}

       配置RabbitMQ队列和交换机规则

RabbitTopicConfig.class

@Configuration
public class RabbitTopicConfig {private static final String QUEUE="seckillQueue";private static final String EXCHANGE="seckillExchange";private static final String ROUTINGKEY="seckill.#";//秒杀队列@Beanpublic Queue queue(){return new Queue(QUEUE);}//声明交换机@Beanpublic TopicExchange topicExchange(){return new TopicExchange(EXCHANGE);}//绑定交换机和队列@Beanpublic Binding binding(){return BindingBuilder.bind(queue()).to(topicExchange()).with(ROUTINGKEY);}
}

信息发送者

MQSender.class

@Service
@Slf4j
public class MQSender {@Autowiredprivate RabbitTemplate rabbitTemplate;public void sendSecKillMessage(Object msg){log.info("发送消息:"+msg);rabbitTemplate.convertAndSend("seckillExchange","seckill.msg",msg);}
}

消息消费者 用来异步下单

MQReceiver.class

@Service
@Slf4j
public class MQReceiver {@Autowiredprivate IGoodsService goodsService;@Autowiredprivate RedisTemplate redisTemplate;@Autowiredprivate IOrderService orderService;//    @RabbitListener(queues = "queue")
//    public void receive(Object msg){
//        log.info("接收消息:"+msg);
//    }
//    @RabbitListener(queues = "queue_topic03")
//    public void receive01(Object msg){
//        log.info("接收消息:"+msg);
//    }
//    @RabbitListener(queues = "queue_topic04")
//    public void receive02(Object msg){
//        log.info("接收消息:"+msg);
//    }@RabbitListener(queues = "seckillQueue")public void receive(String msg) {log.info("接收消息：" + msg);//json转对象SeckillMessage message = JsonUtil.jsonStr2Object(msg, SeckillMessage.class);User user = message.getUser();Long goodsId = message.getGoodsId();GoodsVo goodsVo = goodsService.findGoodsVoGoodsId(goodsId);//判断库存if (goodsVo.getStockCount() < 1) {return;}//判断是否是重复抢购String seckillOrderJson = (String) redisTemplate.opsForValue().get("order:" + user.getId() + ":" + goodsId);if (!StringUtils.isEmpty(seckillOrderJson)){return;}orderService.seckill(user,goodsVo);}
}

修改秒杀接口 下单操作先进入队列

@Controller
@RequestMapping("/seckill")
public class SeckillController implements InitializingBean {@Autowiredprivate IGoodsService goodsService;@Autowiredprivate ISeckillOrderService seckillOrderService;@Autowiredprivate IOrderService orderService;@Autowiredprivate RedisTemplate redisTemplate;@Autowiredprivate MQSender mqSender;private Map<Long, Boolean> EmptyStockMap = new HashMap<>();* @param user* @param goodsId* @return*/@RequestMapping(value = "/doSeckill", method = RequestMethod.POST)@ResponseBodypublic RespBean doSeckill(User user, Long goodsId) {if (user == null) {return RespBean.error(RespBeanEnum.SESSION_ERROR);}GoodsVo goods = goodsService.findGoodsVoByGoodsId(goodsId);//判断库存if (goods.getStockCount() < 1) {return RespBean.error(RespBeanEnum.EMPTY_STOCK);}String seckillOrderJson = (String) 
redisTemplate.opsForValue().get("order:" + user.getId() + ":" + goodsId);if (!StringUtils.isEmpty(seckillOrderJson)) {return RespBean.error(RespBeanEnum.REPEATE_ERROR);}Order order = orderService.seckill(user, goods);if (null != order) {return RespBean.success(order);}*/ValueOperations valueOperations = redisTemplate.opsForValue();//判断是否重复抢购String seckillOrderJson = (String) valueOperations.get("order:" +
user.getId() + ":" + goodsId);if (!StringUtils.isEmpty(seckillOrderJson)) {return RespBean.error(RespBeanEnum.REPEATE_ERROR);}//内存标记,减少Redis访问if (EmptyStockMap.get(goodsId)) {return RespBean.error(RespBeanEnum.EMPTY_STOCK);}//预减库存Long stock = valueOperations.decrement("seckillGoods:" + goodsId);if (stock < 0) {EmptyStockMap.put(goodsId,true);valueOperations.increment("seckillGoods:" + goodsId);return RespBean.error(RespBeanEnum.EMPTY_STOCK);}// 请求入队，立即返回排队中SeckillMessage message = new SeckillMessage(user, goodsId);mqSender.sendsecKillMessage(JsonUtil.object2JsonStr(message));return RespBean.success(0);}

5.3 客户端轮询秒杀结果

 /*** @author： yrh* @Description: 轮询秒杀接口* @return: orderId :成功,-1失败，0排队中*/@RequestMapping(value = "/result", method = RequestMethod.GET)@ResponseBodypublic RespBean result(User user, Long goodsId) {if (null == user) {return RespBean.error(RespBeanEnum.SESSION_ERROR);}Long orderId = seckillOrderService.getResult(user, goodsId);return RespBean.success(orderId);}

Long getResult(User user, Long goodsId);

SeckillOrderServiceImpl.class

 @Overridepublic Long getResult(User user, Long goodsId) {SeckillOrder seckillOrder = seckillOrderMapper.selectOne(new QueryWrapper<SeckillOrder>().eq("user_id", user.getId()).eq("goods_id", goodsId));if (null != seckillOrder) {return seckillOrder.getOrderId();} else {if ( redisTemplate.hasKey("isStockEmpty:" + goodsId)){return -1L;}else {return 0L;}}}