redis实现分布式锁1

在集群下的并发问题：

业务流程：

具体实现：
ILock
点击查看代码

1. package com.hmdp.utils;
3. public interface ILock {
4.     // 获取锁
5.     boolean tryLock(long timeoutSec);
6.     // 释放锁
7.     void unlock();
8. }

复制代码

SimpleRedisLock
点击查看代码

1. package com.hmdp.utils;
3. import org.springframework.data.redis.core.StringRedisTemplate;
5. import java.util.concurrent.TimeUnit;
7. public class SimpleRedisLock implements ILock {
9.     private String name;
10.     private StringRedisTemplate stringRedisTemplate;
11.     private static final String KEY_PREFIX = "lock:";
13.     public SimpleRedisLock(String name, StringRedisTemplate stringRedisTemplate) {
14.         this.name = name;
15.         this.stringRedisTemplate = stringRedisTemplate;
16.     }
18.     @Override
19.     public boolean tryLock(long timeoutSec) {
20.         // 获取线程的标识
21.         long threadId = Thread.currentThread().getId();
23.         // 获取锁
24.         Boolean success = stringRedisTemplate.opsForValue().setIfAbsent(KEY_PREFIX + name, threadId + "", timeoutSec, TimeUnit.SECONDS);
25.         return Boolean.TRUE.equals(success);
26.     }
28.     @Override
29.     public void unlock() {
30.         // 释放锁
31.         stringRedisTemplate.delete(KEY_PREFIX + name);
33.     }
34. }

复制代码

VoucherOrderServiceImpl
点击查看代码

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.SimpleRedisLock;
12. import com.hmdp.utils.UserHolder;
13. import org.springframework.aop.framework.AopContext;
14. import org.springframework.data.redis.core.StringRedisTemplate;
15. import org.springframework.stereotype.Service;
16. import org.springframework.transaction.annotation.Transactional;
18. import javax.annotation.Resource;
19. import java.time.LocalDateTime;
21. /**
22. * <p>
23. *  服务实现类
24. * </p>
25. *
26. * @author ztn
27. * @since 2025-09-23
28. */
29. @Service
30. public class VoucherOrderServiceImpl extends ServiceImpl<VoucherOrderMapper, VoucherOrder> implements IVoucherOrderService {
32.     @Resource
33.     private ISeckillVoucherService seckillVoucherService;
35.     @Resource
36.     private RedisIdWorker redisIdWorker;
38.     @Resource
39.     private StringRedisTemplate stringRedisTemplate;
42.     @Override
43.     public Result seckillVocher(Long voucherId) {
44.         // 1.查询优惠券
45.         SeckillVoucher voucher = seckillVoucherService.getById(voucherId);
46.         // 2.判断秒杀是否开始
47.         if(voucher.getBeginTime().isAfter(LocalDateTime.now())){
48.             return Result.fail("秒杀尚未开始");
49.         }
50.         // 3.判断秒杀是否结束
51.         if(voucher.getEndTime().isBefore(LocalDateTime.now())){
52.             return Result.fail("秒杀已经结束");
53.         }
54.         // 4.判断库是否充足
55.         if(voucher.getStock() < 1){
56.             return Result.fail("库存不足");
57.         }
59.         Long userId = UserHolder.getUser().getId();
60.         // 创建锁对象
61.         SimpleRedisLock lock = new SimpleRedisLock("order:" + userId, stringRedisTemplate);
62.         // 获取锁
63.         boolean isLock = lock.tryLock(1200);
64.         // 判断是否获取锁成功
65.         if(!isLock){
66.             // 获取锁失败，返回错误或重试
67.             return Result.fail("不允许重复下单");
68.         }
69.         try {
70.             // 获取代理对象（事务）
71.             IVoucherOrderService proxy = (IVoucherOrderService) AopContext.currentProxy();
72.             return proxy.createVoucherOrder(voucherId);
73.         }finally {
74.             // 释放锁
75.             lock.unlock();
76.         }
77.     }
78.     @Transactional
79.     public  Result createVoucherOrder(Long voucherId) {
80.         // 5.一人一单
81.         Long userId = UserHolder.getUser().getId();
82.         // 5.1 查询订单
83.         int count = query().eq("user_id", userId).eq("voucher_id", voucherId).count();
84.         // 5.2 判断是否存在
85.         if(count > 0){
86.             // 用户已经购买过了
87.             return Result.fail("用户已经购买过一次了");
88.         }
89.         // 6.扣减库存
90.         boolean success = seckillVoucherService.update()
91.                 .setSql("stock = stock - 1") // set stock =stock -1
92.                 .eq("voucher_id", voucherId)
93. //                .eq("stock",voucher.getStock()) // where id = ? and stock = ?
94.                 .gt("stock",0) // where id = ? and stock > 0
95.                 .update();
97.         if(!success){
98.             return Result.fail("库存不足");
99.         }
100.         // 7.创建订单
101.         VoucherOrder voucherOrder = new VoucherOrder();
102.         // 7.1订单id
103.         long orderId = redisIdWorker.nextId("order");
104.         voucherOrder.setId(orderId);
105.         // 7.2用户id
107.         voucherOrder.setUserId(userId);
108.         // 7.3代金券id
109.         voucherOrder.setVoucherId(voucherId);
110.         save(voucherOrder);
111.         // 8.返回订单id
112.         return Result.ok(orderId);
113.     }
114. }

复制代码

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