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

高并发抢单系统核心实现详解：Redisson分布式锁实战

news 2025/8/5 11:50:41

一、方法整体流程解析

二、关键代码解析（逐行详解）

@Override
public Boolean robNewOrder(Long driverId, Long orderId) {// 1. 参数校验 - 防御性编程if (driverId == null || orderId == null) {throw new GuiguException(ResultCodeEnum.ARGUMENT_VALID_ERROR);}// 2. 创建订单级分布式锁// 锁键设计: "rob_new_order_lock:订单ID" String lockKey = RedisConstant.ROB_NEW_ORDER_LOCK + orderId;RLock lock = redissonClient.getLock(lockKey);

分布式锁核心控制段

    try {// 3. 尝试获取分布式锁（非阻塞式）// 等待时间: 避免线程无限等待// 租期时间: 防止死锁boolean lockAcquired = lock.tryLock(RedisConstant.ROB_NEW_ORDER_LOCK_WAIT_TIME, RedisConstant.ROB_NEW_ORDER_LOCK_LEASE_TIME, TimeUnit.SECONDS);if (!lockAcquired) {// 锁竞争失败日志log.warn("司机{}抢单{}失败：获取锁超时", driverId, orderId);throw new GuiguException(ResultCodeEnum.COB_NEW_ORDER_FAIL);}

业务核心处理段

        // 4. 双重检查 - 防止订单状态在等待锁期间被修改OrderInfo orderInfo = orderInfoMapper.selectOne(new LambdaQueryWrapper<OrderInfo>().eq(OrderInfo::getId, orderId));// 5. 订单存在性检查if (orderInfo == null) {log.warn("司机{}抢单{}失败：订单不存在", driverId, orderId);throw new GuiguException(ResultCodeEnum.DATA_ERROR);}// 6. 状态机验证 - 确保只有待接单订单可抢if (!OrderStatus.WAITING_ACCEPT.getStatus().equals(orderInfo.getStatus())) {log.warn("司机{}抢单{}失败：订单状态不正确，当前状态{}", driverId, orderId, orderInfo.getStatus());throw new GuiguException(ResultCodeEnum.DATA_ERROR);}// 7. 司机状态检查（扩展点）// 可添加：司机是否在线、是否有进行中订单等校验// 8. 原子化更新订单OrderInfo updateOrder = new OrderInfo();updateOrder.setId(orderId);updateOrder.setStatus(OrderStatus.ACCEPTED.getStatus());updateOrder.setDriverId(driverId);updateOrder.setAcceptTime(new Date());updateOrder.setUpdateTime(new Date());int affectedRows = orderInfoMapper.updateById(updateOrder);if (affectedRows != 1) {// 数据库更新失败（罕见情况）log.error("司机{}抢单{}失败：数据库更新异常", driverId, orderId);throw new GuiguException(ResultCodeEnum.COB_NEW_ORDER_FAIL);}

抢单成功后续处理

        // 9. 抢单成功后异步操作try {// 9.1 发送MQ事件（解耦核心流程）// rabbitTemplate.convertAndSend(//     "order.exchange", //     "order.accepted", //     orderId// );// 9.2 记录成功日志log.info("司机{}成功抢到订单{}", driverId, orderId);// 9.3 可扩展操作：// - 更新司机状态为「服务中」// - 推送通知给乘客// - 更新热力图统计} catch (Exception e) {// 核心业务成功后，异步操作异常不影响主流程log.error("抢单后续处理异常: {}", e.getMessage());}return true;

异常处理与资源清理

    } catch (InterruptedException e) {// 处理线程中断log.error("抢单被中断: {}", e.getMessage());Thread.currentThread().interrupt();throw new GuiguException(ResultCodeEnum.COB_NEW_ORDER_FAIL);} catch (Exception e) {// 全局异常捕获log.error("抢单系统异常: {}", e.getMessage());throw new GuiguException(ResultCodeEnum.COB_NEW_ORDER_FAIL);} finally {// 10. 确保锁释放（关键！）if (lock.isHeldByCurrentThread()) {lock.unlock();}}
}

三、架构设计亮点

1. 三级安全防护机制

层级	防护机制	作用
1	Redis抢单标识	前置过滤无效请求
2	Redisson分布式锁	控制并发访问
3	数据库状态机	最终一致性保证

2. 锁设计最佳实践

锁粒度：按订单ID加锁（细粒度）
等待时间：设置超时（默认3-5秒）
自动续期：Redisson看门狗机制
释放保障：finally块确保释放

3. 状态机验证（关键防御）

四、生产环境优化建议

Redis标识前置校验

// 在尝试获取锁前增加检查
String robFlagKey = "order_rob_flag:" + orderId;
if (redisTemplate.hasKey(robFlagKey)) {throw new BusiException("订单已被抢");
}

数据库更新优化

// 使用乐观锁更新
int rows = orderInfoMapper.update(null, new LambdaUpdateWrapper<OrderInfo>().eq(OrderInfo::getId, orderId).eq(OrderInfo::getStatus, OrderStatus.WAITING_ACCEPT.getStatus()).set(OrderInfo::getStatus, OrderStatus.ACCEPTED.getStatus())// ...其他字段
);

锁分段提升并发

// 对热门订单使用分段锁
int segment = orderId % 16;
String lockKey = "rob_lock:" + segment;

监控埋点

// 添加监控指标
Metrics.counter("order.rob.attempt").increment();
if (!lockAcquired) {Metrics.counter("order.rob.lock_fail").increment();
}

五、典型异常场景处理

异常场景	处理方案	保障措施
锁获取超时	立即返回失败	等待时间配置
锁释放失败	设置TTL自动过期	Redisson租期机制
数据库更新失败	事务回滚+异常通知	本地事务+告警
网络分区	Redis哨兵切换	高可用集群