分布式鎖之redisson

redisson是redis官網推薦的java語言實現分布式鎖的項目。當然，redisson遠不止分布式鎖，還包括其他一些分布式結構。詳情請移步：https://github.com/mrniko/redisson/wiki

　　redisson支持4種鏈接redis的方式：

　　Cluster(集群)

　　Sentinel servers(哨兵)

　　Master/Slave servers(主從)

　　Single server(單機)

 

　　下面通過簡單的案例使用redisson的lock。

　　1、RedissonManager類，管理redisson的初始化等操作。

public class RedissonManager {

    private static final String RAtomicName = "genId_";

    private static Config config = new Config();
    private static Redisson redisson = null;

    public static void init(){
        try {
            config.useClusterServers() //這是用的集群server
                    .setScanInterval(2000) //設置集群狀態掃描時間
                    .setMasterConnectionPoolSize(10000) //設置連接數
                    .setSlaveConnectionPoolSize(10000)
                    .addNodeAddress("127.0.0.1:6379","127.0.0.1:6380");
            redisson = Redisson.create(config);
            //清空自增的ID數字
            RAtomicLong atomicLong = redisson.getAtomicLong(RAtomicName);
            atomicLong.set(1);
        }catch (Exception e){
            e.printStackTrace();
        }
    }

    public static Redisson getRedisson(){
        return redisson;
    }

    /** 獲取redis中的原子ID */
    public static Long nextID(){
        RAtomicLong atomicLong = getRedisson().getAtomicLong(RAtomicName);
        atomicLong.incrementAndGet();
        return atomicLong.get();
    }
}

　　2、DistributedRedisLock類，提供鎖和解鎖方法

public class DistributedRedisLock {
    private static Redisson redisson = RedissonManager.getRedisson();
    private static final String LOCK_TITLE = "redisLock_";

    public static void 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());
    }

    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());
    }
}

3、測試

    private static void redisLock(){
        RedissonManager.init(); //初始化
        for (int i = 0; i < 100; i++) {
            Thread t = new Thread(new Runnable() {
                @Override
                public void run() {
                    try {
                        String key = "test123";
                        DistributedRedisLock.acquire(key);
                        Thread.sleep(1000); //獲得鎖之后可以進行相應的處理
                        System.err.println("======獲得鎖后進行相應的操作======");
                        DistributedRedisLock.release(key);
                        System.err.println("=============================");
                    } catch (Exception e) {
                        e.printStackTrace();
                    }
                }
            });
            t.start();
        }
    }

4、測試結果

======lock======Thread-91
======獲得鎖后進行相應的操作======
======unlock======Thread-91
=============================
======lock======Thread-63
======獲得鎖后進行相應的操作======
======unlock======Thread-63
=============================
======lock======Thread-31
======獲得鎖后進行相應的操作======
======unlock======Thread-31
=============================
======lock======Thread-97
======獲得鎖后進行相應的操作======
======unlock======Thread-97
=============================
======lock======Thread-8
======獲得鎖后進行相應的操作======
======unlock======Thread-8
=============================

從測試結果可以看出，結果還是達到了預期，在服務器跑一萬個線程還是能很好運行，感覺還不錯。

題外話：

　　在初始化數據時候，最好不要使用static{} 即靜態塊。因為在多核機器的情況下讀取配置文件，會拋出java.lang.NoClassDefFoundError: Could not initialize class XXX。

所以最好還是使用init的方式，在啟動程序的時候手動執行下。