1. 程式人生 > >java使用Redis6–sentinel單點故障主從自動切換

java使用Redis6–sentinel單點故障主從自動切換

package redis;
import java.util.HashSet;
import java.util.Set;
import redis.clients.jedis.HostAndPort;
import redis.clients.jedis.Jedis;
import redis.clients.jedis.JedisSentinelPool;
public class MyJedisSentinelTest {
    @SuppressWarnings({ "rawtypes", "unchecked", "deprecation" })
    public static void main(String[] args) {
        Set sentinels = new HashSet();
        sentinels.add(new HostAndPort("192.168.77.135", 26379).toString());
        sentinels.add(new HostAndPort("192.168.77.135", 26380).toString());
        sentinels.add(new HostAndPort("192.168.77.135", 26381).toString());
        JedisSentinelPool sentinelPool = new JedisSentinelPool("shard2", sentinels);
        System.out.println("Current master: " + sentinelPool.getCurrentHostMaster().toString());
        Jedis master = sentinelPool.getResource();
        master.set("username","liangzhichao1");
        sentinelPool.returnResource(master);
        Jedis master2 = sentinelPool.getResource();
        String value = master2.get("username");
        System.out.println("username: " + value);
        master2.close();
        sentinelPool.destroy();
    }
}