redis分布式锁

原理

redis为单进程单线程模式，采用队列模式j将并发访问变成串行访问，多客户端对redis的连接不存在竞争关系，setnx命令来实现

命令

SETNX

将key
设置值为value
，如果key
不存在，这种情况下等同[SET](http://www.redis.cn/commands/set.html)命令。 当key
存在时，什么也不做。SETNX
是”SET if Not eXists”的简写。

GETSET

自动将key对应到value并且返回原来key对应的value。如果key存在但是对应的value不是字符串，就返回错误。

demo

public class RedisLock {
    @Autowired
    private StringRedisTemplate redisTemplate;

    /**
     *
     * @param key
     * @param value 当前时间+超时时间
     * @return
     */
    public boolean lock(String key,String value){
        if(redisTemplate.opsForValue().setIfAbsent(key,value)){
            return true;
        }

        String currentValue = redisTemplate.opsForValue().get(key);
        //如果锁过期
        if(!StringUtils.isEmpty(currentValue)
                && Long.parseLong(currentValue) < System.currentTimeMillis()){
            String oldValue = redisTemplate.opsForValue().getAndSet(key,value);
            if(!StringUtils.isEmpty(oldValue) && oldValue.equals(currentValue)){
                return true;
            }

        }
        return false;
    }

    public void unlock(String key,String value){
        try {
            String currentValue = redisTemplate.opsForValue().get(key);
            if (!StringUtils.isEmpty(currentValue) && value.equals(currentValue)) {
                redisTemplate.opsForValue().getOperations().delete(key);
            }
        }catch (Exception e){
            log.error("【redis分布式锁】解锁异常，{}",e);
        }
    }

}

1.解决死锁的问题

当程序中获取锁后，后面过程中出现异常可能会导致所不能释放，所以加入下面判断来解决

 String currentValue = redisTemplate.opsForValue().get(key);
        //如果锁过期
        if(!StringUtils.isEmpty(currentValue)
                && Long.parseLong(currentValue) < System.currentTimeMillis()){
            String oldValue = redisTemplate.opsForValue().getAndSet(key,value);
            if(!StringUtils.isEmpty(oldValue) && oldValue.equals(currentValue)){
                return true;
            }

        }

2.确保只有一个线程获得锁

如下判断来确保，所超时时，当有A,B两个线程刚进来，只有一个获得锁

if(!StringUtils.isEmpty(oldValue) && oldValue.equals(currentValue)){
                return true;
            }

释放锁，就是删除key

public void unlock(String key,String value){
        try {
            String currentValue = redisTemplate.opsForValue().get(key);
            if (!StringUtils.isEmpty(currentValue) && value.equals(currentValue)) {
                redisTemplate.opsForValue().getOperations().delete(key);
            }
        }catch (Exception e){
            log.error("【redis分布式锁】解锁异常，{}",e);
        }
    }