Redis主从监控，故障自动切换

ny3259

系统环境 ：Centos 6.6

Redis版本：2.8.19 
官方地址：http://redis.io/

1、首先下载编译安装redis 
$ wget http://download.redis.io/releases/redis-2.8.19.tar.gz 
$ tar xzf redis-2.8.19.tar.gz 
$ cd redis-2.8.19 
$ make 

一主（Master）两从（Slave1,Slave2） 
将编译好的redis-2.8.19里文件分别拷贝三份到目录Master、Slave1、Slave2、Sentinel1

 
配置redis端口
Master实例：默认配置 端口6379
Slave1和Slave2实例：修改redis.config 文件，配置主redis地址和端口：slaveof 192.168.0.138 6379 （记得#去掉），
同时记得修改端口，配置Slave1 端口6380，Slave2端口6381

 
分别进入Master、Slave1、Slave2目录，启动redis


 
 
此时你可以启动主的redis-cli做操作


 
 
到目前为止，redis主从同步完成，下面是redis集群：
采用Sentinel方案，利用以上的Redis的Master/Slave的复制，可以打造一个高可用的Redis集群;


 
 
 
同时，mysentinel.conf 自动修改成如下：
#redismaster是Master的名称，192.168.0.138是Master的Ip，1表示确认一个Master为O_DOWN最少需要多少个哨兵认可
sentinel monitor redismaster 192.168.0.138 6381 1
#多少秒（默认30秒）后Maste不可用被确认为S_DOWN状态
sentinel down-after-milliseconds redismaster 10000
sentinel config-epoch redismaster 3
sentinel leader-epoch redismaster 3
# Generated by CONFIG REWRITE
port 26379
dir "/home/max/Redis/Sentinel1"
sentinel known-slave redismaster 192.168.0.138 6380
sentinel known-slave redismaster 192.168.0.138 6379
 
sentinel current-epoch 3
 
 
重新启动主


 
发现这个主自动被当作从处理；
 
下面是简单介绍客户端代码使用，利用jedis-2.5.2.jar；
结合spring配置如下
#链接数据库
redis.default.db=5
#客户端超时时间单位是毫秒
redis.timeout=100000
#最大连接数
redis.maxActive=10000
#最大空闲数
redis.maxIdle=100
#最大建立连接等待时间
redis.maxWait=1000
#指明是否在从池中取出连接前进行检验,如果检验失败,则从池中去除连接并尝试取出另一个
redis.testOnBorrow=true
 
 
 <!-- jedis pool配置 -->
 <bean id="jedisPoolConfig" class="redis.clients.jedis.JedisPoolConfig">
  <property name="maxTotal" value="${redis.maxActive}" />
  <property name="maxIdle" value="${redis.maxIdle}" />
  <property name="maxWaitMillis" value="${redis.maxWait}" />
  <!-- 向调用者输出“链接”资源时，是否检测是有有效，如果无效则从连接池中移除，并尝试获取继续获取。设为true，一个挂都不能用 -->
  <property name="testOnBorrow" value="${redis.testOnBorrow}" />
  <!-- 向连接池“归还”链接时，是否检测“链接”对象的有效性。 -->
  <property name="testOnReturn" value="true" />
 </bean>
 
 <bean id="jedisPool" class="redis.clients.jedis.JedisSentinelPool">
  <constructor-arg index="0" value="redismaster" />
  <constructor-arg index="1">
   <set>
    <value>192.168.0.138:26379</value><!--配置了一个哨兵 -->
   </set>
  </constructor-arg>
  <constructor-arg index="2" ref="jedisPoolConfig" />
  <constructor-arg index="3" value="${redis.timeout}" />
  <constructor-arg index="4"><null/></constructor-arg>
  <constructor-arg index="5" value="${redis.default.db}" />
 </bean>
 
测试类代码
  ApplicationContext ac = new ClassPathXmlApplicationContext("applicationContext-redis.xml");
  JedisSentinelPool pool = (JedisSentinelPool) ac.getBean("jedisPool");
  Jedis jedis = null;
  try
  {
   jedis = pool.getResource();
      jedis.hset("max", "zheng", "hello");
  }
  catch (JedisException je)
  {
   throw je;
  }
  finally
  {
   if (jedis != null)
    pool.returnResource(jedis);
  }