redis jedis連接redis集群 cluster模式代碼
redis集群模式支持failover,并且自動支持數據的sharding, 如果數據量很大單個redis實例放不下時只能使用這種模式, 集群模式需要安裝ruby環境,集群的配置用的是ruby腳本。
集群模式的配置是:("192.168.159.90", 6279), ("192.168.159.91", 6279),("192.168.159.92", 6279);("192.168.159.90", 6280), ("192.168.159.91", 6280),("192.168.159.92", 6280); 搭建在90, 91, 92 三臺服務器上,每臺服務器上各兩個實例。
import redis.clients.jedis.HostAndPort;
import redis.clients.jedis.JedisCluster;
import java.util.HashSet;
import java.util.Set;
/**
* Created by outofmemory.cn on 2015/11/6.
*/
public class HelloJedisCluster {
public static void main(String[] args) {
Set<HostAndPort> jedisClusterNodes = new HashSet<HostAndPort>();
//Jedis Cluster will attempt to discover cluster nodes automatically
jedisClusterNodes.add(new HostAndPort("192.168.159.90", 6279));
jedisClusterNodes.add(new HostAndPort("192.168.159.91", 6279));
jedisClusterNodes.add(new HostAndPort("192.168.159.92", 6279));
jedisClusterNodes.add(new HostAndPort("192.168.159.90", 6280));
jedisClusterNodes.add(new HostAndPort("192.168.159.91", 6280));
jedisClusterNodes.add(new HostAndPort("192.168.159.92", 6280));
JedisCluster jc = new JedisCluster(jedisClusterNodes);
jc.set("foo", "bar");
String value = jc.get("foo");
System.out.println(value);
}
}
本文由用戶 wvvh4086 自行上傳分享,僅供網友學習交流。所有權歸原作者,若您的權利被侵害,請聯系管理員。
轉載本站原創文章,請注明出處,并保留原始鏈接、圖片水印。
本站是一個以用戶分享為主的開源技術平臺,歡迎各類分享!