商品秒杀_删除过期订单（2）-【官方】百战程序员_IT在线教育培训机构


xxxxxxxxxx
@Override
public Orders createOrder(Orders orders) {
    // 1.生成订单对象
    orders.setId(IdWorker.getIdStr()); // 手动生产订单id
    orders.setStatus(1); // 订单状态未付款
    orders.setCreateTime(new Date()); // 订单创建时间
    orders.setExpire(new Date(new Date().getTime()+1000*60*5));
    // 计算商品价格
    CartGoods cartGoods = orders.getCartGoods().get(0);
    Integer num = cartGoods.getNum();
    BigDecimal price = cartGoods.getPrice();
    BigDecimal sum = price.multiply(BigDecimal.valueOf(num));
    orders.setPayment(sum);

    // 2.减少秒杀商品库存
    // 查询秒杀商品
    SeckillGoods seckillGoods = findSeckillGoodsByRedis(cartGoods.getGoodId());
    // 查询库存，库存不足抛出异常
    Integer stockCount = seckillGoods.getStockCount();
    if (stockCount <= 0){
        throw new BusException(CodeEnum.NO_STOCK_ERROR);
    }
    // 减少库存
    seckillGoods.setStockCount(seckillGoods.getStockCount() - cartGoods.getNum());
    redisTemplate.boundHashOps("seckillGoods").put(seckillGoods.getGoodsId(),seckillGoods);

    // 3.保存订单数据
    redisTemplate.setKeySerializer(new StringRedisSerializer());
    // 设置订单一分钟过期
    redisTemplate.opsForValue().set(orders.getId(),orders,1, TimeUnit.MINUTES);
    /**
      * 给订单创建副本，副本的过期时间长于原订单
      * redis过期后触发过期事件时，redis数据已经过期，此时只能拿到key，拿不到value。
      * 而过期事件需要回退商品库存，必须拿到value即订单详情，才能拿到商品数据，进行回退操作
      * 我们保存一个订单副本，过期时间长于原订单，此时就可以通过副本拿到原订单数据
      */
    redisTemplate.opsForValue().set(orders.getId()+"_copy",orders,2,TimeUnit.MINUTES);
    return orders;
}

配置redis监听器


xxxxxxxxxx
/**
 * 配置redis监听器
 */
@Configuration
public class RedisListenerConfig {
    // 配置redis监听器，监听redis过期事件
    @Bean
    public RedisMessageListenerContainer container(RedisConnectionFactory connectionFactory) {
        RedisMessageListenerContainer container = new RedisMessageListenerContainer();
        container.setConnectionFactory(connectionFactory);
        return container;
    }
}

创建redis监听类


xxxxxxxxxx
/**
 * redis监听类继承KeyExpirationEventMessageListener
 */
@Component
public class RedisKeyExpirationListener extends KeyExpirationEventMessageListener {
    @Autowired
    private RedisTemplate redisTemplate;
    @Autowired
    private SeckillService seckillService;

    public RedisKeyExpirationListener(RedisMessageListenerContainer listenerContainer) {
        super(listenerContainer);
    }

    /**
     * 订单过期后，关闭交易，回退商品库存
     */
    @Override
    public void onMessage(Message message, byte[] pattern) {
        // 获取失效key，即订单id
        String expiredKey = message.toString();

        // 拿到复制订单信息
        Orders orders = (Orders) redisTemplate.opsForValue().get(expiredKey + "_copy");
        Long goodId = orders.getCartGoods().get(0).getGoodId(); // 产品id
        Integer num = orders.getCartGoods().get(0).getNum(); // 产品数量

        // 查询秒杀商品
        SeckillGoods seckillGoods = seckillService.findSeckillGoodsByRedis(goodId);

        // 回退库存
        seckillGoods.setStockCount(seckillGoods.getStockCount() + num);
        redisTemplate.boundHashOps("seckillGoods").put(goodId, seckillGoods);

        // 删除复制订单数据
        redisTemplate.delete(expiredKey+"_copy");
    }
}

修改支付代码，支付时删除复制订单


xxxxxxxxxx
@Override
public Orders pay(String orderId) {
    // 1.查询订单，设置相应数据
    Orders orders = (Orders) redisTemplate.opsForValue().get(orderId);
    if (orders == null){
        throw new BusException(CodeEnum.ORDER_EXPIRED_ERROR);
    }
    orders.setStatus(2);
    orders.setPaymentTime(new Date());
    orders.setPaymentType(2); // 支付宝支付

    // 2.从redis删除订单
    redisTemplate.delete(orderId);
    redisTemplate.delete(orderId+"_copy");

    // 3.返回订单数据
    return orders;
}

这样生成订单时还会生成一个复制订单，订单数据过期触发过期事件，在过期事件中找到订单的复制订单，从复制订单中拿到商品数据，对商品进行回退库存。

商品秒杀_删除过期订单（1）商品秒杀_删除过期订单（3）

北京市昌平区回龙观镇南店村综合商业楼2楼226室