Клиент Redis (Redission) перестает работать, если первый узел не работает в кластере

Question

У меня есть Master Master Redis кластер 3 (узел1, узел2, узел3). Я использую клиент Redission для распределенной блокировки через JVM. Теперь согласно алгоритму RedLock, который реализован в Redission, он пытается получить блокировку в большинстве узлов (в моем случае это большинство) и использует алгоритм циклического перебора для балансировки нагрузки. Теперь этот механизм блокировки работает нормально, если мы заблокируем сеть для узла 2 или узла 3. Но если мы заблокируем сеть узла 1, то произойдет сбой с приведенной ниже ошибкой.

Exception in thread "main" org.redisson.client.RedisNodeNotFoundException: No node for slot: 15087 and command (EVAL)
at org.redisson.connection.MasterSlaveConnectionManager.getEntry(MasterSlaveConnectionManager.java:578)
at org.redisson.connection.MasterSlaveConnectionManager.connectionWriteOp(MasterSlaveConnectionManager.java:563)
at org.redisson.command.CommandAsyncService.async(CommandAsyncService.java:368)
at org.redisson.command.CommandAsyncService.evalAsync(CommandAsyncService.java:334)
at org.redisson.command.CommandAsyncService.evalWriteAsync(CommandAsyncService.java:282)
at org.redisson.RedissonLock.tryLockInnerAsync(RedissonLock.java:207)
at org.redisson.RedissonLock.tryAcquire(RedissonLock.java:139)
at org.redisson.RedissonLock.tryLock(RedissonLock.java:225)
at com.seamless.common.cache.distributed.LockManager.getLock(LockManager.java:37)
at com.testlock.app.App.main(App.java:34)

Ниже описано, как я создаю клиент Redission

    import java.util.List;
import java.util.concurrent.TimeUnit;

import org.apache.log4j.Logger;
import org.redisson.ClusterServersConfig;
import org.redisson.Config;
import org.redisson.ReadMode;
import org.redisson.Redisson;
import org.redisson.RedissonClient;
import org.redisson.core.RLock;

public class LockManager {


private static final Logger LOG = Logger.getLogger(LockManager.class);


private RedissonClient redissonClient;

LockManager(List<String> nodes){
    Config config = new Config();
    ClusterServersConfig serverConfig=config.useClusterServers();
    serverConfig.setReadMode(ReadMode.MASTER);
    for(String node :nodes){
        serverConfig.addNodeAddress(node);
    }
    redissonClient = Redisson.create(config);

}

public boolean getLock(final String lockKey,int timeout){
    RLock lock=redissonClient.getLock(lockKey);
    try {
        return lock.tryLock(0, timeout, TimeUnit.MILLISECONDS);
    } catch (InterruptedException e) {
        LOG.error("Error getting lock "+e.getMessage());
    }
    return false;
}   

public void releaseLock(final String lockKey){
    RLock lock=redissonClient.getLock(lockKey);
    if(lock.isHeldByCurrentThread())
        lock.unlock();
}
}

Answer 1

Вы должны использовать RedissonRedLock и 3 блокировки для алгоритма RedLock:

RLock lock1 = redisson.getLock("lock1");
RLock lock2 = redisson.getLock("lock2");
RLock lock3 = redisson.getLock("lock3");

RedissonRedLock lock = new RedissonRedLock(lock1, lock2, lock3);
lock.lock();

//...

lock.unlock();