Java操作Redis实现单点故障自动切换

package com.test;

import java.util.HashSet;
import java.util.Set;
import redis.clients.jedis.HostAndPort;
import redis.clients.jedis.Jedis;
import redis.clients.jedis.JedisPoolConfig;
import redis.clients.jedis.JedisSentinelPool;
import redis.clients.jedis.exceptions.JedisConnectionException;
/**
* 连接redis监控实现单点故障自动切换测试类
* @author 张军
*/
public class RedisTest {

//监控连接池
private static JedisSentinelPool jedisPool = null;

//主节点的主机名
private static String master = "redis_master";

//主节点IP
public static String host = "192.168.1.111";

//端口号
public static int port = 26379;

//选择redis库（默认为0）
public static int database = 0;

//超时时间(0标识永远不超时)
public static int timeout = 0;

public static void main(String[] args) {
try {
Set<String> sentinels = new HashSet<String>();
sentinels.add(new HostAndPort(host,port).toString());
jedisPool = new JedisSentinelPool(master, sentinels,new JedisPoolConfig(),timeout,null,database);
test();
} catch (InterruptedException e) {
e.printStackTrace();
}
}

/**
* 循环set数据，中间把主节点进程杀掉，看处理情况
* @throws InterruptedException
*/
public static void test() throws InterruptedException{
long start = System.currentTimeMillis();
for (int i = 0; i < 100000; i++) {
try {
Jedis jedis = jedisPool.getResource();
jedis.set("zhangjun_" + i, "" + i);
System.out.println("set第"+i+"条:"+i);
jedisPool.returnResource(jedis);
Thread.sleep(1000);
} catch (JedisConnectionException e) {
e.printStackTrace();
System.out.println("第"+i+"条出现异常："+i);
Thread.sleep(1000);
}
}
long end = System.currentTimeMillis();
System.out.println("JedisSentinelPool@Pool SET: " + ((end - start)/1000.0) + " seconds");
}

}

持续补全中。。。。。