1.maven依赖：

           
      
       redis.clients
            
      
       jedis
            
      
       2.7.3
        
     

2.增加spring 配置

       
           
            
            
            
        
       
           
                   
       
        classpath:redis-nodes.properties
                
               
               
                         
               
               
        
     

3.增加connect-redis.properties 配置文件

这里配置了6个节点

address1=192.168.221.128:7000  address2=192.168.221.128:7001  address3=192.168.221.128:7002  address4=192.168.221.129:7003  address5=192.168.221.129:7004  address6=192.168.221.129:7005

4.增加java类

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 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);      }      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;      }  }
         
        
       
      
     

5.到此配置完成

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

@Autowired  JedisCluster jedisCluster;