【黑马点评二刷日记】优惠券秒杀下单
实现全局唯一ID
为什么我们需要全局唯一ID？
因为：
如果我们使用数据库自增ID会导致问题的产生
id规律太明显，
受单表数据量的限制
用Redis来实现全局唯一ID
@ComponentpublicclassRedisIdWorker{/** * 开始时间戳 */privatestaticfinallongBEGIN_TIMESTAMP=1640995200L;/** * 序列号的位数 */privatestaticfinalintCOUNT_BITS=32;privateStringRedisTemplatestringRedisTemplate;publicRedisIdWorker(StringRedisTemplatestringRedisTemplate){this.stringRedisTemplate=stringRedisTemplate;}//生成分布式IDpubliclongnextId(StringkeyPrefix){// 1.生成时间戳LocalDateTimenow=LocalDateTime.now();longnowSecond=now.toEpochSecond(ZoneOffset.UTC);longtimestamp=nowSecond-BEGIN_TIMESTAMP;// 2.生成序列号// 2.1.获取当前日期，精确到天。以当天的时间戳为key，防止一直自增下去导致超时Stringdate=now.format(DateTimeFormatter.ofPattern("yyyy:MM:dd"));// 2.2.自增长longcount=stringRedisTemplate.opsForValue().increment("icr:"+keyPrefix+":"+date);// 3.拼接并返回returntimestamp<<COUNT_BITS|count;}}实现优惠券发放
业务理解：发放优惠券实现业务增长
需要实现的：添加优惠券，实现秒杀下单，库存超卖，实现一人一单
在实现优惠券发放过程，我们通过调用Voucher接口来实现
@RestController@RequestMapping("/voucher")publicclassVoucherController{@ResourceprivateIVoucherServicevoucherService;/** * 新增普通券 * @param voucher 优惠券信息 * @return 优惠券id */@PostMappingpublicResultaddVoucher(@RequestBodyVouchervoucher){voucherService.save(voucher);returnResult.ok(voucher.getId());}/** * 新增秒杀券 * @param voucher 优惠券信息，包含秒杀信息 * @return 优惠券id */@PostMapping("seckill")publicResultaddSeckillVoucher(@RequestBodyVouchervoucher){voucherService.addSeckillVoucher(voucher);returnResult.ok(voucher.getId());}/** * 查询店铺的优惠券列表 * @param shopId 店铺id * @return 优惠券列表 */@GetMapping("/list/{shopId}")publicResultqueryVoucherOfShop(@PathVariable("shopId")LongshopId){returnvoucherService.queryVoucherOfShop(shopId);}}实现优惠券秒杀的下单功能
业务实现：秒杀是否开始或结束，如果未开始或结束则无法下单；库存是否充足，不足无法下单。
@ServicepublicclassVoucherOrderServiceImplextendsServiceImpl<VoucherOrderMapper,VoucherOrder>implementsIVoucherOrderService{@ResourceprivateISeckillVoucherServiceseckillVoucherService;@AutowiredprivateRedisIdWorkerredisIdWorker;@OverridepublicResultseckillVoucher(LongvoucherId){//1.查询秒杀券SeckillVouchervoucher=seckillVoucherService.getById(voucherId);//2.判断秒杀券是否合法if(voucher.getBeginTime().isAfter(LocalDateTime.now())){//秒杀券的开始时间在当前时间后returnResult.fail("秒杀尚未开始");}if(voucher.getEndTime().isBefore(LocalDateTime.now())){// 秒杀券的结束时间在当前时间之前returnResult.fail("秒杀已结束");}if(voucher.getStock()<1){returnResult.fail("秒杀券已抢空");}//5.秒杀券合法，则秒杀券抢购成功，秒杀券库存数量减一booleanflag=seckillVoucherService.update(newLambdaUpdateWrapper<SeckillVoucher>().eq(SeckillVoucher::getVoucherId,voucherId).setSql("stock=stock-1"));if(!flag){thrownewRuntimeException("秒杀券扣减失败");}//6.秒杀成功，创建对应的订单，并保存到数据库VoucherOrdervoucherOrder=newVoucherOrder();longorderId=redisIdWorker.nextId(null);voucherOrder.setId(orderId);voucherOrder.setUserId(ThreadLocalUtls.getUser().getId());voucherOrder.setVoucherId(voucherOrder.getId());flag=this.save(voucherOrder);if(!flag){thrownewRuntimeException("创建秒杀券订单失败");}//返回订单idreturnResult.ok(orderId);}}乐观锁解决超卖问题（版本号，CAS）
这里我们有两种解决方案：
版本号解决
CAS乐观锁解决
CAS不需要再数据库表中添加version字段，节省了内存开销的问题，矮子里面挑将军，我们用CAS来实现。
使用CAS的优点：
避免了内存过大的开销
弊端：
成功率很低
// 5、秒杀券合法，则秒杀券抢购成功，秒杀券库存数量减一booleanflag=seckillVoucherService.update(newLambdaUpdateWrapper<SeckillVoucher>().eq(SeckillVoucher::getVoucherId,voucherId).eq(SeckillVoucher::getStock,voucher.getStock()).setSql("stock = stock -1"));一人一单
需求：修改秒杀业务，要求同一个优惠券，每人只能用一次。
/** * 抢购秒杀券 * * @param voucherId * @return */@Transactional@OverridepublicResultseckillVoucher(LongvoucherId){// 1、查询秒杀券SeckillVouchervoucher=seckillVoucherService.getById(voucherId);// 2、判断秒杀券是否合法if(voucher.getBeginTime().isAfter(LocalDateTime.now())){// 秒杀券的开始时间在当前时间之后returnResult.fail("秒杀尚未开始");}if(voucher.getEndTime().isBefore(LocalDateTime.now())){// 秒杀券的结束时间在当前时间之前returnResult.fail("秒杀已结束");}if(voucher.getStock()<1){returnResult.fail("秒杀券已抢空");}// 3、创建订单LonguserId=ThreadLocalUtls.getUser().getId();synchronized(userId.toString().intern()){// 创建代理对象，使用代理对象调用第三方事务方法， 防止事务失效IVoucherOrderServiceproxy=(IVoucherOrderService)AopContext.currentProxy();returnproxy.createVoucherOrder(userId,voucherId);}}/** * 创建订单 */@TransactionalpublicResultcreateVoucherOrder(LonguserId,LongvoucherId){// synchronized (userId.toString().intern()) {// 1、判断当前用户是否是第一单intcount=this.count(newLambdaQueryWrapper<VoucherOrder>().eq(VoucherOrder::getUserId,userId));if(count>=1){// 当前用户不是第一单returnResult.fail("用户已购买");}// 2、用户是第一单，可以下单，秒杀券库存数量减一booleanflag=seckillVoucherService.update(newLambdaUpdateWrapper<SeckillVoucher>().eq(SeckillVoucher::getVoucherId,voucherId).gt(SeckillVoucher::getStock,0).setSql("stock = stock -1"));if(!flag){thrownewRuntimeException("秒杀券扣减失败");}// 3、创建对应的订单，并保存到数据库VoucherOrdervoucherOrder=newVoucherOrder();longorderId=redisIdWorker.nextId(SECKILL_VOUCHER_ORDER);voucherOrder.setId(orderId);voucherOrder.setUserId(ThreadLocalUtls.getUser().getId());voucherOrder.setVoucherId(voucherOrder.getId());flag=this.save(voucherOrder);if(!flag){thrownewRuntimeException("创建秒杀券订单失败");}// 4、返回订单idreturnResult.ok(orderId);// }}关于锁，我们需要注意的是：
- 锁的范围要尽量小；锁范围越大，性能越低。synchronized尽量锁代码块。
- 锁的对象是一个不变的值，在面对long类型的userId时，每次请求都会创建一个新的userId对象，使用我们使用toString（）方法变为String类型。在toString源码中我们发现，底层调用的是long的静态函数，还是会产生新的对象，所以调用intern() 方法从常量池中寻找与当前 字符串值一致的字符串对象。
- 我们哟啊锁的是一整个事务，不能锁定一个代码块，否则还是会出现超卖现象。