java使用Redis6–sentinel單點故障主從自動切換
阿新 • • 發佈:2018-12-22
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(); } }