基于redis实现分布式锁

 基于redis实现分布式锁，主要原理在于key,每次访问时判断当前key是否存在于redis中，若存在则阻塞，若不存在则加入redis中同时获取redis锁。

但是java中获取key值，及向redis中塞入key以下是两个操作不是原子性的

　　1、 redis.get(key)

　　2、redis.setEx(key,60*5)

当线程A和线程B发生并发时，A和B同时get(key),为null，则代表A和B都可以获取当前锁，从而发生并发问题。

所以此处使用redis事务来避免此问题发生。

 public static boolean lock(String key){
       //获取redisTemplate
        RedisTemplate redisTemplate= RedisHelper.getTemplate();
        Boolean rs = (Boolean) redisTemplate.execute(new RedisCallback(key, 60*5));
        return  rs;
    }

    public static class RedisCallback implements org.springframework.data.redis.core.RedisCallback<Boolean> {
        private byte[] key;
        private int expire;

        public RedisCallback(String key,int expire) {
            this.expire = expire;
            this.key = RedisHelper.getTemplate().getStringSerializer().serialize(key);
        }


        @Override
        public Boolean doInRedis(RedisConnection redisConnection) throws DataAccessException {
            //开启监听，一旦当前key发生变化，事务将被中断,将不会执行返回null
            redisConnection.watch(key);
            //若key存在，则获取不到锁
            byte[] value= redisConnection.get(key);
            if(value!=null){
                return false;
            }
            //事务块开始
            redisConnection.multi();
            redisConnection.setEx(key,expire,new byte[]{'Y'});
            redisConnection.get(key);
            //事务块执行，其返回值为执行事务块呢内所有命令的返回值，也就是上边为何加一条get(key),用于判断执行结果
            List<Object> obj = redisConnection.exec();
            if(CollectionUtils.isNotEmpty(obj)&&obj.size()==1){
                //成功则获取该锁
                return true;
            }
            return false;
        }
    }