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 自行上傳分享,僅供網友學習交流。所有權歸原作者,若您的權利被侵害,請聯系管理員。
轉載本站原創文章,請注明出處,并保留原始鏈接、圖片水印。
本站是一個以用戶分享為主的開源技術平臺,歡迎各類分享!