码迷,mamicode.com
首页 > 其他好文 > 详细

redis分布式锁的使用

时间:2020-07-06 23:55:00      阅读:80      评论:0      收藏:0      [点我收藏+]

标签:下单   dex   thread   lis   col   线程   bsp   tac   通过   

1.通过官方文档查看相关的命令操作:http://www.redis.cn/commands.html

  关键命令:setIfAbsent(String key,String value)对应官方文档的 setnx

       解释:将key设置值为value,如果key不存在,这种情况下等同SET命令。 当key存在时,什么也不做。SETNX是”SET if Not eXists”的简写。

      getAndSet

      解释:自动将key对应到value并且返回原来key对应的value。如果key存在但是对应的value不是字符串,就返回错误。(get旧值,set新值)

2.编写redisLock,即上锁和解锁的方法:

@Service
@Slf4j
public class RedisLock {
    @Autowired
    StringRedisTemplate template;

    public boolean lock(String key,String value){
        //1.如果能设置value表示锁没被占用,返回true表示上锁成功,否则进入下一步
        if (template.opsForValue().setIfAbsent(key,value)) {
            return true;
        }
        
        String currentValue = template.opsForValue().get(key);
        //2.这一步是为了防止死锁,因为如果被上锁的那段程序抛出异常,会导致无法执行解锁方法从而导致死锁
        //所以value的值应设为当前时间+超时时间,当Redis里的currentValue小于线程当前的系统时间,
        //说明死锁产生了,需解开这个死锁
        if(!StringUtils.isEmpty(currentValue)&&Long.valueOf(currentValue)<System.currentTimeMillis()) {
            //3.解死锁的操作,把原来的currentValue设置为新的value,并为拿到锁的新线程重新上锁
            String oldValue = template.opsForValue().getAndSet(key, value);
            //4.这步是为了防止在死锁产生的时候,同时有多个线程进来上锁
            // ,只有oldValue等于currentValue的线程才可成功上锁
            if(!StringUtils.isEmpty(oldValue)&&oldValue.equals(currentValue)) {
                template.opsForValue().set(key,value);
                return true;
            }
        }
        //上锁失败
        return false;
    }

    public void unlock(String key,String value){
        
        try {
            String currentValue = template.opsForValue().get(key);
            //只有在Redis里面的CurrentValue等于传进来的Value才能解锁
            if (!StringUtils.isEmpty(currentValue) && currentValue.equals(value)) {
                template.delete(key);
            }
        }catch (Exception e){
            log.error("【redis分布式锁】解锁异常, {}", e);
        }
    }
}

3.在相应的程序里调用redisLock

 @Override
    public String orderSecKillProduct(String productId) {
        //value的值设为当前时间+超时时间
        String time=String.valueOf(System.currentTimeMillis()+10*1000);
        //加锁
        if(!redisLock.lock(productId,time)){
            //上锁失败,抛出异常跳转到相应的页码
            throw  new SellException(101,"太多人抢购了,请重试");
        }
        //查询库存若为0则,提示已抢购完
        Integer stockNum = productStock.get(productId);
        if(stockNum==0){
            throw new SellException(100,"已被抢购完了");
        }
        //下单
        ordered.put(KeyUtil.genUniqueKey(), productId);
        //减库存
        stockNum=stockNum-1;
        try {
            Thread.sleep(100);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        //存入数据库
        productStock.put(productId,stockNum);
        //解锁
        redisLock.unlock(productId,time);
        //查询
        return query(productId);
    }

 

 

setIfAbsent

redis分布式锁的使用

标签:下单   dex   thread   lis   col   线程   bsp   tac   通过   

原文地址:https://www.cnblogs.com/shouyaya/p/13258414.html

(0)
(0)
   
举报
评论 一句话评论(0
登录后才能评论!
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码!