redis分布式锁

 1  private static String lockKey = "myLockKey";
 2 
 3     /**
 4      * value：当前时间ms值 + 超时时间（如3s）
 5      * @param jedis
 6      * @param value
 7      * @return
 8      */
 9     public boolean lock(Jedis jedis, String value){
10         Long result = jedis.setnx(lockKey, value);
11         //添加成功
12         if(result == 1){
13             return true;
14         }
15         String oldValue = jedis.get(lockKey);
16         //锁过期
17         if(!StringUtils.isEmpty(oldValue) && Long.parseLong(oldValue) < System.currentTimeMillis()){
18 
19             String val = jedis.getSet(lockKey, value);
20             //因为redis是单线程的，这些判断很有必要
21             if(!StringUtils.isEmpty(val) && val.equals(value)){
22                 return true;
23             }
24         }
25         return false;
26 
27 
28     }
29 
30     /**
31      *
32      * @param jedis
33      * @param value:与获取锁的value一致
34      */
35     public void unLock(Jedis jedis, String value){
36         try{
37             String old = jedis.get(lockKey);
38             if(!StringUtils.isEmpty(old) && old.equals(value)){
39                 jedis.del(lockKey);
40             }
41         }catch (Exception e){
42             e.printStackTrace();
43         }
44 
45 
46     }