一：說明

redis-cluster需要6臺redis才行，分為3組，每組都是1主1從。

二：啟動6臺redis

修改redis.conf 檔案為redis1.conf redis2,conf redis3,conf redis4,conf redis5,conf redis6,conf

配置檔案做如下修改，埠肯定是都不一樣的，然後啟動：

daemonize yes
protected-mode no
cluster-enabled yes
cluster-config-file nodes2.conf
cluster-node-timeout 5000
port 6372
 

>> ps -ef|grep redis看到
root      2912     1  0 13:48 ?        00:00:00 ./redis-server *:6371 [cluster]
root      2923     1  0 13:48 ?        00:00:00 ./redis-server *:6372 [cluster]
root      2930     1  0 13:48 ?        00:00:00 ./redis-server *:6373 [cluster]
root      2938     1  0 13:48 ?        00:00:00 ./redis-server
 
 *:6374 [cluster]
root      2946     1  0 13:48 ?        00:00:00 ./redis-server *:6375 [cluster]
root      2956     1  0 13:48 ?        00:00:00 ./redis-server *:6376 [cluster]

三：執行ruby

>> yum install ruby rubygems -y
>> 安裝gem-redis
>> https://rubygems.org/gems/redis/versions/3.0.0
>> gem install -l redis-3.0
 
.0.gem
>> ## 一定一定要注意，這裡的ip是你主機的ip，而不一定是127.0.0.1 ，到時候用jedis去連線，這裡的ip就是相對jedis的地址  
>> ./redis-trib.rb create --replicas 1 127.0.0.1:6371 127.0.0.1:6372 127.0.0.1:6373 127.0.0.1:6374 127.0.0.1:6375 127.0.0.1:6376

四：Jedis

public class Main {
    public static void main(String[] args) throws InterruptedException {
        JedisPoolConfig config = new JedisPoolConfig();
        config.setMaxTotal(100);
        config.setMaxIdle(50);
        config.setMinIdle(20);
        config.setMaxWaitMillis(6 * 1000);
        config.setTestOnBorrow(true);
        Set<HostAndPort> jedisClusterNodes = new HashSet<HostAndPort>();
        jedisClusterNodes.add(new HostAndPort("127.0.0.1", 6371));
        jedisClusterNodes.add(new HostAndPort("127.0.0.1", 6372));
        jedisClusterNodes.add(new HostAndPort("127.0.0.1", 6373));
        jedisClusterNodes.add(new HostAndPort("127.0.0.1", 6374));
        jedisClusterNodes.add(new HostAndPort("127.0.0.1", 6375));
        jedisClusterNodes.add(new HostAndPort("127.0.0.1", 6376));
        JedisCluster jedisCluster = new JedisCluster(jedisClusterNodes, 2000, 100, config);
        String key = "aa";
        for (int i = 1; i <= 100; i++) {
            jedisCluster.set(key + i, key + i);
            String value = jedisCluster.get(key + i);
            System.out.println(value);
        }
    }
}