Redis分布式锁之setnx，expire，delete的用法

使用分布式锁的原因主要是为了控制高并发情况下多线程对于共享资源的访问。本文主要讲解如何运用Redis分布式锁的几个命令setnx(key, value)，expire(key, seconds)以及delete(key)实现一种简单的“分布式锁”。 内容 （1）首先要添加Redis的依赖（在本文是与Spring Boot进行整合）以及在application.properties配置文件进行主机号和端口号等一些配置。

<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-redis</artifactId>
    <version>1.3.5.RELEASE</version>
</dependency>

spring.redis.host=127.0.0.1
spring.redis.port=6379

（2）自定义注入跟Redis的操作组件相关的Bean配置，在这里主要是自定义注入配置RedisTemplate跟StringRedisTemplate操作组件。

// redis的通用化配置
@Configuration
public class RedisConfig {
    @Autowired
    private RedisConnectionFactory redisConnectionFactory;
 
    @Bean
    public RedisTemplate<String,Object> redisTemplate(){
        RedisTemplate<String,Object> redisTemplate=new RedisTemplate<>();
        redisTemplate.setConnectionFactory(redisConnectionFactory);
        //TODO:指定Key、Value的序列化策略
        redisTemplate.setKeySerializer(new StringRedisSerializer());
        redisTemplate.setValueSerializer(new JdkSerializationRedisSerializer());
 
        redisTemplate.setHashKeySerializer(new StringRedisSerializer());
        return redisTemplate;
    }
 
    @Bean
    public StringRedisTemplate stringRedisTemplate(){
        StringRedisTemplate stringRedisTemplate=new StringRedisTemplate();
        stringRedisTemplate.setConnectionFactory(redisConnectionFactory);
        return stringRedisTemplate;
    }
}

（3）分布式锁的使用

ValueOperations valueOperations=stringRedisTemplate.opsForValue();
//key一般使用用户唯一id或者其他id，主要是保证唯一；
//value可以使用时间戳+任意数；
String key = userId;
String value = RandomUtil.getAnyNum();
Boolean result=valueOperations.setIfAbsent(key,value);
if (result){
   stringRedisTemplate.expire(key,20, TimeUnit.SECONDS);
   try{
    	//主要业务逻辑
   }catch(Exception e){
   		throw new Exception(".....");
   }finally{
   		//真正“释放锁”的操作，判断一下当前要释放的锁是否就是之前一开始获取到的锁，
   		//如果是，就释放！这一点可以很好的避免误删锁的问题！
   		if (value.equals(valueOperations.get(key).toString())){
    		stringRedisTemplate.delete(key);
		}
   }
}

“setnx和expire”的解释： setIfAbsent其实就是setnx 首先判断缓存中是否存在该key-value，如果不存在缓存中则加入到缓存并返回true。 此时给锁加一个过期时间，在这里是20秒，主要是为了避免应用在服务重启或者异常导致锁无法释放后，不会出现锁一直无法被释放的情况。就是说20秒后锁无论有没有被释放都会自动过期，如果不过期的话就会出现key一直存在缓存当中，假如该key是使用用户id，那么就会导致该用户后期一直无法进行相关的业务操作，这是expire的作用：对锁在规定时间进行过期操作。