redis解决超卖问题，一人一单

超卖问题：

采用优化的CAS法（乐观锁）解决超卖问题：

一人一单的业务流程：

同时为了解决一人一单的并发问题，由于是插入数据，所以采用悲观锁。
在调用方法前将userid加锁，来保证同一个用户上同一把锁。而不同用户上不同的锁来实现并发执行。
又由于toString()的底层是new了一个新对象，所以使用synchronized (userId.toString().intern())intern()会去寻找相同值在内存中地址并返回。保证了同一个用户上同一把锁。
直接调用this.createVoucherOrder() 会导致事务失效（Spring AOP代理机制），所以采用通过代理对象调用使事务注解生效。保证方法内的数据库操作具有原子性。

• 查询优惠券信息 → 2. 时间校验 → 3. 库存检查 → 4. 用户级别加锁
  ↓
  
• 获取代理对象 → 6. 进入事务方法 → 7. 一人一单检查 → 8. 扣减库存 → 9. 创建订单
  

添加依赖：

1.    <dependency>
2.             <groupId>org.aspectj</groupId>
3.             aspectjweaver</artifactId>
4.         </dependency>

复制代码

启动类添加注解：

1. package com.hmdp;
3. import org.mybatis.spring.annotation.MapperScan;
4. import org.springframework.boot.SpringApplication;
5. import org.springframework.boot.autoconfigure.SpringBootApplication;
6. import org.springframework.context.annotation.EnableAspectJAutoProxy;
8. @EnableAspectJAutoProxy(exposeProxy = true)
9. @MapperScan("com.hmdp.mapper")
10. @SpringBootApplication
11. public class HmDianPingApplication {
13.     public static void main(String[] args) {
14.         SpringApplication.run(HmDianPingApplication.class, args);
15.     }
17. }

复制代码

具体实现:
点击查看代码

1. package com.hmdp.service.impl;
3. import com.hmdp.dto.Result;
4. import com.hmdp.entity.SeckillVoucher;
5. import com.hmdp.entity.VoucherOrder;
6. import com.hmdp.mapper.VoucherOrderMapper;
7. import com.hmdp.service.ISeckillVoucherService;
8. import com.hmdp.service.IVoucherOrderService;
9. import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
10. import com.hmdp.utils.RedisIdWorker;
11. import com.hmdp.utils.UserHolder;
12. import org.springframework.aop.framework.AopContext;
13. import org.springframework.stereotype.Service;
14. import org.springframework.transaction.annotation.Transactional;
16. import javax.annotation.Resource;
17. import java.time.LocalDateTime;
19. /**
20. * <p>
21. *  服务实现类
22. * </p>
23. *
24. * @author ztn
25. * @since 2025-09-23
26. */
27. @Service
28. public class VoucherOrderServiceImpl extends ServiceImpl<VoucherOrderMapper, VoucherOrder> implements IVoucherOrderService {
30.     @Resource
31.     private ISeckillVoucherService seckillVoucherService;
33.     @Resource
34.     private RedisIdWorker redisIdWorker;
37.     @Override
38.     public Result seckillVocher(Long voucherId) {
39.         // 1.查询优惠券
40.         SeckillVoucher voucher = seckillVoucherService.getById(voucherId);
41.         // 2.判断秒杀是否开始
42.         if(voucher.getBeginTime().isAfter(LocalDateTime.now())){
43.             return Result.fail("秒杀尚未开始");
44.         }
45.         // 3.判断秒杀是否结束
46.         if(voucher.getEndTime().isBefore(LocalDateTime.now())){
47.             return Result.fail("秒杀已经结束");
48.         }
49.         // 4.判断库是否充足
50.         if(voucher.getStock() < 1){
51.             return Result.fail("库存不足");
52.         }
54.         Long userId = UserHolder.getUser().getId();
55.         synchronized (userId.toString().intern()) {
56.             // 获取代理对象（事务）
57.             IVoucherOrderService proxy = (IVoucherOrderService) AopContext.currentProxy();
58.             return proxy.createVoucherOrder(voucherId);
59.         }
60.     }
61.     @Transactional
62.     public  Result createVoucherOrder(Long voucherId) {
63.         // 5.一人一单
64.         Long userId = UserHolder.getUser().getId();
65.         // 5.1 查询订单
66.         int count = query().eq("user_id", userId).eq("voucher_id", voucherId).count();
67.         // 5.2 判断是否存在
68.         if(count > 0){
69.             // 用户已经购买过了
70.             return Result.fail("用户已经购买过一次了");
71.         }
72.         // 6.扣减库存
73.         boolean success = seckillVoucherService.update()
74.                 .setSql("stock = stock - 1") // set stock =stock -1
75.                 .eq("voucher_id", voucherId)
76. //                .eq("stock",voucher.getStock()) // where id = ? and stock = ?
77.                 .gt("stock",0) // where id = ? and stock > 0
78.                 .update();
80.         if(!success){
81.             return Result.fail("库存不足");
82.         }
83.         // 7.创建订单
84.         VoucherOrder voucherOrder = new VoucherOrder();
85.         // 7.1订单id
86.         long orderId = redisIdWorker.nextId("order");
87.         voucherOrder.setId(orderId);
88.         // 7.2用户id
90.         voucherOrder.setUserId(userId);
91.         // 7.3代金券id
92.         voucherOrder.setVoucherId(voucherId);
93.         save(voucherOrder);
94.         // 8.返回订单id
95.         return Result.ok(orderId);
96.     }
97. }

复制代码

来源：程序园用户自行投稿发布，如果侵权，请联系站长删除
免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！

谢谢分享，辛苦了