Spring整合Redis之哨兵与故障转移

港控/mmm° 2022-06-10 04:28 339阅读 0赞

### 前言 ###

上篇[博客][Link 1]谈到了Spring整合redis集群以及故障转移演示，会发现redis集群模式存在一个很明显的问题：当某个主节点及其所有从节点挂掉，整个集群因为缺少该节点负责范围的哈希槽（hash slot）而宕掉，不具高可用性。redis引入了哨兵（sentinel）模式，能很好解决集群模式存在的不足。引用官网，redis哨兵系统有三个作用：

*  **监控（Monitoring）**： Sentinel 会不断地检查你的主服务器和从服务器是否运作正常。
 *  **提醒（Notification）**： 当被监控的某个 Redis 服务器出现问题时， Sentinel 可以通过 API 向管理员或者其他应用程序发送通知。
 *  **自动故障迁移（Automatic failover**）： 当一个主服务器不能正常工作时， Sentinel 会开始一次自动故障迁移操作， 它会将失效主服务器的其中一个从服务器升级为新的主服务器， 并让失效主服务器的其他从服务器改为复制新的主服务器； 当客户端试图连接失效的主服务器时， 集群也会向客户端返回新主服务器的地址， 使得集群可以使用新主服务器代替失效服务器。

本文主要讲解spring整合redis sentinel及故障转移示例，以此加深理解。

### 环境准备 ###

笔者已经预先搭建好Redis Sentinel，环境如下：

*  OS：CentOS release 6.5 (Final)
 *  Redis版本：4.0.1

<table> 
 <thead> 
  <tr> 
   <th>role</th> 
   <th>ip</th> 
   <th>port</th> 
  </tr> 
 </thead> 
 <tbody> 
  <tr> 
   <td>Redis Master</td> 
   <td>192.168.48.31</td> 
   <td>6379</td> 
  </tr> 
  <tr> 
   <td>Redis Slave1</td> 
   <td>192.168.48.32</td> 
   <td>6379</td> 
  </tr> 
  <tr> 
   <td>Redis Slave0</td> 
   <td>192.168.48.33</td> 
   <td>6379</td> 
  </tr> 
  <tr> 
   <td>Redis Sentinel</td> 
   <td>192.168.48.31</td> 
   <td>26379</td> 
  </tr> 
  <tr> 
   <td>Redis Sentinel</td> 
   <td>192.168.48.32</td> 
   <td>26379</td> 
  </tr> 
  <tr> 
   <td>Redis Sentinel</td> 
   <td>192.168.48.33</td> 
   <td>26379</td> 
  </tr> 
 </tbody> 
</table>

客户端连接主节点，查看Redis Master相关信息

redis-cli -h 192.168.48.31 info Replication

![Redis Master相关信息][Redis Master]

Redis Sentinel启动信息

![Redis Sentinel启动信息][Redis Sentinel]

客户端连接sentinel节点，查看Redis Sentinel相关信息

redis-cli -h 192.168.48.31 -p 26379 info Sentinel

![Redis Sentinel相关信息][Redis Sentinel 1]

### spring整合redis sentinel ###

#### step1、maven依赖引入 ####

<dependencies>
        <dependency>
            <groupId>org.springframework.data</groupId>
            <artifactId>spring-data-redis</artifactId>
            <version>1.8.6.RELEASE</version>
        </dependency>
        <dependency>
            <groupId>redis.clients</groupId>
            <artifactId>jedis</artifactId>
            <version>2.9.0</version>
        </dependency>
    </dependencies>

#### step2、配置ConnectionFactory ####

构造JedisConnectionFactory实例，注入池配置poolConfig和哨兵配置sentinelConfig

#### step3、配置JedisPoolConfig ####

配置文件spring-redis.properties内容

redis.minIdle=50
    redis.maxIdle=200
    redis.maxActive=100
    redis.maxWait=3000
    redis.testOnBorrow=true

#### step4、配置RedisSentinelConfiguration ####

和集群配置一样，sentinel也有两种配置方式

1.sentinels设值注入

2.propertySource构造注入

spring-redis-sentinel.properties内容：

#哨兵监控主redis节点名称，必选
    spring.redis.sentinel.master=mymaster
    #哨兵节点
    spring.redis.sentinel.nodes=192.168.48.31:26379,192.168.48.32:26379,192.168.48.33:26379

RedisSentinelConfiguration源码中这两个配置属性常量：

private static final String REDIS_SENTINEL_MASTER_CONFIG_PROPERTY = "spring.redis.sentinel.master";
    private static final String REDIS_SENTINEL_NODES_CONFIG_PROPERTY = "spring.redis.sentinel.nodes";

![RedisSentinelConfiguration源码][RedisSentinelConfiguration]

#### step5、配置RedisTemplate ####

然后配置RedisTemplate，用于redis命令操作

#### step6、测试 ####

package example;
    
    import org.springframework.context.support.ClassPathXmlApplicationContext;
    import org.springframework.data.redis.core.StringRedisTemplate;
    import org.springframework.data.redis.core.ValueOperations;
    
    public class SpringMain { 
    
        public static void main(String[] args) throws InterruptedException { 
            ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext("classpath:spring-redis.xml");
            StringRedisTemplate template = context.getBean(StringRedisTemplate.class);
            ValueOperations<String, String> valueOperations = template.opsForValue();
            valueOperations.set("foo","bar");
            context.destroy();
        }
    }

由于主从复制，Master(48.31)、Slave1(48.32)、Slave0(48.33)能查看到相同的结果：

![master的foo值][master_foo]  
![slave1的foo值][slave1_foo]  
![slave2的foo值][slave1_foo]

到此，spring整合redis sentinel完成，完整配置如下：

<?xml version="1.0" encoding="UTF-8"?>
    <beans xmlns="http://www.springframework.org/schema/beans" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:p="http://www.springframework.org/schema/p" xmlns:redis="http://www.springframework.org/schema/redis" xmlns:context="http://www.springframework.org/schema/context" xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd http://www.springframework.org/schema/redis http://www.springframework.org/schema/redis/spring-redis.xsd http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context.xsd">
    
        <context:property-placeholder location="classpath:*.properties" ignore-unresolvable="true" />
    
        
        <bean id="jedisConnectionFactory" class="org.springframework.data.redis.connection.jedis.JedisConnectionFactory">
            <constructor-arg name="sentinelConfig" ref="redisSentinelConfiguration"/>
            <constructor-arg name="poolConfig" ref="jedisPoolConfig" />
        </bean>
    
        <bean id="redisSentinelConfiguration" class="org.springframework.data.redis.connection.RedisSentinelConfiguration">
            <constructor-arg name="propertySource" ref="propertySource"/>
    
        </bean>
    
        <bean name="propertySource" class="org.springframework.core.io.support.ResourcePropertySource">
            <constructor-arg name="location" value="classpath:spring-redis-sentinel.properties" />
        </bean>
    
        
        <bean id="jedisPoolConfig" class="redis.clients.jedis.JedisPoolConfig" >
            <property name="minIdle" value="${redis.minIdle}" />
            <property name="maxIdle" value="${redis.maxIdle}" />
            <property name="maxTotal" value="${redis.maxActive}" />
            <property name="maxWaitMillis" value="${redis.maxWait}" />
            <property name="testOnBorrow" value="${redis.testOnBorrow}" />
            <property name="testOnReturn" value="true" />
            <property name="testWhileIdle" value="true" />
        </bean>
    
        
        <bean id="stringRedisTemplate" class="org.springframework.data.redis.core.StringRedisTemplate" p:connection-factory-ref="jedisConnectionFactory"/>

### sentinel故障转移 ###

为验证故障转移，我们关闭Master节点

shutdown

![关闭Master节点][Master]

Sentinel监控日志：

![Sentinel监控日志][Sentinel]

简单解释下日志信息：

*  \+sdown 表示监控节点主观下线（单个Sentinel实例对服务器做出的下线判断）
 *  \+odown 表示监控节点客观下线（多个Sentinel实例对服务器做出的sdown判断），sentinel.config中配置达到2个sdown（quorum参数配置）便判断为客观下线
 *  \+switch-master 从slave节点中选个作为新的主节点，Slave1（192.168.48.32:6379）

查看该节点信息，发现他的角色已经变为master，原先的Slave0(192.168.48.33:6379)变成新master的slave：

redis-cli -h 192.168.48.32 info Replication

![新Master节点][Master 1]

接下来再来测试一种情况：在故障节点重启之前发送写命令，故障节点重启后数据是否会复制过来？

valueOperations.set("foo1","bar1");

结果：

![新master的foo1值][master_foo1]

重启原来的Master节点（192.168.48.31:6379）

![重启原Master节点后][Master 2]

原先的Master重启后变成了新Master的从节点了，试着查看foo1的值

![foo1值同步过来了][foo1]

可见，重启后，新的从节点会复制新的master节点，保证数据一致性。

**参考**

spring-data-redis sentinel:https://docs.spring.io/spring-data/redis/docs/2.0.0.RC2/reference/html/\#redis:sentinel

中文官网：http://www.redis.cn/topics/sentinel.html

[Link 1]: http://blog.csdn.net/u014513883/article/details/76785474
[Redis Master]: /images/20220610/41264d8ac7654f64b2a78fd813f0bca1.png
[Redis Sentinel]: /images/20220610/0df649bab3b944c083173a43fa523dd9.png
[Redis Sentinel 1]: /images/20220610/34ad35ba9c284773abdf809b7040c7cb.png
[RedisSentinelConfiguration]: /images/20220610/96885a58804d4810aeb60b7ee93d800c.png
[master_foo]: /images/20220610/c57d55bc2be64fd7a567a15aada79dcb.png
[slave1_foo]: /images/20220610/82ee37badabe49bb8685a9149472c7bd.png
[Master]: /images/20220610/426c2547ed59468d9216d7db41b4bdbd.png
[Sentinel]: /images/20220610/099311e398474961b142a22dfcc6f952.png
[Master 1]: /images/20220610/50755ac6a8ed45539ea302f0982c29d2.png
[master_foo1]: /images/20220610/aae268dd972147909bb975b236830738.png
[Master 2]: /images/20220610/309cffca8b1a49f599d02e8c1e455d45.png
[foo1]: /images/20220610/17b1e362c7684e55a3141c5ce4e1a4b6.png