超卖的原因
在高并发情况下,由于查询库存和减库存之间存在时间差异,导致查询的数据不是真正的数据,导致的问题。
超卖的解决方案:
CAS(乐观锁)
在修改数据的同时查询数据:如果查询到的数据和之前查询到的数据一致,库存减1,新增订单。
但是会产生问题,多个线程同时查询的数据都是已经被修改的数据,所以大量线程会执行失败。
因此需要修改策略:判断库存是否大于0。
一人一单怎么实现:
在扣减库存之前判断当前用户是否已存在当前订单。仍然会出现并发问题。
和超卖不同,一人一单是插入不存在的数据而不是修改数据,因此不适用于乐观锁。
使用悲观锁解决并发问题。
@Override
public Result seckillVoucher(Long voucherId) {
// 查询优惠券,
SeckillVoucher voucher = seckillVoucherService.getById(voucherId);
if (voucher == null) {
return Result.fail("没有秒杀券");
}
// 判断秒杀是否开始,
if (!voucher.getBeginTime().isBefore(LocalDateTime.now()) || !voucher.getEndTime().isAfter(LocalDateTime.now())) {
return Result.fail("现在不是秒杀时间");
}
// 判断库存是否充足,
Integer stock = voucher.getStock();
if (stock < 1) {
return Result.fail("库存不足");
}
Long userId = UserHolder.getUser().getId();
// 将 userId.toString().intern() 作为锁对象。这意味着,只有持有相同 userId 的线程才能进入同步块,其它持有不同 userId 的线程可以并行执行。
synchronized (userId.toString().intern()){
IVoucherOrderService iVoucherOrderService = (IVoucherOrderService) AopContext.currentProxy();
return iVoucherOrderService.createOrder(voucherId);
}
}
@Transactional
public Result createOrder(Long voucherId) {
// 一人一单
Integer count = query().eq("user_id", UserHolder.getUser().getId()).eq("voucher_id", voucherId).count();
if(count!=0){
return Result.fail("已下过单了");
}
// 扣减秒杀券,
boolean update = seckillVoucherService.update().setSql("stock=stock-1")
.eq("voucher_id", voucherId)
.gt("stock", 0)
.update();
if(!update){
return Result.fail("库存不足");
}
// 秒杀创建订单
VoucherOrder voucherOrder = new VoucherOrder();
voucherOrder.setVoucherId(voucherId);
voucherOrder.setUserId(UserHolder.getUser().getId());
long orderId = redisIdWorker.nextId("order");
voucherOrder.setId(orderId);
save(voucherOrder);
return Result.ok(orderId);
}