分布式锁优化

Author: xiaolyuh123

spring-boot-student-data-redis-distributed-lock/src/main/java/com/xiaolyuh/redis/lock/RedisLock3.java

@@ -269,8 +269,8 @@ public Boolean unlock() {
                     return result == 1;
                 });
             } catch (Throwable e) {
-                logger.warn("Redis不支持EVAL命令，使用降级方式解锁：{}",e.getMessage(), e);
-                String value = (String) redisTemplate.opsForValue().get(lockKey);
+                logger.warn("Redis不支持EVAL命令，使用降级方式解锁：{}", e.getMessage());
+                String value = this.get(lockKey, String.class);
                 if (lockValue.equals(value)) {
                     redisTemplate.delete(lockKey);
                     return true;
@@ -281,17 +281,18 @@ public Boolean unlock() {
 
         return true;
     }
-    
+
     /**
      * 获取锁状态
+     *
+     * @return
      * @Title: isLock
-     * @return  
      * @author yuhao.wang
      */
     public boolean isLock() {
-		
-		return locked;
-	}
+
+        return locked;
+    }
 
     /**
      * 重写redisTemplate的set方法
@@ -328,6 +329,26 @@ public String doInRedis(RedisConnection connection) throws DataAccessException {
         });
     }
 
+    /**
+     * 获取redis里面的值
+     *
+     * @param key    key
+     * @param aClass class
+     * @return T
+     */
+    private <T> T get(final String key, Class<T> aClass) {
+        Assert.isTrue(!StringUtils.isEmpty(key), "key不能为空");
+        return redisTemplate.execute((RedisConnection connection) -> {
+            Object nativeConnection = connection.getNativeConnection();
+            Object result = null;
+            if (nativeConnection instanceof JedisCommands) {
+                result = ((JedisCommands) nativeConnection).get(key);
+            }
+            return (T) result;
+        });
+    }
+
+
     /**
      * @param millis 毫秒
      * @param nanos  纳秒

spring-boot-student-layering-cache/pom.xml

@@ -56,7 +56,7 @@
         <dependency>
             <groupId>com.github.xiaolyuh</groupId>
             <artifactId>layering-cache-starter</artifactId>
-            <version>1.1.0</version>
+            <version>1.1.3</version>
         </dependency>
 
     </dependencies>