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

private static List<RedisServer> toRedisServersList(List<Map<String, String>> source) {
    List<RedisServer> servers = new ArrayList<RedisServer>(source.size());
    for (Map<String, String> info : source) {
        servers.add(RedisServer.newServerFrom(Converters.toProperties(info)));
    }
    return servers;
}
 

@Test
public void testMonitor() {
    Collection<RedisServer> masters = connection.masters();
    RedisServer master = masters.iterator().next();
    master.setName(master.getName() + ":");
    connection.monitor(master);
}
 

@Test
public void testFailover() throws InterruptedException {
    Collection<RedisServer> masters = connection.masters();
    connection.failover(masters.iterator().next());
    
    Thread.sleep(10000);
    
    RedisServer newMaster = connection.masters().iterator().next();
    assertThat(masters.iterator().next().getPort()).isNotEqualTo(newMaster.getPort());
}
 

private static List<RedisServer> toRedisServersList(List<Map<String, String>> source) {
    List<RedisServer> servers = new ArrayList<RedisServer>(source.size());
    for (Map<String, String> info : source) {
        servers.add(RedisServer.newServerFrom(Converters.toProperties(info)));
    }
    return servers;
}
 

@Test
public void testMonitor() {
    Collection<RedisServer> masters = connection.masters();
    RedisServer master = masters.iterator().next();
    master.setName(master.getName() + ":");
    connection.monitor(master);
}
 

@Test
public void testFailover() throws InterruptedException {
    Collection<RedisServer> masters = connection.masters();
    connection.failover(masters.iterator().next());
    
    Thread.sleep(10000);
    
    RedisServer newMaster = connection.masters().iterator().next();
    assertThat(masters.iterator().next().getPort()).isNotEqualTo(newMaster.getPort());
}
 

private static List<RedisServer> toRedisServersList(List<Map<String, String>> source) {
    List<RedisServer> servers = new ArrayList<RedisServer>(source.size());
    for (Map<String, String> info : source) {
        servers.add(RedisServer.newServerFrom(Converters.toProperties(info)));
    }
    return servers;
}
 

@Test
public void testMonitor() {
    Collection<RedisServer> masters = connection.masters();
    RedisServer master = masters.iterator().next();
    master.setName(master.getName() + ":");
    connection.monitor(master);
}
 

@Test
public void testFailover() throws InterruptedException {
    Collection<RedisServer> masters = connection.masters();
    connection.failover(masters.iterator().next());
    
    Thread.sleep(10000);
    
    RedisServer newMaster = connection.masters().iterator().next();
    assertThat(masters.iterator().next().getPort()).isNotEqualTo(newMaster.getPort());
}
 

private static List<RedisServer> toRedisServersList(List<Map<String, String>> source) {
    List<RedisServer> servers = new ArrayList<RedisServer>(source.size());
    for (Map<String, String> info : source) {
        servers.add(RedisServer.newServerFrom(Converters.toProperties(info)));
    }
    return servers;
}
 

@Test
public void testMonitor() {
    Collection<RedisServer> masters = connection.masters();
    RedisServer master = masters.iterator().next();
    master.setName(master.getName() + ":");
    connection.monitor(master);
}
 

@Test
public void testFailover() throws InterruptedException {
    Collection<RedisServer> masters = connection.masters();
    connection.failover(masters.iterator().next());
    
    Thread.sleep(10000);
    
    RedisServer newMaster = connection.masters().iterator().next();
    assertThat(masters.iterator().next().getPort()).isNotEqualTo(newMaster.getPort());
}
 

private static List<RedisServer> toRedisServersList(List<Map<String, String>> source) {
    List<RedisServer> servers = new ArrayList<RedisServer>(source.size());
    for (Map<String, String> info : source) {
        servers.add(RedisServer.newServerFrom(Converters.toProperties(info)));
    }
    return servers;
}
 

@Test
public void testMonitor() {
    Collection<RedisServer> masters = connection.masters();
    RedisServer master = masters.iterator().next();
    master.setName(master.getName() + ":");
    connection.monitor(master);
}
 

@Test
public void testFailover() throws InterruptedException {
    Collection<RedisServer> masters = connection.masters();
    connection.failover(masters.iterator().next());
    
    Thread.sleep(10000);
    
    RedisServer newMaster = connection.masters().iterator().next();
    assertThat(masters.iterator().next().getPort()).isNotEqualTo(newMaster.getPort());
}
 

private static List<RedisServer> toRedisServersList(List<Map<String, String>> source) {
    List<RedisServer> servers = new ArrayList<RedisServer>(source.size());
    for (Map<String, String> info : source) {
        servers.add(RedisServer.newServerFrom(Converters.toProperties(info)));
    }
    return servers;
}
 

@Test
public void testMonitor() {
    Collection<RedisServer> masters = connection.masters();
    RedisServer master = masters.iterator().next();
    master.setName(master.getName() + ":");
    connection.monitor(master);
}
 

@Test
public void testFailover() throws InterruptedException {
    Collection<RedisServer> masters = connection.masters();
    connection.failover(masters.iterator().next());
    
    Thread.sleep(10000);
    
    RedisServer newMaster = connection.masters().iterator().next();
    assertThat(masters.iterator().next().getPort()).isNotEqualTo(newMaster.getPort());
}
 

private static List<RedisServer> toRedisServersList(List<Map<String, String>> source) {
    List<RedisServer> servers = new ArrayList<RedisServer>(source.size());
    for (Map<String, String> info : source) {
        servers.add(RedisServer.newServerFrom(Converters.toProperties(info)));
    }
    return servers;
}
 

@Test
public void testMonitor() {
    Collection<RedisServer> masters = connection.masters();
    RedisServer master = masters.iterator().next();
    master.setName(master.getName() + ":");
    connection.monitor(master);
}
 

@Test
public void testFailover() throws InterruptedException {
    Collection<RedisServer> masters = connection.masters();
    connection.failover(masters.iterator().next());
    
    Thread.sleep(10000);
    
    RedisServer newMaster = connection.masters().iterator().next();
    assertThat(masters.iterator().next().getPort()).isNotEqualTo(newMaster.getPort());
}
 

@Override
public Collection<RedisServer> masters() {
  Span span = helper.buildSpan("masters");
  return helper.decorate(span, redisSentinelConnection::masters);
}
 

@Override
public Collection<RedisServer> slaves(NamedNode master) {
  Span span = helper.buildSpan("slaves");
  return helper.decorate(span, () -> redisSentinelConnection.slaves(master));
}
 

@Override
public void monitor(RedisServer master) {
  Span span = helper.buildSpan("monitor");
  helper.decorate(span, () -> redisSentinelConnection.monitor(master));
}
 

@Override
public Collection<RedisServer> masters() {
  Span span = helper.buildSpan("masters");
  return helper.decorate(span, redisSentinelConnection::masters);
}
 

@Override
public Collection<RedisServer> slaves(NamedNode master) {
  Span span = helper.buildSpan("slaves");
  return helper.decorate(span, () -> redisSentinelConnection.slaves(master));
}
 

@Override
public void monitor(RedisServer master) {
  Span span = helper.buildSpan("monitor");
  helper.decorate(span, () -> redisSentinelConnection.monitor(master));
}
 

@Override
public void monitor(RedisServer master) {
    connection.sync(RedisCommands.SENTINEL_MONITOR, master.getName(), master.getHost(), 
                                master.getPort().intValue(), master.getQuorum().intValue());
}
 

@Test
public void testMasters() {
    Collection<RedisServer> masters = connection.masters();
    assertThat(masters).hasSize(1);
}