Redis - 全局ID生成器 RedisIdWorker

概述

代码实现

测试

一、CountDownLatch 工具类

二、ExecutorService & Executors

超卖问题

一、乐观锁

二、悲观锁

三、事务隔离级别

一人一单问题

一、单服务器系统解决方案

二、分布式系统解决方案 (通过 Lua 脚本保证原子性)

一、优惠券下单逻辑

二、代码实现 (Lua脚本)

--1. 参数列表
--1.1. 优惠券id
local voucherId = ARGV[1]
--1.2. 用户id
local userId = ARGV[2]
--1.3. 订单id
local orderId = ARGV[3]

--2. 数据key
--2.1. 库存key
local stockKey = 'seckill:stock:' .. voucherId
--2.2. 订单key
local orderKey = 'seckill:order' .. voucherId

--3. 脚本业务
--3.1. 判断库存是否充足 get stockKey
if( tonumber( redis.call('get', stockKey) ) <= 0 ) then
return 1
end
--3.2. 判断用户是否下单 SISMEMBER orderKey userId
if( redis.call( 'sismember', orderKey, userId ) == 1 ) then
return 2
end
--3.4 扣库存： stockKey 的库存 -1

redis.call( 'incrby', stockKey, -1 )
--3.5 下单(保存用户)： orderKey 集合中添加 userId

redis.call( 'sadd', orderKey, userId )
-- 3.6. 发送消息到队列中

redis.call( 'xadd', 'stream.orders', '*', 'userId', userId, 'voucherId', voucherId, 'id', orderId )

三、加载 Lua 脚本

四、执行 Lua 脚本

实战：添加优惠券 & 单服务器创建订单

添加优惠券

一、普通优惠券

二、限量优惠券

(缺陷) 优惠券下单功能

一、功能说明

四、代码实现

• 
  
• VoucherOrderServiceImpl (下述代码在分布式环境下仍然存在超卖问题)
  

  @Service
  
  public class VoucherOrderServiceImpl extends ServiceImpl<VoucherOrderMapper, VoucherOrder> implements IVoucherOrderService{
  
  @Resource
  
  	private ISeckillVoucherService seckillVoucherService;
  
  @Override
  
  	public Result seckillVoucher(Long voucherId) {
  
  // 查询优惠券
  
  		SeckillVoucher voucher = seckillVoucherService.getById(voucherId);
  
  // 优惠券抢购时间判断
  if(voucher.getBeginTime().isAfter(LocalDateTime.now) || voucher.getEndTime().isBefore(LocalDateTime.now()){
  
  			return Result.fail("当前不在抢购时间!");
  
  		}
  
  // 库存判断
  if(voucher.getStock() < 1){
  
  			return Result.fail("库存不足!");
  
  		}
  
  // !!! 实现一人一单功能 !!!
  
  		Long userId = UserHolder.getUser().getId();
  
  		synchronized (userId.toString().intern()) {
  
  			IVoucherOrderService proxy = (IVoucherOrderService) AopContext.currentProxy();
  
  			return proxy.createVoucherOrder(voucherId);
  
  		}
  
  	}
  
  @Transactional
  
  	public Result createVoucherOrder(Long userId) {
  
  		Long userId = UserHolder.getUser().getId();
  
  // 查询当前用户是否已经购买过优惠券
  
  		int count = query().eq("user_id", userId).eq("voucher_id", voucherId).count();
  if( count > 0 ) {
  
  			return Result.fail("当前用户不可重复购买!");
  
  // !!! 实现乐观锁 !!!
  // 扣减库存
  
  		boolean success = seckillVoucherService.update()
  .setSql("stock = stock - 1")                       // set stock = stock - 1;
  .eq("voucher_id", voucherId).gt("stock", 0)        // where voucher_id = voucherId and stock > 0;
  .update();
  if(!success) {
  
  			return Result.fail("库存不足!");
  
  		}
  
  // 创建订单
  
  		VoucherOrder voucherOrder = new VoucherOrder();
  
  		voucherOrder.setId(redisIdWorker.nextId("order"));
  
  		voucherOrder.setUserId(UserHolder.getUser().getId());
  
  		voucherOrder.setVoucherId(voucherId);
  save(voucherOrder);
  
  // 返回订单id
  
  		return Result.ok(orderId);
  
  }