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

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

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

赋gitee源码示例:

这里设置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();
        }

    }
经验分享 程序员 微信小程序 职场和发展