当前位置：首页 > news >正文

二刷黑马点评秒杀优化

news 2025/7/18 10:15:06

优化逻辑

把耗时较短的逻辑判断放入redsi中，比如库存是否足够以及是否一人一单，只要这样的逻辑完成，就代表一定能下单成功，我们就将结果返回给用户，然后我们再开一个线程慢慢执行队列中的信息

问题：
如何快速校验一人一单以及库存是否充足

交验和下单是两个线程，如何将二者对应：
在redis操作完成之后，会返回一些信息给前端，同时将这些信息丢给异步队列执行，后续操作通过id来查询下单逻辑是否完成

![[Pasted image 20250717173831.png]]

整体流程

下单后判断是否充足只需要去redis根据key查询对应的value是否大于0 ,如果大于0再判断是否下过单，如果在set集合中没有这条数据，那么就将userId和优惠卷存入redis,将优惠卷id、用户id和订单id存入阻塞队列中，异步存储到数据库

![[Pasted image 20250717174050.png]]

stringRedisTemplate.opsForValue().set(SECKILL_STOCK_KEY + voucher.getId(), voucher.getStock().toString());
保存优惠卷并将保存秒杀的库存到Redis

-- 3.脚本业务
-- 3.1.判断库存是否充足 get stockKey
if(tonumber(redis.call('get', stockKey)) <= 0) then-- 3.2.库存不足，返回1return 1
end
-- 3.2.判断用户是否下单 SISMEMBER orderKey userId
if(redis.call('sismember', orderKey, userId) == 1) then-- 3.3.存在，说明是重复下单，返回2return 2
end
-- 3.6.发送消息到队列中， XADD stream.orders * k1 v1 k2 v2 ...
redis.call('xadd', 'stream.orders', '*', 'userId', userId, 'voucherId', voucherId, 'id', orderId)

只要>0就可以下单，然后判断用户是否下过单

命令结构：
XADD stream.orders * k1 v1 k2 v2 ...
- stream.orders：目标流的名称。
- *：自动生成唯一的消息 ID（格式为 时间戳-序列号）。
- k1 v1 k2 v2 ...：消息的键值对数据。

Long result = stringRedisTemplate.execute(  SECKILL_SCRIPT, Collections.emptyList(),  voucherId.toString(), userId.toString(), String.valueOf(orderId)  
);

脚本参数：
- SECKILL_SCRIPT：预定义的 Lua 脚本，处理秒杀业务逻辑（如库存校验、扣减）。
- Collections.emptyList()：Lua 脚本中KEYS参数为空列表（无需键名参数）。
- 后续参数为ARGV数组，依次是voucherId、userId、orderId，供 Lua 脚本内部使用。

private static final ExecutorService SECKILL_ORDER_EXECUTOR=Executors.newSingleThreadExecutor();
定义了一个静态常量线程池，这是一个单线程的执行器，保证任务按顺序执行, 避免多线程并发处理同一用户订单导致的重复下单问题

// 类初始化后启动工作线程 
@PostConstruct 
private void init() { SECKILL_ORDER_EXECUTOR.submit(new VoucherOrderHandler()); }

@PostConstruct确保类初始化后立即启动订单处理线程，并会持续运行直到应用关闭

 private class VoucherOrderHandler implements Runnable{@Overridepublic void run() {while (true){try {// 1.获取队列中的订单信息VoucherOrder voucherOrder = orderTasks.take();// 2.创建订单handleVoucherOrder(voucherOrder);} catch (Exception e) {log.error("处理订单异常", e);}}}}

实现 Runnable 接口的类通常用于创建线程任务，可以通过 Thread 类或线程池执行。

orderTasks.take() 是阻塞调用，队列空时线程会等待
确保订单按放入队列的顺序处理
异常处理保证线程不会因异常终止
proxy.createVoucherOrder(voucherOrder);
Spring 事务依赖 ThreadLocal，多线程环境下子线程无法获取主线程的事务上下文
通过注入代理对象proxy调用事务方法，确保事务生效
也就是说继承Runnable接口的类可以被在线程池中被调用
而这里选择了在类初始化之后就调用

Spring 事务管理的工作原理

private void handleVoucherOrder(VoucherOrder voucherOrder) {// ...获取锁...try {// 通过代理对象调用事务方法proxy.createVoucherOrder(voucherOrder);} finally {// ...释放锁...}
}

Spring 的声明式事务是通过 AOP 代理实现的。当在方法上使用@Transactional注解时，Spring 会为该类创建一个代理对象，在调用带注解的方法时，代理会拦截调用并添加事务管理逻辑。
如果直接使用this.createVoucherOrder(voucherOrder)，事务不会生效，因为AOP代理被绕过了，必须通过代理对象调用这个方法才能触发事务增强
因为：