高并发下的分布式锁

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"; //用
使用create-react-app快速搭建react环境
使用create-react-app快速搭建react环境 npm install create-react-app -g cd test_dir create-react-app demo_rea
redis的安装配置
先介绍mac的安装方法一、安装（首先你要先安装brew工具） brew install redis 然后在终端的末尾你会发现如下： if you don't want/need a backgr
redis 主从复制
一、集群的作用 1.主从备份防止主机宕机 2.读写分离分担master的任务 3.任务分离，如从服务器分别担任备份工作与计算工作二、redis集群配置 Master配置 1、关闭rdb快照
redis的过期策略以及内存淘汰机制
一、分析这个问题其实相当重要，到底redis有没用到家，这个问题就可以看出来。比如你redis只能存5G数据，可是你写了10G，那会删5G的数据。怎么删的，这个问题思考过么？还有，你的数据已经设置

高并发下的分布式锁

相关文章

随机推荐