卡飞资源网

专业编程技术资源共享平台

浅聊 Redis如何实现秒杀(一)

1、下单时需要判断两点:

(1)秒杀是否开始或结束,如果尚未开始或已经结束则无法下单

(2)库存是否充足,不足则无法下单

我们先通过代码实现上面的秒杀流程:

 public Result seckillVoucher(Long voucherId) {
        // 1.查询优惠券
        SeckillVoucher voucher = seckillVoucherService.getById(voucherId);
        // 2.判断秒杀是否开始
        if (voucher.getBeginTime().isAfter(LocalDateTime.now())) {
            // 尚未开始
            return Result.fail("秒杀尚未开始!");
        }
        // 3.判断秒杀是否已经结束
        if (voucher.getEndTime().isBefore(LocalDateTime.now())) {
            // 尚未开始
            return Result.fail("秒杀已经结束!");
        }
        // 4.判断库存是否充足
        if (voucher.getStock() < 1) {
            // 库存不足
            return Result.fail("库存不足!");
        }

         // 6.扣减库存
            boolean success = seckillVoucherService.update()
                    .setSql("stock = stock - 1") // set stock = stock - 1
                    .eq("voucher_id", voucherId).gt("stock", 0) // where id = ? and stock > 0
                    .update();
   
   			if (!success) {
                // 扣减失败
                return Result.fail("库存不足!");
            }
   				// 7.创建订单
            VoucherOrder voucherOrder = new VoucherOrder();
            // 7.1.订单id
            long orderId = redisIdWorker.nextId("order");
            voucherOrder.setId(orderId);
            // 7.2.用户id
            voucherOrder.setUserId(userId);
            // 7.3.代金券id
            voucherOrder.setVoucherId(voucherId);
            save(voucherOrder);

            // 7.返回订单id
            return Result.ok(orderId);
    }

以上是一个初级的秒杀下单的流程,这段代码里面有一个很大的BUG,就是超卖的问题;

if (voucher.getStock() < 1) return Result.fail("库存不足!");}:这个if判断语句会存在多线程安全问题,如果现在的库存stock=1;这时候有5个线程同时执行到这行代码,那么5个线程执行的结果都是false;不会进入if语句里面,就跳过了库存不足的判断了,从而出现超卖的问题;

2、超卖问题是典型的多线程安全问题,针对这一问题的常见解决方案就是加锁:

(1)悲观锁:认为线程安全问题一定会发生,因此在操作数据之前先获取锁,确保线程串行执行。 例如Synchronized、Lock都属于悲观锁

(2)乐观锁:认为线程安全问题不一定会发生,因此不加锁,只是在更新数据时去判断有没有其它线程对数据做了修改。 如果没有修改则认为是安全的,自己才更新数据。 如果已经被其它线程修改说明发生了安全问题,此时可以重试或异常。

这里我们只讲乐观锁的实现方式,应为悲观锁比较简单,直接在代码或者方法上面添加Synchronized即可;

乐观锁的关键是判断之前查询得到的数据是否有被修改过,常见的方式有两种:

(1)版本号法:

这种方式我们应该是经常使用的,就是在商品表里面添加一个字段:version版本号,假如线程1和线程2,同时查询商品信息的时候,这时候版本号为1,库存数量也为1。然后线程1先执行扣减库存操作:set stock = stock - 1,version = version + 1 where id = 10 and version = 1; 这个时候的version就是等于1,所以扣减库存执行成功;然后线程2来执行扣减库存:set stock = stock - 1,version = version + 1 where id = 10 and version = 1;但是这个时候数据库里面的version已经等于2了,所以这条sql语句执行不会成功的,这样就会避免超卖的问题;

上面版本号虽然解决了超卖的问题,但是还是有缺陷的,因为就算版本号已经被修改过了,但是只要库存的值 > 0;那么就还是应该秒杀成功,不应该因为版本号不一致返回失败;

所以这种问题我们可以不需要版本号,直接判断库存的值是否大于0就行了:set stock = stock - 1 where id = 10 and stock > 0;这样就可以解决超卖问题;

控制面板
您好,欢迎到访网站!
  查看权限
网站分类
最新留言