redis jedis連接redis集群 cluster模式代碼

wvvh4086 8年前發布 | 7K 次閱讀 Java Jedis Redis

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