AI专业者开发社区 1 号成员
  •  0 回帖  •  0 浏览  •  4 个月前
 

java操作 redis集群

1.redis 服务端集群搭建步骤：

  1. 下载 redis 安装包，进行解压安装

  2. 安装 ruby、rubygems install ruby ，安装 ruby 的原因是，在进行集群的时候，使用的是 ruby 语言工具实现的，所以在集群之前首先需要搭建 ruby 的环境

  3. 在上述步骤完成之后，便可以搭建集群环境，redis 提供了两种集群搭建方法，执行脚本方法 (安装包下面的 util 包中) 和手动搭建。

  注意：

  1. 在集群的时候，如果是远端客户端访问 redis 服务端，那么在分片的时候，需要使用 Ip 进行分片，下面会详细说

  2. 在创建每个节点的时候，不要只用 redis-server ，使用绝对路径下的 redis-server xxx

  具体的安装步骤如下：http://blog.csdn.net/xu470438000/article/details/42971091

  附件：在安装 ruby 的时候，需要 gemredis，下载地址在下面。

2. 客户端 (java)：

注意：

1. 本文的客户端使用的是 java, 官网中对于 java 客户端也提供了不少的 client, 但是本文使用的是官方推荐的 jedis。

2. 在项目开发中，一般情况下都会用到 spring 来管理应用，本文也是如此，spring 本身也提供了对 redis 的集成支持，具体的网址：http://projects.spring.io/spring-data-redis，

 但是好像目前 spring-data-redis 不提供集群的功能，所以本文没有使用它，而是使用了原装的 jedis 来进行开发，如果在项目中没有用到集群的功能，则可以使用 spirng-data-redis。

 

 

 

下面是具体的代码实现

 

1.maven 依赖

 

 

Java 代码  收藏代码
  1. <dependency>  
  2.     <groupId>redis.clients</groupId>  
  3.     <artifactId>jedis</artifactId>  
  4.     <version>2.7.2</version>  
  5. </dependency>  

 

 

2.applicationContext.xml 中的配置

 

 

Java 代码  收藏代码
  1.    <!-- jedis cluster config -->  
  2.    <bean name="genericObjectPoolConfig" class="org.apache.commons.pool2.impl.GenericObjectPoolConfig" >  
  3.         <property name="maxWaitMillis" value="-1" />  
  4.         <property name="maxTotal" value="1000" />  
  5.         <property name="minIdle" value="8" />  
  6.         <property name="maxIdle" value="100" />  
  7. </bean>  
  8.   
  9. <bean id="jedisCluster" class="com.besttone.subscribe.util.JedisClusterFactory">  
  10.     <property name="addressConfig">  
  11.         <value>classpath:redis-config.properties</value>  
  12.     </property>  
  13.     <property name="addressKeyPrefix" value="address" />    
  14.       
  15.     <property name="timeout" value="300000" />  
  16.     <property name="maxRedirections" value="6" />  
  17.     <property name="genericObjectPoolConfig" ref="genericObjectPoolConfig" />  
  18. </bean>  

 

 

3.JedisClusterFactory 实现类

 

Java 代码  收藏代码
  1. public class JedisClusterFactory implements FactoryBean<JedisCluster>, InitializingBean {  
  2.   
  3.     private Resource addressConfig;  
  4.     private String addressKeyPrefix ;  
  5.   
  6.     private JedisCluster jedisCluster;  
  7.     private Integer timeout;  
  8.     private Integer maxRedirections;  
  9.     private GenericObjectPoolConfig genericObjectPoolConfig;  
  10.       
  11.     private Pattern p = Pattern.compile("^.+[:]\\d{1,5}\\s*$");  
  12.   
  13.     @Override  
  14.     public JedisCluster getObject() throws Exception {  
  15.         return jedisCluster;  
  16.     }  
  17.   
  18.     @Override  
  19.     public Class<? extends JedisCluster> getObjectType() {  
  20.         return (this.jedisCluster != null ? this.jedisCluster.getClass() : JedisCluster.class);  
  21.     }  
  22.   
  23.     @Override  
  24.     public boolean isSingleton() {  
  25.         return true;  
  26.     }  
  27.   
  28.   
  29.   
  30.     private Set<HostAndPort> parseHostAndPort() throws Exception {  
  31.         try {  
  32.             Properties prop = new Properties();  
  33.             prop.load(this.addressConfig.getInputStream());  
  34.   
  35.             Set<HostAndPort> haps = new HashSet<HostAndPort>();  
  36.             for (Object key : prop.keySet()) {  
  37.   
  38.                 if (!((String) key).startsWith(addressKeyPrefix)) {  
  39.                     continue;  
  40.                 }  
  41.   
  42.                 String val = (String) prop.get(key);  
  43.   
  44.                 boolean isIpPort = p.matcher(val).matches();  
  45.   
  46.                 if (!isIpPort) {  
  47.                     throw new IllegalArgumentException("ip 或 port 不合法");  
  48.                 }  
  49.                 String[] ipAndPort = val.split(":");  
  50.   
  51.                 HostAndPort hap = new HostAndPort(ipAndPort[0], Integer.parseInt(ipAndPort[1]));  
  52.                 haps.add(hap);  
  53.             }  
  54.   
  55.             return haps;  
  56.         } catch (IllegalArgumentException ex) {  
  57.             throw ex;  
  58.         } catch (Exception ex) {  
  59.             throw new Exception("解析 jedis 配置文件失败", ex);  
  60.         }  
  61.     }  
  62.       
  63.     @Override  
  64.     public void afterPropertiesSet() throws Exception {  
  65.         Set<HostAndPort> haps = this.parseHostAndPort();  
  66.           
  67.         jedisCluster = new JedisCluster(haps, timeout, maxRedirections,genericObjectPoolConfig);  
  68.           
  69.     }  
  70.     public void setAddressConfig(Resource addressConfig) {  
  71.         this.addressConfig = addressConfig;  
  72.     }  
  73.   
  74.     public void setTimeout(int timeout) {  
  75.         this.timeout = timeout;  
  76.     }  
  77.   
  78.     public void setMaxRedirections(int maxRedirections) {  
  79.         this.maxRedirections = maxRedirections;  
  80.     }  
  81.   
  82.     public void setAddressKeyPrefix(String addressKeyPrefix) {  
  83.         this.addressKeyPrefix = addressKeyPrefix;  
  84.     }  
  85.   
  86.     public void setGenericObjectPoolConfig(GenericObjectPoolConfig genericObjectPoolConfig) {  
  87.         this.genericObjectPoolConfig = genericObjectPoolConfig;  
  88.     }  
  89.   
  90. }  

 

4.redis-config.properties 文件

 

   这是一个集群环境，六个节点 (不同端口)，三个 master , 三个 slaver

 

Java 代码  收藏代码
  1. address1=192.168.30.139:7000  
  2. address2=192.168.30.139:7001  
  3. address3=192.168.30.139:7002  
  4. address4=192.168.30.139:7003  
  5. address5=192.168.30.139:7004  
  6. address6=192.168.30.139:7005