spring集成 JedisCluster 连接 redis3.0 集群详解编程语言

<bean name="genericObjectPoolConfig" class="org.apache.commons.pool2.impl.GenericObjectPoolConfig" >   
        <property name="maxWaitMillis" value="-1" />   
        <property name="maxTotal" value="1000" />   
        <property name="minIdle" value="8" />   
        <property name="maxIdle" value="100" />   
</bean>   
   
<bean id="jedisCluster" class="xxx.JedisClusterFactory">   
    <property name="addressConfig">   
        <value>classpath:connect-redis.properties</value>   
    </property>   
    <property name="addressKeyPrefix" value="address" />   <!--  属性文件里  key的前缀 -->   
       
    <property name="timeout" value="300000" />   
    <property name="maxRedirections" value="6" />   
    <property name="genericObjectPoolConfig" ref="genericObjectPoolConfig" />   
</bean>  

address1=172.16.23.27:6379   
address2=172.16.23.27:6380   
address3=172.16.23.27:6381   
address4=172.16.23.27:6382   
address5=172.16.23.27:6383   
address6=172.16.23.27:6384  

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<JedisCluster>, 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<? extends JedisCluster> getObjectType() {   
        return (this.jedisCluster != null ? this.jedisCluster.getClass() : JedisCluster.class);   
    }   
   
    @Override   
    public boolean isSingleton() {   
        return true;   
    }   
   
   
   
    private Set<HostAndPort> parseHostAndPort() throws Exception {   
        try {   
            Properties prop = new Properties();   
            prop.load(this.addressConfig.getInputStream());   
   
            Set<HostAndPort> haps = new HashSet<HostAndPort>();   
            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<HostAndPort> 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;   
    }   
   
}