前言

上篇部落格談到了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

客戶端連線主節點，檢視Redis Master相關資訊

redis-cli -h 192.168.48.31 info Replication

Redis Sentinel啟動資訊

客戶端連線sentinel節點，檢視Redis Sentinel相關資訊

redis-cli -h 192.168.48.31 -p 26379 info Sentinel

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

<bean id="jedisConnectionFactory" class="org.springframework.data.redis.connection.jedis.JedisConnectionFactory">
    <constructor-arg name="sentinelConfig" ref="redisSentinelConfiguration"/>
    <constructor-arg name="poolConfig" ref="jedisPoolConfig" />
</bean>

step3、配置JedisPoolConfig

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

配置檔案spring-redis.properties內容

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

step4、配置RedisSentinelConfiguration

和叢集配置一樣，sentinel也有兩種配置方式

1.sentinels設值注入

<bean id="redisSentinelConfiguration" class="org.springframework.data.redis.connection.RedisSentinelConfiguration">
    <property name="sentinels">
        <set>
            <bean name="sentinelNode1" class="org.springframework.data.redis.connection.RedisNode">
                <constructor-arg name="host" value="192.168.48.31"/>
                <constructor-arg name="port" value="26379"/>
            </bean>
            <bean name="sentinelNode2" class="org.springframework.data.redis.connection.RedisNode">
                <constructor-arg name="host" value="192.168.48.32"/>
                <constructor-arg name="port" value="26379"/>
            </bean>
            <bean name="sentinelNode3" class="org.springframework.data.redis.connection.RedisNode">
                <constructor-arg name="host" value="192.168.48.33"/>
                <constructor-arg name="port" value="26379"/>
            </bean>
        </set>
    </property>
    <property name="master">
        <bean name="masterNode" class="org.springframework.data.redis.connection.RedisNode">
            <!--必須指定主節點名稱-->
            <property name="name" value="mymaster"/>
            <constructor-arg name="host" value="192.168.48.31"/>
            <constructor-arg name="port" value="6379"/>
        </bean>
    </property>
</bean>

2.propertySource構造注入

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

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

step5、配置RedisTemplate

然後配置RedisTemplate，用於redis命令操作

<bean id="stringRedisTemplate" class="org.springframework.data.redis.core.StringRedisTemplate" p:connection-factory-ref="jedisConnectionFactory"/>

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)能檢視到相同的結果：

到此，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" />

    <!-- Jedis ConnectionFactory -->
    <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"/>
<!--        <property name="sentinels">
            <set>
                <bean name="sentinelNode1" class="org.springframework.data.redis.connection.RedisNode">
                    <constructor-arg name="host" value="192.168.48.31"/>
                    <constructor-arg name="port" value="26379"/>
                </bean>
                <bean name="sentinelNode2" class="org.springframework.data.redis.connection.RedisNode">
                    <constructor-arg name="host" value="192.168.48.32"/>
                    <constructor-arg name="port" value="26379"/>
                </bean>
                <bean name="sentinelNode3" class="org.springframework.data.redis.connection.RedisNode">
                    <constructor-arg name="host" value="192.168.48.33"/>
                    <constructor-arg name="port" value="26379"/>
                </bean>
            </set>
        </property>
        <property name="master">
            <bean name="masterNode" class="org.springframework.data.redis.connection.RedisNode">
                &lt;!&ndash;必須指定主節點名稱&ndash;&gt;
                <property name="name" value="mymaster"/>
                <constructor-arg name="host" value="192.168.48.31"/>
                <constructor-arg name="port" value="6379"/>
            </bean>
        </property>-->
    </bean>

    <bean name="propertySource" class="org.springframework.core.io.support.ResourcePropertySource">
        <constructor-arg name="location" value="classpath:spring-redis-sentinel.properties" />
    </bean>

    <!-- JedisPoolConfig definition -->
    <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>

    <!-- redis template definition -->
    <bean id="stringRedisTemplate" class="org.springframework.data.redis.core.StringRedisTemplate" p:connection-factory-ref="jedisConnectionFactory"/>

sentinel故障轉移

為驗證故障轉移，我們關閉Master節點

shutdown

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

接下來再來測試一種情況：在故障節點重啟之前傳送寫命令，故障節點重啟後資料是否會複製過來？

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

結果：

重啟原來的Master節點（192.168.48.31:6379）

原先的Master重啟後變成了新Master的從節點了，試著檢視foo1的值

可見，重啟後，新的從節點會複製新的master節點，保證資料一致性。

參考