高并发下的分布式锁

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

随机推荐

递归和分治思想
一、斐波那契数列 1 1 2 3 5 8 13 21 34 55 89 144 ...... 我们可以用数学函数来定义： |0，当n = 0 F(n) = |1，当n = 1
aof恢复与rdb服务器迁移
一、不小心flushall或flushdb了怎么办？？？只有aof还不够。因为如果发生重写，aof文件里就什么都没有了。所以要及时shutdown nosave,防止aof重写！！！然后将a
python变量作用域
在Python中并不是所有的语句块中都会产生作用域。只有当变量在Module(模块)、Class(类)、def(函数)中定义的时候，才会有作用域的概念。需要注意的是：在if-elif-else、f
反向代理缓存
一、传统代理很久以前，我们通常需要通过代理服务器来访问互联网上的Web站点，代理服务器本身接入了互联网，而我们通过内部网络与代理服务器相连。即便是现在，有些时候为了访问一些由于某种原因无法直接访问
使用宝塔面板定时任务不执行问题处理
定时任务不执行不用宝塔自带的计划任务，因为宝塔自带的计划任务无法以www:www身份去执行任务，会导致面板无法正常写入日志在vps中输入：crontab -e -uwww ，然后贴上 * * *

高并发下的分布式锁

相关文章

随机推荐