复用代码系列：简单Redis分布式锁（基于Redisson）

分手后的思念是犯贱 2022-05-26 13:27 123阅读 0赞

[复用代码系列目录][Link 1]

Redisson配置

package com.redis.lock.redisson;
    
    import org.redisson.Redisson;
    import org.redisson.api.RAtomicLong;  
    import org.redisson.config.Config;  
      
    public class RedissonManager {  
      
        private static final String RAtomicName = "genId_";  
      
        private static Config config = new Config();  
        private static Redisson redisson = null;  
      
       public static void init(String key,String value){  
            try {  
    /*            config.useClusterServers() //这是用的集群server 
                        .setScanInterval(2000) //设置集群状态扫描时间 
                        .setMasterConnectionPoolSize(10000) //设置连接数 
                        .setSlaveConnectionPoolSize(10000) 
                        .addNodeAddress("127.0.0.1:6379");*/  
                if(key==null || "".equals(key)){  
                    key=RAtomicName;  
                }  
                config.useSingleServer().setAddress("127.0.0.1:6379");  
                redisson = (Redisson) Redisson.create(config);  
                //清空自增的ID数字  
                RAtomicLong atomicLong = redisson.getAtomicLong(key);  
                long pValue=1;  
                if(value!=null && !"".equals(value)){  
                    pValue = Long.parseLong(value);  
                }  
                atomicLong.set(pValue);  
            }catch (Exception e){  
                e.printStackTrace();  
            }  
        }  
      
        public static Redisson getRedisson(){  
            return redisson;  
        }  
      
        /** 获取redis中的原子ID */  
        public static Long nextID(){  
            RAtomicLong atomicLong = getRedisson().getAtomicLong(RAtomicName);  
           //原子性的获取下一个ID，递增1   
           atomicLong.incrementAndGet();  
            return atomicLong.get();  
        }  
    }

分布式锁：

package com.redis.lock.redisson;
    
    import org.redisson.Redisson;
    import org.redisson.api.RLock;
    
    import java.util.concurrent.TimeUnit;
    
    public class DistributedRedisLock {
        private static Redisson redisson = RedissonManager.getRedisson();
        private static final String LOCK_TITLE = "redisLock_";  
      
        public static boolean acquire(String lockName){  
            String key = LOCK_TITLE + lockName;  
            RLock mylock = redisson.getLock(key);
            mylock.lock(2, TimeUnit.MINUTES); //lock提供带timeout参数，timeout结束强制解锁，防止死锁
            System.err.println("======lock======"+Thread.currentThread().getName());  
            return  true;  
        }  
      
        public static void release(String lockName){  
            String key = LOCK_TITLE + lockName;  
            RLock mylock = redisson.getLock(key);
            mylock.unlock();  
            System.err.println("======unlock======"+Thread.currentThread().getName());  
        }  
    }

[Link 1]: https://blog.csdn.net/sunct/article/details/80175458