redis集群下分布式锁的实现

比眉伴天荒 2022-05-22 07:37 162阅读 0赞

1,redis集群的配置文件

<table style="height:200px;"> 
 <tbody> 
 <tr> 
 <td>redis.cluster.nodes=192.168.1.102:7000,192.168.1.102:7001,192.168.1.102:7002,192.168.1.102:7003,192.168.1.102:7004,192.168.1.102:7005 redis.cluster.testOnReturn=true redis.cluster.maxIdle=10 redis.cluster.minIdle=2 redis.cluster.maxWaitMills=3000 redis.cluster.testOnBorrow=true redis.cluster.maxTotal=4 redis.cluster.connectionTimeOut=30000</td> 
 </tr> 
 </tbody> 
</table>

2，redis集群的连接配置

<table style="height:200px;"> 
 <tbody> 
 <tr> 
 <td>/** * 提供集群部署的情况下面的redisTemplate支持 * @param factory * @return */ @Bean("redisTemplate") &nbsp; &nbsp; public RedisTemplate&lt;Object, Object&gt; redisTemplate(RedisConnectionFactory factory) { &nbsp; &nbsp; &nbsp; &nbsp; RedisTemplate&lt;Object, Object&gt; redisTemplate = new RedisTemplate&lt;Object, Object&gt;(); &nbsp; &nbsp; &nbsp; &nbsp; redisTemplate.setConnectionFactory(factory); &nbsp; &nbsp; &nbsp; &nbsp; Jackson2JsonRedisSerializer&lt;Object&gt; serializer = new Jackson2JsonRedisSerializer&lt;Object&gt;(Object.class); &nbsp; &nbsp; &nbsp; &nbsp; ObjectMapper om = new ObjectMapper(); &nbsp; &nbsp; &nbsp; &nbsp; om.setVisibility(PropertyAccessor.ALL, JsonAutoDetect.Visibility.ANY); &nbsp; &nbsp; &nbsp; &nbsp; om.enableDefaultTyping(ObjectMapper.DefaultTyping.NON_FINAL); &nbsp; &nbsp; &nbsp; &nbsp; serializer.setObjectMapper(om); &nbsp; &nbsp; &nbsp; &nbsp; redisTemplate.setKeySerializer(serializer); &nbsp; &nbsp; &nbsp; &nbsp; redisTemplate.setValueSerializer(serializer); &nbsp; &nbsp; &nbsp; &nbsp; redisTemplate.afterPropertiesSet(); &nbsp; &nbsp; &nbsp; &nbsp; //redisTemplate.setEnableTransactionSupport(true); &nbsp; &nbsp; &nbsp; &nbsp; return redisTemplate; &nbsp; &nbsp; } /** &nbsp; &nbsp; &nbsp;* jedis 连接池 &nbsp; &nbsp; &nbsp;* @return &nbsp; &nbsp; &nbsp;*/ &nbsp; &nbsp; private JedisPoolConfig jedisPoolConfig() { &nbsp; &nbsp; &nbsp; &nbsp; JedisPoolConfig config = new JedisPoolConfig(); &nbsp; &nbsp; &nbsp; &nbsp; config.setMaxTotal(redisConfig.getCluster().getMaxTotal()); &nbsp; &nbsp; &nbsp; &nbsp; config.setMaxIdle(redisConfig.getCluster().getMaxIdle()); &nbsp; &nbsp; &nbsp; &nbsp; config.setMaxWaitMillis(redisConfig.getCluster().getMaxWaitMills()); &nbsp; &nbsp; &nbsp; &nbsp; config.setTestOnBorrow(redisConfig.getCluster().getTestOnBorrow()); &nbsp; &nbsp; &nbsp; &nbsp; return config; &nbsp; &nbsp; } &nbsp; &nbsp;&nbsp; &nbsp; &nbsp; @Bean(name = "redisCacheManager") &nbsp; &nbsp; public CacheManager cacheManager(RedisTemplate&lt;Object, Object&gt; redisTemplate) { &nbsp; &nbsp; &nbsp; &nbsp; RedisCacheManager cacheManager = new RedisCacheManager(redisTemplate); &nbsp; &nbsp; &nbsp; &nbsp; cacheManager.setDefaultExpiration(1800); &nbsp; &nbsp; &nbsp; &nbsp; return cacheManager; &nbsp; &nbsp; } &nbsp; &nbsp;&nbsp; &nbsp; &nbsp; /** &nbsp; &nbsp; &nbsp;* redisCluster配置 &nbsp; &nbsp; &nbsp;* &nbsp; &nbsp; &nbsp;* @return &nbsp; &nbsp; &nbsp;*/ &nbsp; &nbsp; @Bean &nbsp; &nbsp; public RedisClusterConfiguration redisProperties() { &nbsp; &nbsp; &nbsp; &nbsp; Map&lt;String, Object&gt; source = new HashMap&lt;String, Object&gt;(); &nbsp; &nbsp; &nbsp; &nbsp; source.put("spring.redis.cluster.nodes", redisConfig.getCluster().getNodes()); &nbsp; &nbsp; &nbsp; &nbsp; source.put("spring.redis.cluster.timeout", redisConfig.getCluster().getConnectionTimeOut()); &nbsp; &nbsp; &nbsp; &nbsp; return new RedisClusterConfiguration(new MapPropertySource("RedisProperties", source)); &nbsp; &nbsp; } &nbsp; &nbsp;&nbsp; &nbsp; &nbsp; @Bean("jedisConnFactory") &nbsp; &nbsp; public JedisConnectionFactory jedisConnectionFactory() { &nbsp; &nbsp; &nbsp; &nbsp; //redis cluster &nbsp; &nbsp; &nbsp; &nbsp; JedisConnectionFactory factory = new JedisConnectionFactory(redisProperties(),jedisPoolConfig()); &nbsp; &nbsp; &nbsp; &nbsp; return factory; &nbsp; &nbsp; }</td> 
 </tr> 
 </tbody> 
</table>

3，redis集群下分布式锁的主要实现方法

<table style="height:200px;"> 
 <tbody> 
 <tr> 
 <td>package com.dream21th.dream21thredis.lock; import java.util.Random; import org.springframework.dao.DataAccessException; import org.springframework.data.redis.connection.RedisConnection; import org.springframework.data.redis.core.RedisCallback; import org.springframework.data.redis.core.RedisTemplate; import org.springframework.data.redis.serializer.Jackson2JsonRedisSerializer; import lombok.extern.slf4j.Slf4j; /** &nbsp;* Redis distributed lock implementation. &nbsp;* &nbsp;* @author dream21th &nbsp;*/ @Slf4j public class RedisLock { &nbsp; &nbsp; private RedisTemplate redisTemplate; &nbsp; &nbsp; private static final int DEFAULT_ACQUIRY_RESOLUTION_MILLIS = 100; &nbsp; &nbsp; /** &nbsp; &nbsp; &nbsp;* Lock key path. &nbsp; &nbsp; &nbsp;*/ &nbsp; &nbsp; private String lockKey; &nbsp; &nbsp; /** &nbsp; &nbsp; &nbsp;* 锁超时时间，防止线程在入锁以后，无限的执行等待 &nbsp; &nbsp; &nbsp;*/ &nbsp; &nbsp; private int expireMsecs = 60 * 1000; &nbsp; &nbsp; /** &nbsp; &nbsp; &nbsp;* 锁等待时间，防止线程饥饿 &nbsp; &nbsp; &nbsp;*/ &nbsp; &nbsp; private int timeoutMsecs = 10 * 1000; &nbsp; &nbsp; private volatile boolean locked = false; &nbsp; &nbsp; /** &nbsp; &nbsp; &nbsp;* Detailed constructor with default acquire timeout 10000 msecs and lock expiration of 60000 msecs. &nbsp; &nbsp; &nbsp;* &nbsp; &nbsp; &nbsp;* @param lockKey lock key (ex. account:1, ...) &nbsp; &nbsp; &nbsp;*/ &nbsp; &nbsp; public RedisLock(RedisTemplate redisTemplate, String lockKey) { &nbsp; &nbsp; &nbsp; &nbsp; this.redisTemplate = redisTemplate; &nbsp; &nbsp; &nbsp; &nbsp; this.lockKey = lockKey + "_lock"; &nbsp; &nbsp; } &nbsp; &nbsp; /** &nbsp; &nbsp; &nbsp;* Detailed constructor with default lock expiration of 60000 msecs. &nbsp; &nbsp; &nbsp;* &nbsp; &nbsp; &nbsp;*/ &nbsp; &nbsp; public RedisLock(RedisTemplate redisTemplate, String lockKey, int timeoutMsecs) { &nbsp; &nbsp; &nbsp; &nbsp; this(redisTemplate, lockKey); &nbsp; &nbsp; &nbsp; &nbsp; this.timeoutMsecs = timeoutMsecs; &nbsp; &nbsp; } &nbsp; &nbsp; /** &nbsp; &nbsp; &nbsp;* Detailed constructor. &nbsp; &nbsp; &nbsp;* &nbsp; &nbsp; &nbsp;*/ public RedisLock(RedisTemplate redisTemplate, String lockKey, int timeoutMsecs, int expireMsecs) { &nbsp; &nbsp; &nbsp; &nbsp; this(redisTemplate, lockKey, timeoutMsecs); &nbsp; &nbsp; &nbsp; &nbsp; this.expireMsecs = expireMsecs; &nbsp; &nbsp; } &nbsp; &nbsp; /** &nbsp; &nbsp; &nbsp;* @return lock key &nbsp; &nbsp; &nbsp;*/ &nbsp; &nbsp; public String getLockKey() { &nbsp; &nbsp; &nbsp; &nbsp; return lockKey; &nbsp; &nbsp; } &nbsp; &nbsp; private String get(final String key) { &nbsp; &nbsp; &nbsp; &nbsp; Object obj = null; &nbsp; &nbsp; &nbsp; &nbsp; try { &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; obj = redisTemplate.execute(new RedisCallback&lt;Object&gt;() { &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; @Override &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; public Object doInRedis(RedisConnection connection) throws DataAccessException { &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; //StringRedisSerializer serializer = new StringRedisSerializer(); &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; Jackson2JsonRedisSerializer&lt;Object&gt; serializer = new Jackson2JsonRedisSerializer&lt;Object&gt;(Object.class); &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; byte[] data = connection.get(serializer.serialize(key)); &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; connection.close(); &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; if (data == null) { &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; return null; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; } &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; return serializer.deserialize(data); &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; } &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; }); &nbsp; &nbsp; &nbsp; &nbsp; } catch (Exception e) { &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; log.error("get redis error, key : {}", key); &nbsp; &nbsp; &nbsp; &nbsp; } &nbsp; &nbsp; &nbsp; &nbsp; return obj != null ? obj.toString() : null; &nbsp; &nbsp; } &nbsp; &nbsp; private boolean setNX(final String key, final String value) { &nbsp; &nbsp; &nbsp; &nbsp; Object obj = null; &nbsp; &nbsp; &nbsp; &nbsp; try { &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; obj = redisTemplate.execute(new RedisCallback&lt;Object&gt;() { &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; @Override &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; public Object doInRedis(RedisConnection connection) throws DataAccessException { &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; //StringRedisSerializer serializer = new StringRedisSerializer(); &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; Jackson2JsonRedisSerializer&lt;Object&gt; serializer = new Jackson2JsonRedisSerializer&lt;Object&gt;(Object.class); &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; Boolean success = connection.setNX(serializer.serialize(key), serializer.serialize(value)); &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; connection.close(); &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; return success; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; } &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; }); &nbsp; &nbsp; &nbsp; &nbsp; } catch (Exception e) { &nbsp; &nbsp; &nbsp; &nbsp; log.info("{}",e); &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; log.error("setNX redis error, key : {}", key); &nbsp; &nbsp; &nbsp; &nbsp; } &nbsp; &nbsp; &nbsp; &nbsp; return obj != null ? (Boolean) obj : false; &nbsp; &nbsp; } &nbsp; &nbsp; private String getSet(final String key, final String value) { &nbsp; &nbsp; &nbsp; &nbsp; Object obj = null; &nbsp; &nbsp; &nbsp; &nbsp; try { &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; obj = redisTemplate.execute(new RedisCallback&lt;Object&gt;() { &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; @Override &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; public Object doInRedis(RedisConnection connection) throws DataAccessException { &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; //StringRedisSerializer serializer = new StringRedisSerializer(); &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; Jackson2JsonRedisSerializer&lt;Object&gt; serializer = new Jackson2JsonRedisSerializer&lt;Object&gt;(Object.class); &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; byte[] ret = connection.getSet(serializer.serialize(key), serializer.serialize(value)); &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; connection.close(); &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; return serializer.deserialize(ret); &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; } &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; }); &nbsp; &nbsp; &nbsp; &nbsp; } catch (Exception e) { &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; log.error("setNX redis error, key : {}", key); &nbsp; &nbsp; &nbsp; &nbsp; } &nbsp; &nbsp; &nbsp; &nbsp; return obj != null ? (String) obj : null; &nbsp; &nbsp; } &nbsp; &nbsp; /** &nbsp; &nbsp; &nbsp;* 获得 lock. &nbsp; &nbsp; &nbsp;* 实现思路: 主要是使用了redis 的setnx命令,缓存了锁. &nbsp; &nbsp; &nbsp;* reids缓存的key是锁的key,所有的共享, value是锁的到期时间(注意:这里把过期时间放在value了,没有时间上设置其超时时间) &nbsp; &nbsp; &nbsp;* 执行过程: &nbsp; &nbsp; &nbsp;* 1.通过setnx尝试设置某个key的值,成功(当前没有这个锁)则返回,成功获得锁 &nbsp; &nbsp; &nbsp;* 2.锁已经存在则获取锁的到期时间,和当前时间比较,超时的话,则设置新的值 &nbsp; &nbsp; &nbsp;* &nbsp; &nbsp; &nbsp;* @return true if lock is acquired, false acquire timeouted &nbsp; &nbsp; &nbsp;* @throws InterruptedException in case of thread interruption &nbsp; &nbsp; &nbsp;*/ &nbsp; &nbsp; public boolean lock() throws InterruptedException { &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; int timeout = timeoutMsecs; &nbsp; &nbsp; &nbsp; &nbsp; while (timeout &gt;= 0) { &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; long expires = System.currentTimeMillis() + expireMsecs + 1; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; String expiresStr = String.valueOf(expires); //锁到期时间 &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; //log.info("=========="+Thread.currentThread().getName()+"========="+timeout); &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; if (this.setNX(lockKey, expiresStr)) { &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; // lock acquired &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; locked = true; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; return true; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; } &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; String currentValueStr = this.get(lockKey); //redis里的时间 &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; if (currentValueStr != null &amp;&amp; Long.parseLong(currentValueStr) &lt; System.currentTimeMillis()) { &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; //判断是否为空，不为空的情况下，如果被其他线程设置了值，则第二个条件判断是过不去的 &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; // lock is expired &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; String oldValueStr = this.getSet(lockKey, expiresStr); &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; //获取上一个锁到期时间，并设置现在的锁到期时间， &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; //只有一个线程才能获取上一个线上的设置时间，因为jedis.getSet是同步的 &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; if (oldValueStr != null &amp;&amp; oldValueStr.equals(currentValueStr)) { &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; //防止误删（覆盖，因为key是相同的）了他人的锁——这里达不到效果，这里值会被覆盖，但是因为什么相差了很少的时间，所以可以接受 &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; //[分布式的情况下]:如过这个时候，多个线程恰好都到了这里，但是只有一个线程的设置值和当前值相同，他才有权利获取锁 &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; // lock acquired &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; locked = true; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; return true; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; } &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; } &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; //timeout -= DEFAULT_ACQUIRY_RESOLUTION_MILLIS; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; int sleepTime=new Random().nextInt(10)*DEFAULT_ACQUIRY_RESOLUTION_MILLIS; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; timeout -=sleepTime; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; //log.info("=========="+Thread.currentThread().getName()+"========="+sleepTime); &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; /* &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; 延迟100 毫秒,&nbsp; 这里使用随机时间可能会好一点,可以防止饥饿进程的出现,即,当同时到达多个进程, &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; 只会有一个进程获得锁,其他的都用同样的频率进行尝试,后面有来了一些进行,也以同样的频率申请锁,这将可能导致前面来的锁得不到满足. &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; 使用随机的等待时间可以一定程度上保证公平性 &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp;*/ &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; Thread.sleep(sleepTime); &nbsp; &nbsp; &nbsp; &nbsp; } &nbsp; &nbsp; &nbsp; &nbsp; return false; &nbsp; &nbsp; } &nbsp; &nbsp; /** &nbsp; &nbsp; &nbsp;* Acqurired lock release. &nbsp; &nbsp; &nbsp;*/ &nbsp; &nbsp; public void unlock() { &nbsp; &nbsp; &nbsp; &nbsp; if (locked) { &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; redisTemplate.delete(lockKey); &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; locked = false; &nbsp; &nbsp; &nbsp; &nbsp; } &nbsp; &nbsp; } &nbsp; &nbsp;&nbsp; &nbsp; &nbsp;&nbsp; &nbsp; &nbsp; public boolean isExpired(){ &nbsp; &nbsp; String currentValueStr = this.get(lockKey); //redis里的时间 &nbsp; &nbsp; if(currentValueStr==null){ &nbsp; &nbsp; return true; &nbsp; &nbsp; } &nbsp; &nbsp; return Long.parseLong(currentValueStr) &lt; System.currentTimeMillis()?true:false; &nbsp; &nbsp; } }</td> 
 </tr> 
 </tbody> 
</table>

4，测试方法，模仿100的线程操作（）

<table style="height:200px;"> 
 <tbody> 
 <tr> 
 <td>package com.dream21th.dream21thredis.service; import java.util.stream.IntStream; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.data.redis.core.RedisTemplate; import org.springframework.stereotype.Service; import com.dream21th.dream21thredis.lock.RedisLock; import lombok.extern.slf4j.Slf4j; @Slf4j @Service public class RedisLockService { @Autowired private RedisTemplate&lt;Object, Object&gt; redisTemplate; private static String key = "lock-test"; private static int count=10; public void test() { RedisLock lock = new RedisLock(redisTemplate, key, 10000, 20000); try { if (lock.lock()) { log.info(Thread.currentThread().getName()+"------&gt;&gt;&gt;&gt;begin"); Thread.sleep(1000); if(count&gt;=1){ &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; count--; log.info("count:{}",count); } log.info(Thread.currentThread().getName()+"------&gt;&gt;&gt;&gt;end"); } } catch (InterruptedException e) { e.printStackTrace(); } finally { // 为了让分布式锁的算法更稳键些，持有锁的客户端在解锁之前应该再检查一次自己的锁是否已经超时，再去做DEL操作，因为可能客户端因为某个耗时的操作而挂起， // 操作完的时候锁因为超时已经被别人获得，这时就不必解锁了. if(!lock.isExpired()){ lock.unlock(); } } } public void run(){ IntStream.range(0, 100).forEach(i-&gt;{ Thread run=new Thread(new Runnable() { @Override public void run() { test(); } }); run.start(); }); } }5，测试controller 
 <table style="height:200px;"> 
 <tbody> 
 <tr> 
 <td>package com.dream21th.dream21thredis.controller; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.web.bind.annotation.PostMapping; import org.springframework.web.bind.annotation.RequestMapping; import org.springframework.web.bind.annotation.RestController; import com.dream21th.dream21thredis.service.RedisLockService; @RestController @RequestMapping("/redisLock") public class RedisLockController { @Autowired private RedisLockService redisLockService; @PostMapping("/testLock") public void testRedisLock(){ redisLockService.run(); } }</td> 
 </tr> 
 </tbody> 
 </table>6，测试结果 
 <table style="height:200px;"> 
 <tbody> 
 <tr> 
 <td>2018-06-19 14:42:40.706&nbsp; INFO 7064 --- [nio-8080-exec-1] o.a.c.c.C.[Tomcat].[localhost].[/]&nbsp; &nbsp; &nbsp; &nbsp;: Initializing Spring FrameworkServlet 'dispatcherServlet' 2018-06-19 14:42:40.706&nbsp; INFO 7064 --- [nio-8080-exec-1] o.s.web.servlet.DispatcherServlet&nbsp; &nbsp; &nbsp; &nbsp; : FrameworkServlet 'dispatcherServlet': initialization started 2018-06-19 14:42:40.821&nbsp; INFO 7064 --- [nio-8080-exec-1] o.s.web.servlet.DispatcherServlet&nbsp; &nbsp; &nbsp; &nbsp; : FrameworkServlet 'dispatcherServlet': initialization completed in 115 ms 2018-06-19 14:42:41.072&nbsp; INFO 7064 --- [&nbsp; &nbsp; &nbsp; Thread-93] c.d.d.service.RedisLockService&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp;: Thread-93------&gt;&gt;&gt;&gt;begin 2018-06-19 14:42:42.072&nbsp; INFO 7064 --- [&nbsp; &nbsp; &nbsp; Thread-93] c.d.d.service.RedisLockService&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp;: count:9 2018-06-19 14:42:42.072&nbsp; INFO 7064 --- [&nbsp; &nbsp; &nbsp; Thread-93] c.d.d.service.RedisLockService&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp;: Thread-93------&gt;&gt;&gt;&gt;end 2018-06-19 14:42:42.079&nbsp; INFO 7064 --- [&nbsp; &nbsp; &nbsp; Thread-73] c.d.d.service.RedisLockService&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp;: Thread-73------&gt;&gt;&gt;&gt;begin 2018-06-19 14:42:43.080&nbsp; INFO 7064 --- [&nbsp; &nbsp; &nbsp; Thread-73] c.d.d.service.RedisLockService&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp;: count:8 2018-06-19 14:42:43.080&nbsp; INFO 7064 --- [&nbsp; &nbsp; &nbsp; Thread-73] c.d.d.service.RedisLockService&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp;: Thread-73------&gt;&gt;&gt;&gt;end 2018-06-19 14:42:43.335&nbsp; INFO 7064 --- [&nbsp; &nbsp; &nbsp;Thread-100] c.d.d.service.RedisLockService&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp;: Thread-100------&gt;&gt;&gt;&gt;begin 2018-06-19 14:42:44.336&nbsp; INFO 7064 --- [&nbsp; &nbsp; &nbsp;Thread-100] c.d.d.service.RedisLockService&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp;: count:7 2018-06-19 14:42:44.336&nbsp; INFO 7064 --- [&nbsp; &nbsp; &nbsp;Thread-100] c.d.d.service.RedisLockService&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp;: Thread-100------&gt;&gt;&gt;&gt;end 2018-06-19 14:42:44.341&nbsp; INFO 7064 --- [&nbsp; &nbsp; &nbsp; Thread-21] c.d.d.service.RedisLockService&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp;: Thread-21------&gt;&gt;&gt;&gt;begin 2018-06-19 14:42:45.341&nbsp; INFO 7064 --- [&nbsp; &nbsp; &nbsp; Thread-21] c.d.d.service.RedisLockService&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp;: count:6 2018-06-19 14:42:45.341&nbsp; INFO 7064 --- [&nbsp; &nbsp; &nbsp; Thread-21] c.d.d.service.RedisLockService&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp;: Thread-21------&gt;&gt;&gt;&gt;end 2018-06-19 14:42:45.346&nbsp; INFO 7064 --- [&nbsp; &nbsp; &nbsp; Thread-78] c.d.d.service.RedisLockService&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp;: Thread-78------&gt;&gt;&gt;&gt;begin 2018-06-19 14:42:46.346&nbsp; INFO 7064 --- [&nbsp; &nbsp; &nbsp; Thread-78] c.d.d.service.RedisLockService&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp;: count:5 2018-06-19 14:42:46.346&nbsp; INFO 7064 --- [&nbsp; &nbsp; &nbsp; Thread-78] c.d.d.service.RedisLockService&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp;: Thread-78------&gt;&gt;&gt;&gt;end 2018-06-19 14:42:46.353&nbsp; INFO 7064 --- [&nbsp; &nbsp; &nbsp; Thread-16] c.d.d.service.RedisLockService&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp;: Thread-16------&gt;&gt;&gt;&gt;begin 2018-06-19 14:42:47.353&nbsp; INFO 7064 --- [&nbsp; &nbsp; &nbsp; Thread-16] c.d.d.service.RedisLockService&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp;: count:4 2018-06-19 14:42:47.353&nbsp; INFO 7064 --- [&nbsp; &nbsp; &nbsp; Thread-16] c.d.d.service.RedisLockService&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp;: Thread-16------&gt;&gt;&gt;&gt;end 2018-06-19 14:42:47.361&nbsp; INFO 7064 --- [&nbsp; &nbsp; &nbsp; Thread-47] c.d.d.service.RedisLockService&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp;: Thread-47------&gt;&gt;&gt;&gt;begin 2018-06-19 14:42:48.361&nbsp; INFO 7064 --- [&nbsp; &nbsp; &nbsp; Thread-47] c.d.d.service.RedisLockService&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp;: count:3 2018-06-19 14:42:48.361&nbsp; INFO 7064 --- [&nbsp; &nbsp; &nbsp; Thread-47] c.d.d.service.RedisLockService&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp;: Thread-47------&gt;&gt;&gt;&gt;end 2018-06-19 14:42:48.448&nbsp; INFO 7064 --- [&nbsp; &nbsp; &nbsp; Thread-31] c.d.d.service.RedisLockService&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp;: Thread-31------&gt;&gt;&gt;&gt;begin 2018-06-19 14:42:49.448&nbsp; INFO 7064 --- [&nbsp; &nbsp; &nbsp; Thread-31] c.d.d.service.RedisLockService&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp;: count:2 2018-06-19 14:42:49.448&nbsp; INFO 7064 --- [&nbsp; &nbsp; &nbsp; Thread-31] c.d.d.service.RedisLockService&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp;: Thread-31------&gt;&gt;&gt;&gt;end 2018-06-19 14:42:49.458&nbsp; INFO 7064 --- [&nbsp; &nbsp; &nbsp; Thread-61] c.d.d.service.RedisLockService&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp;: Thread-61------&gt;&gt;&gt;&gt;begin 2018-06-19 14:42:50.459&nbsp; INFO 7064 --- [&nbsp; &nbsp; &nbsp; Thread-61] c.d.d.service.RedisLockService&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp;: count:1 2018-06-19 14:42:50.460&nbsp; INFO 7064 --- [&nbsp; &nbsp; &nbsp; Thread-61] c.d.d.service.RedisLockService&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp;: Thread-61------&gt;&gt;&gt;&gt;end 2018-06-19 14:42:50.472&nbsp; INFO 7064 --- [&nbsp; &nbsp; &nbsp; Thread-94] c.d.d.service.RedisLockService&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp;: Thread-94------&gt;&gt;&gt;&gt;begin 2018-06-19 14:42:51.473&nbsp; INFO 7064 --- [&nbsp; &nbsp; &nbsp; Thread-94] c.d.d.service.RedisLockService&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp;: count:0 2018-06-19 14:42:51.473&nbsp; INFO 7064 --- [&nbsp; &nbsp; &nbsp; Thread-94] c.d.d.service.RedisLockService&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp;: Thread-94------&gt;&gt;&gt;&gt;end 2018-06-19 14:42:51.501&nbsp; INFO 7064 --- [&nbsp; &nbsp; &nbsp; Thread-12] c.d.d.service.RedisLockService&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp;: Thread-12------&gt;&gt;&gt;&gt;begin 2018-06-19 14:42:52.501&nbsp; INFO 7064 --- [&nbsp; &nbsp; &nbsp; Thread-12] c.d.d.service.RedisLockService&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp;: Thread-12------&gt;&gt;&gt;&gt;end</td> 
 </tr> 
 </tbody> 
 </table>2018-06-19 14:42:40.706&nbsp; INFO 7064 --- [nio-8080-exec-1] o.a.c.c.C.[Tomcat].[localhost].[/]&nbsp; &nbsp; &nbsp; &nbsp;: Initializing Spring FrameworkServlet 'dispatcherServlet' 2018-06-19 14:42:40.706&nbsp; INFO 7064 --- [nio-8080-exec-1] o.s.web.servlet.DispatcherServlet&nbsp; &nbsp; &nbsp; &nbsp; : FrameworkServlet 'dispatcherServlet': initialization started 2018-06-19 14:42:40.821&nbsp; INFO 7064 --- [nio-8080-exec-1] o.s.web.servlet.DispatcherServlet&nbsp; &nbsp; &nbsp; &nbsp; : FrameworkServlet 'dispatcherServlet': initialization completed in 115 ms 2018-06-19 14:42:41.072&nbsp; INFO 7064 --- [&nbsp; &nbsp; &nbsp; Thread-93] c.d.d.service.RedisLockService&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp;: Thread-93------&gt;&gt;&gt;&gt;begin 2018-06-19 14:42:42.072&nbsp; INFO 7064 --- [&nbsp; &nbsp; &nbsp; Thread-93] c.d.d.service.RedisLockService&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp;: count:9 2018-06-19 14:42:42.072&nbsp; INFO 7064 --- [&nbsp; &nbsp; &nbsp; Thread-93] c.d.d.service.RedisLockService&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp;: Thread-93------&gt;&gt;&gt;&gt;end 2018-06-19 14:42:42.079&nbsp; INFO 7064 --- [&nbsp; &nbsp; &nbsp; Thread-73] c.d.d.service.RedisLockService&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp;: Thread-73------&gt;&gt;&gt;&gt;begin 2018-06-19 14:42:43.080&nbsp; INFO 7064 --- [&nbsp; &nbsp; &nbsp; Thread-73] c.d.d.service.RedisLockService&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp;: count:8 2018-06-19 14:42:43.080&nbsp; INFO 7064 --- [&nbsp; &nbsp; &nbsp; Thread-73] c.d.d.service.RedisLockService&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp;: Thread-73------&gt;&gt;&gt;&gt;end 2018-06-19 14:42:43.335&nbsp; INFO 7064 --- [&nbsp; &nbsp; &nbsp;Thread-100] c.d.d.service.RedisLockService&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp;: Thread-100------&gt;&gt;&gt;&gt;begin 2018-06-19 14:42:44.336&nbsp; INFO 7064 --- [&nbsp; &nbsp; &nbsp;Thread-100] c.d.d.service.RedisLockService&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp;: count:7 2018-06-19 14:42:44.336&nbsp; INFO 7064 --- [&nbsp; &nbsp; &nbsp;Thread-100] c.d.d.service.RedisLockService&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp;: Thread-100------&gt;&gt;&gt;&gt;end 2018-06-19 14:42:44.341&nbsp; INFO 7064 --- [&nbsp; &nbsp; &nbsp; Thread-21] c.d.d.service.RedisLockService&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp;: Thread-21------&gt;&gt;&gt;&gt;begin 2018-06-19 14:42:45.341&nbsp; INFO 7064 --- [&nbsp; &nbsp; &nbsp; Thread-21] c.d.d.service.RedisLockService&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp;: count:6 2018-06-19 14:42:45.341&nbsp; INFO 7064 --- [&nbsp; &nbsp; &nbsp; Thread-21] c.d.d.service.RedisLockService&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp;: Thread-21------&gt;&gt;&gt;&gt;end 2018-06-19 14:42:45.346&nbsp; INFO 7064 --- [&nbsp; &nbsp; &nbsp; Thread-78] c.d.d.service.RedisLockService&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp;: Thread-78------&gt;&gt;&gt;&gt;begin 2018-06-19 14:42:46.346&nbsp; INFO 7064 --- [&nbsp; &nbsp; &nbsp; Thread-78] c.d.d.service.RedisLockService&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp;: count:5 2018-06-19 14:42:46.346&nbsp; INFO 7064 --- [&nbsp; &nbsp; &nbsp; Thread-78] c.d.d.service.RedisLockService&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp;: Thread-78------&gt;&gt;&gt;&gt;end 2018-06-19 14:42:46.353&nbsp; INFO 7064 --- [&nbsp; &nbsp; &nbsp; Thread-16] c.d.d.service.RedisLockService&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp;: Thread-16------&gt;&gt;&gt;&gt;begin 2018-06-19 14:42:47.353&nbsp; INFO 7064 --- [&nbsp; &nbsp; &nbsp; Thread-16] c.d.d.service.RedisLockService&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp;: count:4 2018-06-19 14:42:47.353&nbsp; INFO 7064 --- [&nbsp; &nbsp; &nbsp; Thread-16] c.d.d.service.RedisLockService&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp;: Thread-16------&gt;&gt;&gt;&gt;end 2018-06-19 14:42:47.361&nbsp; INFO 7064 --- [&nbsp; &nbsp; &nbsp; Thread-47] c.d.d.service.RedisLockService&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp;: Thread-47------&gt;&gt;&gt;&gt;begin 2018-06-19 14:42:48.361&nbsp; INFO 7064 --- [&nbsp; &nbsp; &nbsp; Thread-47] c.d.d.service.RedisLockService&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp;: count:3 2018-06-19 14:42:48.361&nbsp; INFO 7064 --- [&nbsp; &nbsp; &nbsp; Thread-47] c.d.d.service.RedisLockService&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp;: Thread-47------&gt;&gt;&gt;&gt;end 2018-06-19 14:42:48.448&nbsp; INFO 7064 --- [&nbsp; &nbsp; &nbsp; Thread-31] c.d.d.service.RedisLockService&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp;: Thread-31------&gt;&gt;&gt;&gt;begin 2018-06-19 14:42:49.448&nbsp; INFO 7064 --- [&nbsp; &nbsp; &nbsp; Thread-31] c.d.d.service.RedisLockService&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp;: count:2 2018-06-19 14:42:49.448&nbsp; INFO 7064 --- [&nbsp; &nbsp; &nbsp; Thread-31] c.d.d.service.RedisLockService&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp;: Thread-31------&gt;&gt;&gt;&gt;end 2018-06-19 14:42:49.458&nbsp; INFO 7064 --- [&nbsp; &nbsp; &nbsp; Thread-61] c.d.d.service.RedisLockService&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp;: Thread-61------&gt;&gt;&gt;&gt;begin 2018-06-19 14:42:50.459&nbsp; INFO 7064 --- [&nbsp; &nbsp; &nbsp; Thread-61] c.d.d.service.RedisLockService&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp;: count:1 2018-06-19 14:42:50.460&nbsp; INFO 7064 --- [&nbsp; &nbsp; &nbsp; Thread-61] c.d.d.service.RedisLockService&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp;: Thread-61------&gt;&gt;&gt;&gt;end 2018-06-19 14:42:50.472&nbsp; INFO 7064 --- [&nbsp; &nbsp; &nbsp; Thread-94] c.d.d.service.RedisLockService&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp;: Thread-94------&gt;&gt;&gt;&gt;begin 2018-06-19 14:42:51.473&nbsp; INFO 7064 --- [&nbsp; &nbsp; &nbsp; Thread-94] c.d.d.service.RedisLockService&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp;: count:0 2018-06-19 14:42:51.473&nbsp; INFO 7064 --- [&nbsp; &nbsp; &nbsp; Thread-94] c.d.d.service.RedisLockService&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp;: Thread-94------&gt;&gt;&gt;&gt;end 2018-06-19 14:42:51.501&nbsp; INFO 7064 --- [&nbsp; &nbsp; &nbsp; Thread-12] c.d.d.service.RedisLockService&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp;: Thread-12------&gt;&gt;&gt;&gt;begin 2018-06-19 14:42:52.501&nbsp; INFO 7064 --- [&nbsp; &nbsp; &nbsp; Thread-12] c.d.d.service.RedisLockService&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp;: Thread-12------&gt;&gt;&gt;&gt;end </td> 
 </tr> 
 </tbody> 
</table>

7，码云地址：https://gitee.com/dream21th/dream21th-redis