高并发下的分布式锁

public String deductStrck() throws InterruptedException{
    String lockKey = "product_001";    //用作一把分布式锁
    String clientId = UUID.randomUUID().toString();    //记录锁的id，防止别的线程可以解开这把锁

    try{
        //开始锁住
        //设置超时时间目的是为了防止程序突然中断而造成的死锁现象
        //锁的续命操作：时间设置为10，可以再开一个线程每3分钟检查一下看看这把锁是否存在，如果存在将过期时间再延长
        Boolean result = stringRedisTemplate.opsForValue().setIfAbsent(lockKey,clientId,10,TimeUnit.SECONDS)

        if(!result){
            return error;
        }

        //业务逻辑
        int stock Integer.parseInt(stringRedisTemplate.opsForValue().get("stock"));
        if(stock>0){
            int realStock = stock-1;
            stringRedisTemplate.opsForValue().set("stock",realStock);
            System.out.println("扣减成功，剩余库存"+realStock);
        }else{
            System.out.println("扣减失败，库存不足");
        }
    }finally{//最终要解开这把锁
        if(clientId.equals(stringRedisTemplate.opsForValue().get(lockKey))){//防止别的线程可以解开这把锁
            stringRedisTemplate.opsForValue().deleted(lockKey);
        }
    }
}

redisson提供完善的分布式锁：https://redisson.org

随机推荐

高并发下的分布式锁
public String deductStrck() throws InterruptedException{ String lockKey = "product_001"; //用
javascript中的正则表达式
javascript正则表达式的定义 JavaScript中的正则表达式定义在一个RegExp对象中，通过实例化一个RegExp构造函数来创建一个正则表达式对象var pattern=new R
gitlab备份与恢复
一、gitlab备份 [root@localhost ~]# gitlab-rake gitlab:backup:create Dumping database ... Dumping Postgr
如何应对缓存穿透和缓存雪崩问题
分析:这两个问题，说句实在话，一般中小型传统软件企业，很难碰到这个问题。如果有大并发的项目，流量有几百万左右。这两个问题一定要深刻考虑。缓存穿透，即黑客故意去请求缓存中不存在的数据，导致所有的请
php配置加载器
配置加载器当我们使用App::cfg系列方法获取配置时，wulaphp是通过配置加载器先加载配置然后再返回配置项对应值的（当然可以返回整个配置数组）。配置加载器ConfigurationLoade

高并发下的分布式锁

相关文章

随机推荐