原文：http://xyqck163.iteye.com/blog/2211108

客户端采用最新的jedis 2.7

1.

maven依赖：

<dependency>

<groupId>redis.clients</groupId>

<artifactId>jedis</artifactId>

<version>2.7.2</version>

</dependency>

 

2.增加spring 配置

 

                 
                  
                  
                  
          
         
             
                  
       
        classpath:connect-redis.properties
               
              
         
                      
              
              
          
     

 

3.增加connect-redis.properties  配置文件，这里配置了6个节点

address1=172.16.23.27:6379address2=172.16.23.27:6380address3=172.16.23.27:6381address4=172.16.23.27:6382address5=172.16.23.27:6383address6=172.16.23.27:6384 4.增加java类package cn.zsmy.palmdoctor.redis;import java.util.HashSet;import java.util.Properties;import java.util.Set;import java.util.regex.Pattern;import org.apache.commons.pool2.impl.GenericObjectPoolConfig;import org.springframework.beans.factory.FactoryBean;import org.springframework.beans.factory.InitializingBean;import org.springframework.core.io.Resource;import redis.clients.jedis.HostAndPort;import redis.clients.jedis.JedisCluster;public class JedisClusterFactory implements FactoryBean
     
      , InitializingBean {    private Resource addressConfig;    private String addressKeyPrefix ;    private String password;    private JedisCluster jedisCluster;    private Integer timeout;    private Integer maxRedirections;    private GenericObjectPoolConfig genericObjectPoolConfig;        private Pattern p = Pattern.compile("^.+[:]\\d{1,5}\\s*$");    @Override    public JedisCluster getObject() throws Exception {        return jedisCluster;    }    @Override    public Class
       getObjectType() {        return (this.jedisCluster != null ? this.jedisCluster.getClass() : JedisCluster.class);    }    @Override    public boolean isSingleton() {        return true;    }    private Set
      
        parseHostAndPort() throws Exception {        try {            Properties prop = new Properties();            prop.load(this.addressConfig.getInputStream());            Set
       
         haps = new HashSet
        
         ();            for (Object key : prop.keySet()) {                if (!((String) key).startsWith(addressKeyPrefix)) {                    continue;                }                String val = (String) prop.get(key);                boolean isIpPort = p.matcher(val).matches();                if (!isIpPort) {                    throw new IllegalArgumentException("ip 或 port 不合法");                }                String[] ipAndPort = val.split(":");                HostAndPort hap = new HostAndPort(ipAndPort[0], Integer.parseInt(ipAndPort[1]));                haps.add(hap);            }            return haps;        } catch (IllegalArgumentException ex) {            throw ex;        } catch (Exception ex) {            throw new Exception("解析 jedis 配置文件失败", ex);        }    }        @Override    public void afterPropertiesSet() throws Exception {        Set
         
           haps = this.parseHostAndPort();                //jedisCluster = new JedisCluster(haps, timeout, maxRedirections,genericObjectPoolConfig);        jedisCluster = new JedisCluster(haps, timeout, 2000, maxRedirections, password, genericObjectPoolConfig);    }    public void setAddressConfig(Resource addressConfig) {        this.addressConfig = addressConfig;    }    public void setTimeout(int timeout) {        this.timeout = timeout;    }    public void setMaxRedirections(int maxRedirections) {        this.maxRedirections = maxRedirections;    }    public void setAddressKeyPrefix(String addressKeyPrefix) {        this.addressKeyPrefix = addressKeyPrefix;    }    public void setGenericObjectPoolConfig(GenericObjectPoolConfig genericObjectPoolConfig) {        this.genericObjectPoolConfig = genericObjectPoolConfig;    }    public void setPassword(String password) {        this.password = password;    }}
         
        
       
      
     

5.到此配置完成

使用时，直接注入即可， 如下所示：

@Autowired

JedisCluster jedisCluster;