分散ロックのredisson

redissonはredis公式サイトが推奨するjava言語で分散ロックを実現するプロジェクトである.もちろん、redissonは分散ロックだけでなく、他のいくつかの分散構造も含まれています.詳細については、次の手順に従います.https://github.com/mrniko/redisson/wiki
redissonは4つのリンクredisをサポートします.
Cluster
Sentinal 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
=============================

テストの結果から、結果は予想通りでしたが、サーバーで1万個のスレッドを走ってもうまく動作し、悪くないと思います.
余談:
データの初期化にはstatic{}すなわち静的ブロックは使用しないほうがよい.マルチコアマシンの場合にプロファイルを読み込むためjavaが放出される.lang.NoClassDefFoundError: Could not initialize class XXX.
だからinitを使って、プログラムを起動するときに手動で実行したほうがいいです.
転載先:https://www.cnblogs.com/zhongkaiuu/p/redisson.html