classpath:redis.properties
                       
                  
             
                
           
          
            
             
             
             
           
          
          
            
             
             
        
             
        
             
         
           
              
          
                     
          
          
          
          
          
              
                
               
               
           
                          
          
              
     

 

spring-context-jedis-cluster.xml

     
     
      
       Jedis Cluster Configuration集群
      
      
      
      
       
       
        
         
          
          
         
         
          
          
         
         
          
          
         
         
          
          
         
         
          
          
         
         
          
          
         
        
       
      
              
        
           
      
      
       
       
      
      
       
      
     

 

redis-cluster.properties#cluster configurationredis.host1=xx.xx.xx.xxredis.port1=7000redis.host2=xx.xx.xx.xxredis.port2=7001redis.host3=xx.xx.xx.xxredis.port3=7002redis.host4=xx.xx.xx.xxredis.port4=7000redis.host5=xx.xx.xx.xxredis.port5=7001redis.host6=xx.xx.xx.xxredis.port6=7002redis.maxRedirects=3redis.maxIdle=100redis.maxTotal=600

 

 

package cn.zsmy.palmdoctor.redis;import java.io.Serializable;import java.util.ArrayList;import java.util.HashSet;import java.util.Iterator;import java.util.List;import java.util.Map;import java.util.Set;import java.util.concurrent.TimeUnit;import org.springframework.beans.factory.annotation.Autowired;import org.springframework.beans.factory.annotation.Qualifier;import org.springframework.dao.DataAccessException;import org.springframework.data.redis.connection.RedisConnection;import org.springframework.data.redis.core.BoundSetOperations;import org.springframework.data.redis.core.HashOperations;import org.springframework.data.redis.core.ListOperations;import org.springframework.data.redis.core.RedisCallback;import org.springframework.data.redis.core.RedisTemplate;import org.springframework.stereotype.Service;@Servicepublic class RedisUtil{    @Autowired     @Qualifier("redisTemplate")    public RedisTemplate
     
       redisTemplate;        @Autowired    @Qualifier("redisTemplate")       protected RedisTemplate
      
        redisTemplateSerializable;        /**     * 缓存基本的对象，Integer、String、实体类等     * @param key    缓存的键值     * @param value    缓存的值     * @return        缓存的对象     */    public void setCacheObject(String key, Object value)    {        redisTemplate.opsForValue().set(key,value);    }        /**     * 获得缓存的基本对象。     * @param key        缓存键值     * @param operation     * @return            缓存键值对应的数据     */    public Object getCacheObject(String key/*,ValueOperations
       
         operation*/)    {        return redisTemplate.opsForValue().get(key);     }        /**     * 缓存List数据     * @param key        缓存的键值     * @param dataList    待缓存的List数据     * @return            缓存的对象     */    public Object setCacheList(String key, List
        
       
      
     

 

 

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

 

package cn.zsmy.palmdoctor.redis;import java.io.ByteArrayInputStream;import java.io.ByteArrayOutputStream;import java.io.Closeable;import java.io.IOException;import java.io.ObjectInputStream;import java.io.ObjectOutputStream;import cn.zsmy.constant.Constant;/** * @author shm */public class SerializeUtil {    public static byte[] serialize(Object value) {        if (value == null) {            throw new NullPointerException("Can't serialize null");        }        byte[] rv = null;        ByteArrayOutputStream bos = null;        ObjectOutputStream os = null;        try {            bos = new ByteArrayOutputStream();            os = new ObjectOutputStream(bos);            os.writeObject(value);            os.close();            bos.close();            rv = bos.toByteArray();        } catch (Exception e) {            e.printStackTrace();            Constant.MY_LOG.info("serialize error");        } finally {            close(os);            close(bos);        }        return rv;    }    public static Object deserialize(byte[] in) {        return deserialize(in, Object.class);    }    @SuppressWarnings("unchecked")    public static 
     
       T deserialize(byte[] in, Class
      
        requiredType) {        Object rv = null;        ByteArrayInputStream bis = null;        ObjectInputStream is = null;        try {            if (in != null) {                bis = new ByteArrayInputStream(in);                is = new ObjectInputStream(bis);                rv = is.readObject();            }        } catch (Exception e) {            e.printStackTrace();            Constant.MY_LOG.info("deserialize error");        } finally {            close(is);            close(bis);        }        return (T) rv;    }    private static void close(Closeable closeable) {        if (closeable != null)            try {                closeable.close();            } catch (IOException e) {                e.printStackTrace();                Constant.MY_LOG.info("close stream error");            }    }}