Springboot整合Redisson解决超卖问题【分布式锁】

Springboot整合Redisson解决商品秒杀超卖问题【分布式锁】：

在Redis多线程高并发模拟商品秒杀情况，采用Redis官方提供的Redisson来解决高并发情况下数据原子性问题，Redisson无论实在Redis单机模式、哨兵模式、集群模式下实现的分布式锁都很好的处理了上述问题，可以点击源码进去学习思路，在这里我们直接示例（商品秒杀超卖），注意这里多线程并发用APIFOX工具模拟.

赋gitee源码示例：https://gitee.com/xzq25_com/redis_test

这里设置40个线程同时抢购商品，可以看到后台打印商品，注意：当前环境是Redis单机环境下，Redisson在分布式环境下模拟可以更为清楚的明白分布式锁的应用，这里不做模拟

核心代码示例：

 /**
     * 模拟商品超卖：扣减库存
     * @return
     * @throws InterruptedException
     */
    @PostMapping("/deductstock")
    public Map deductStock() throws InterruptedException {

        RLock lock = redission.getLock(COMMON + DUCESTOCK);
        
        //尝试获取锁20s,获取失败则返回
        boolean  requireLock = lock.tryLock(20, TimeUnit.SECONDS);
        Map  map = new HashMap<>();
        if(!requireLock){
            map.put("code",300);
            map.put("mes","获锁超时");
            return  map;
        }
        
        try {
            // 获取redis库中的商品库存数量
            Integer stock= Integer.parseInt(String.valueOf(redisUtil.get(STOCK)));
            if(stock>0){
                stock =  stock-1;
                redisUtil.set(STOCK,stock);
                System.out.println("商品扣减成功，剩余商品："+stock);
            }else{
                System.out.println("库存不足 剩余商品:"+stock);
            }

            map.put("code",200);
            map.put("mes","扣去库存成功,剩余库存数 stock="+stock);
            return  map;

        }catch (Exception e){
            map.put("code",500);
            map.put("mes","程序出错");
            e.printStackTrace();
            return map;
        }finally {
            // 释放锁
            lock.unlock();
        }

    }
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45