解决redisCluster 连接失败的问题

使用redis3.2.8 建立集群后，发现在连接redis 经常报连接失败。但是单独连接某个节点时，是不会报错的，经过分析终于发现了原因。
原因是这样的：我在建立集群的时候配置文件redis.conf 中
bind 127.0.0.1 192.168.6.24
在使用命令：./redis-trib.rb  create  --replicas  1  192.168.6.24:7000 192.168.6.24:7001  192.168.6.24:7002 192.168.6.24:7003  192.168.6.24:7004  192.168.6.24:7005
建立集群，建立完集群后，连接redis 发现有问题，后把rdis.conf 中改为：bind 192.168.6.24

所以客户端有时候会连接 127.0.0.1：****，所以就报错了。

如何解决这个问题呢：
1.删除nodes-700*.conf ,appendonly.aof , dump.rdb 这三个文件
2.启动服务
[root@yunboce redis]# ./redis-server 7000/redis.conf
[root@yunboce redis]# ./redis-server 7001/redis.conf
[root@yunboce redis]# ./redis-server 7002/redis.conf
[root@yunboce redis]# ./redis-server 7003/redis.conf
[root@yunboce redis]# ./redis-server 7004/redis.conf
[root@yunboce redis]# ./redis-server 7005/redis.conf

3.执行建群命令：
./redis-trib.rb  create  --replicas  1  192.168.6.24:7000 192.168.6.24:7001  192.168.6.24:7002 192.168.6.24:7003  192.168.6.24:7004  192.168.6.24:7005


4.测试：


import java.util.HashSet;
import java.util.Map;
import java.util.Set;
import java.util.TreeSet;

import org.apache.commons.pool2.impl.GenericObjectPoolConfig;

import redis.clients.jedis.HostAndPort;
import redis.clients.jedis.Jedis;
import redis.clients.jedis.JedisCluster;
import redis.clients.jedis.JedisPool;

public class JedisClusterTest {


JedisCluster jedisCluster = null;

private String nameKey="test1";

    /**
     * 因为是测试，这里没有写单例
     */
   
    public void before(){
    //注意：这里超时时间不要太短，他会有超时重试机制。而且其他像httpclient、dubbo等RPC框架也要注意这点
    GenericObjectPoolConfig config = new GenericObjectPoolConfig();
//        config.setMaxIdle(200);
//        config.setMaxTotal(300);
//        config.setTestOnReturn(true);
        Set<HostAndPort> nodes = new HashSet<HostAndPort>();   
        nodes.add(new HostAndPort("192.168.6.24",7000));
        nodes.add(new HostAndPort("192.168.6.24",7001)); 
        nodes.add(new HostAndPort("192.168.6.24",7002));
        nodes.add(new HostAndPort("192.168.6.24",7003));
       nodes.add(new HostAndPort("192.168.6.24",7005));
       nodes.add(new HostAndPort("192.168.6.24",7004));
       
       
        jedisCluster = new JedisCluster(nodes, 10000, 1000, 1,
        config);

        System.out.println(jedisCluster+"===");
        for(int i=0;i<1;i++){
        System.out.println(jedisCluster.set("test1"+i, "张三"+i));
        System.out.println(jedisCluster.get("test1"+i));
        }
       

    }

      
    public TreeSet<String> keys(String pattern){ 
      //  logger.debug("Start getting keys..."); 
        TreeSet<String> keys = new TreeSet<String>(); 
        Map<String, JedisPool> clusterNodes = jedisCluster.getClusterNodes(); 
        for(String k : clusterNodes.keySet()){
       
            System.out.println("Getting keys from: {}"+k); 
            JedisPool jp = clusterNodes.get(k); 
            Jedis connection = jp.getResource(); 
            try { 
            Set<String> str = connection.keys(pattern);
            System.out.println(str.toString());
                keys.addAll(str); 
            } catch(Exception e){ 
               // logger.error("Getting keys error: {}", e); 
            } finally{ 
               System.out.println("Connection closed."); 
               connection.close();//用完一定要close这个链接！！！ 
            } 
        } 
          
       
       
        return keys; 
    } 
   
   
    public static void main(String[] args) {

    JedisClusterTest test = new JedisClusterTest();
    test.before();
    TreeSet<String> t = test.keys("*");
}


}