/**
 * redis 得到所有的master and slave 信息
 */
@Test
public void testGetAllMasterAndSlave() {

    RedisSentinelConnection conn = stringRedisTemplate.getConnectionFactory().getSentinelConnection();

    for (RedisServer master : conn.masters()) {
        System.out.println("master => " + master);// 打印master信息
        Collection<RedisServer> slaves = conn.slaves(master);
        // 打印该master下的所有slave信息
        for (RedisServer slave : slaves) {
            System.out.println("slaves of " + master + " => " + slave);
        }
        System.out.println("--------------");
    }
}
 

@Override
public RedisSentinelConnection getSentinelConnection() {
    if (!redisson.getConfig().isSentinelConfig()) {
        throw new InvalidDataAccessResourceUsageException("Redisson is not in Sentinel mode");
    }
    
    SentinelConnectionManager manager = ((SentinelConnectionManager)((Redisson)redisson).getConnectionManager());
    for (RedisClient client : manager.getSentinels()) {
        org.redisson.client.RedisConnection connection = client.connect();
        try {
            String res = connection.sync(RedisCommands.PING);
            if ("pong".equalsIgnoreCase(res)) {
                return new RedissonSentinelConnection(connection);
            }
        } catch (Exception e) {
            log.warn("Can't connect to " + client, e);
            connection.closeAsync();
        }
    }
    
    throw new InvalidDataAccessResourceUsageException("Sentinels are not found");
}
 

@Override
public RedisSentinelConnection getSentinelConnection() {
    if (!redisson.getConfig().isSentinelConfig()) {
        throw new InvalidDataAccessResourceUsageException("Redisson is not in Sentinel mode");
    }
    
    SentinelConnectionManager manager = ((SentinelConnectionManager)((Redisson)redisson).getConnectionManager());
    for (RedisClient client : manager.getSentinels()) {
        org.redisson.client.RedisConnection connection = client.connect();
        try {
            String res = connection.sync(RedisCommands.PING);
            if ("pong".equalsIgnoreCase(res)) {
                return new RedissonSentinelConnection(connection);
            }
        } catch (Exception e) {
            log.warn("Can't connect to " + client, e);
            connection.closeAsync();
        }
    }
    
    throw new InvalidDataAccessResourceUsageException("Sentinels are not found");
}
 

@Override
public RedisSentinelConnection getSentinelConnection() {
    if (!redisson.getConfig().isSentinelConfig()) {
        throw new InvalidDataAccessResourceUsageException("Redisson is not in Sentinel mode");
    }
    
    SentinelConnectionManager manager = ((SentinelConnectionManager)((Redisson)redisson).getConnectionManager());
    for (RedisClient client : manager.getSentinels()) {
        org.redisson.client.RedisConnection connection = client.connect();
        try {
            String res = connection.sync(RedisCommands.PING);
            if ("pong".equalsIgnoreCase(res)) {
                return new RedissonSentinelConnection(connection);
            }
        } catch (Exception e) {
            log.warn("Can't connect to " + client, e);
            connection.closeAsync();
        }
    }
    
    throw new InvalidDataAccessResourceUsageException("Sentinels are not found");
}
 

@Override
public RedisSentinelConnection getSentinelConnection() {
    if (!redisson.getConfig().isSentinelConfig()) {
        throw new InvalidDataAccessResourceUsageException("Redisson is not in Sentinel mode");
    }
    
    SentinelConnectionManager manager = ((SentinelConnectionManager)((Redisson)redisson).getConnectionManager());
    for (RedisClient client : manager.getSentinels()) {
        org.redisson.client.RedisConnection connection = client.connect();
        try {
            String res = connection.sync(RedisCommands.PING);
            if ("pong".equalsIgnoreCase(res)) {
                return new RedissonSentinelConnection(connection);
            }
        } catch (Exception e) {
            log.warn("Can't connect to " + client, e);
            connection.closeAsync();
        }
    }
    
    throw new InvalidDataAccessResourceUsageException("Sentinels are not found");
}
 

@Override
public RedisSentinelConnection getSentinelConnection() {
    if (!redisson.getConfig().isSentinelConfig()) {
        throw new InvalidDataAccessResourceUsageException("Redisson is not in Sentinel mode");
    }
    
    SentinelConnectionManager manager = ((SentinelConnectionManager)((Redisson)redisson).getConnectionManager());
    for (RedisClient client : manager.getSentinels()) {
        org.redisson.client.RedisConnection connection = client.connect();
        try {
            String res = connection.sync(RedisCommands.PING);
            if ("pong".equalsIgnoreCase(res)) {
                return new RedissonSentinelConnection(connection);
            }
        } catch (Exception e) {
            log.warn("Can't connect to " + client, e);
            connection.closeAsync();
        }
    }
    
    throw new InvalidDataAccessResourceUsageException("Sentinels are not found");
}
 

@Override
public RedisSentinelConnection getSentinelConnection() {
    System.out.println("getSentinelConnection");
    return redisConnectionFactory.getSentinelConnection();
}
 

public TracingRedisSentinelConnection(RedisSentinelConnection redisSentinelConnection,
    TracingConfiguration configuration) {
  this.redisSentinelConnection = redisSentinelConnection;
  this.helper = new TracingHelper(configuration);
}
 

@Override
public RedisSentinelConnection getSentinelConnection() {
  return new TracingRedisSentinelConnection(connection.getSentinelConnection(),
      tracingConfiguration);
}
 

@Override
public RedisSentinelConnection getSentinelConnection() {
  return new TracingRedisSentinelConnection(delegate.getSentinelConnection(),
      tracingConfiguration);
}
 

@Test
public void delegatesCallToGetSentinelConnection() {
  RedisSentinelConnection connection = connectionFactory.getSentinelConnection();
  verify(delegate).getSentinelConnection();
  assertTrue(connection instanceof TracingRedisSentinelConnection);
}
 

public TracingRedisSentinelConnection(RedisSentinelConnection redisSentinelConnection,
    TracingConfiguration configuration) {
  this.redisSentinelConnection = redisSentinelConnection;
  this.helper = new TracingHelper(configuration);
}
 

@Override
public RedisSentinelConnection getSentinelConnection() {
  return new TracingRedisSentinelConnection(connection.getSentinelConnection(),
      tracingConfiguration);
}
 

@Override
public RedisSentinelConnection getSentinelConnection() {
  return new TracingRedisSentinelConnection(delegate.getSentinelConnection(),
      tracingConfiguration);
}
 

@Test
public void delegatesCallToGetSentinelConnection() {
  RedisSentinelConnection connection = connectionFactory.getSentinelConnection();
  verify(delegate).getSentinelConnection();
  assertTrue(connection instanceof TracingRedisSentinelConnection);
}