redis 主從備份及其主備切換的操作

Posted on by

首先原文是用瞭3 個服務器，我是用瞭一個服務器；

然後再原文的基礎上，稍加瞭自己的整理。

前提：

redis中，主從切換場景中，沒有絕對的主和從，隻有初始化的主和從，然後當主down後，從就變成主瞭，而主即使連接上，也是從，不會變為主

1.redis-server的主備關系：

master : redis-1

slave1 : redis-2

slave3 : redis-3

2. 首先進行主從備份：

修改從服務 redis-1 redis-2 的redis.conf

在從服務上 修改redis.conf 加入 slaveof 127.0.0.1 6379

主從備份： 這裡設置成功之後，會進行主服務進行set之後，可在從服務進行get key ，可是一旦主服務宕機，從服務無法再進行set key

3.設置主從切換

三個服務器都修改 sentinel-test.conf

加入

sentinel monitor MyMaster 127.0.0.1 6381 1
sentinel down-after-milliseconds MyMaster 5000
sentinel failover-timeout MyMaster 900000
sentinel parallel-syncs MyMaster 2

第一行配置指示 Sentinel 去監視一個名為 mymaster 的主服務器， 這個主服務器的 IP 地址為 127.0.0.1 ， 端口號為 6379 ， 而將這個主服務器判斷為失效至少需要 2 個 Sentinel 同意 （隻要同意 Sentinel 的數量不達標，自動故障遷移就不會執行）。

第二行down-after-milliseconds 選項指定瞭 Sentinel 認為服務器已經斷線所需的毫秒數。

如果服務器在給定的毫秒數之內， 沒有返回 Sentinel 發送的 PING 命令的回復， 或者返回一個錯誤， 那麼 Sentinel 將這個服務器標記為主觀下線（subjectively down，簡稱 SDOWN ）。

不過隻有一個 Sentinel 將服務器標記為主觀下線並不一定會引起服務器的自動故障遷移： 隻有在足夠數量的 Sentinel 都將一個服務器標記為主觀下線之後， 服務器才會被標記為客觀下線（objectively down， 簡稱 ODOWN ）， 這時自動故障遷移才會執行。

將服務器標記為客觀下線所需的 Sentinel 數量由對主服務器的配置決定。

第三行暫時不知道是什麼意思；

第四行 parallel-syncs 選項指定瞭在執行故障轉移時， 最多可以有多少個從服務器同時對新的主服務器進行同步， 這個數字越小， 完成故障轉移所需的時間就越長。

如果從服務器被設置為允許使用過期數據集（參見對 redis.conf 文件中對 slave-serve-stale-data 選項的說明）， 那麼你可能不希望所有從服務器都在同一時間向新的主服務器發送同步請求， 因為盡管復制過程的絕大部分步驟都不會阻塞從服務器， 但從服務器在載入主服務器發來的 RDB 文件時， 仍然會造成從服務器在一段時間內不能處理命令請求： 如果全部從服務器一起對新的主服務器進行同步， 那麼就可能會造成所有從服務器在短時間內全部不可用的情況出現。

你可以通過將這個值設為 1 來保證每次隻有一個從服務器處於不能處理命令請求的狀態。

4.啟動

  啟動redis-server
    # ./src/redis-server redis.conf 
    啟動redis-sentinel
    # ./src/redis-sentinelsentinel-test.conf

註意： 三臺服務器都是這麼啟動的哦！~

補充：Redis CLuster主備切換、故障轉移測試

redis版本5.0.5

測試redis Cluster主備切換、故障轉移

1.下線一個從節點，此時它的主節點打印的日志

集群狀態

2.下線一臺主節點，此時它的從節點打印的日志

集群狀態

測試主備切換時客戶端狀態

第一步：查看當前集群狀態

可以看到六個節點都是可用狀態，其中83.46的6379是81.64上的6380的從節點，計劃Kill掉81.64上的6380主節點，然後觀察83.46的6379節點日志

第二步：kill掉81.64上的6380

10:11:25：kill掉81.64上的6380，可以看到其從節點很快提示連接主節點失敗，並且開始一秒鐘一次的重連操作

此時查看集群的節點狀態如下，可以看到槽 5461-10922在這個主節點上，此時整個reidis集群處於不可用狀態

10:12:24：應用程序報錯，redis操作超時

10:11:43 ：在重連17次失敗次數之後，從節點將主節點標記為失敗，並且整個集群的狀態切換為不可用，之後不甘心，又去嘗試連接主節點

10:12:03：在重連20次失敗後，從節點打印日志，等待投票選舉，但是沒有達到多數贊成，於是繼續重連之前的主節點

10:12:14：提示選舉失敗，選舉過期，又繼續重連

10:12:45：選舉成功勝出，成為瞭新的主節點，整個集群的狀態變為可用

10:13:39：大概一分鐘之後，redis客戶端自動刷新瞭集群配置，成功連接上redis集群，此時主備切換和故障轉移完成

此前項目中存在的問題

redis master宕機之後，會出現應用程序連接不上redis cluster的問題，需要重啟服務才能解決

排查原因之後發現是spring boot 2.x版本默認使用瞭lettuce作為redis客戶端，而lettuce默認是不開啟自動刷新集群拓撲的，當redis master宕機並且集群完成故障轉移/主從切換之後，客戶端使用的還是之前錯誤的集群信息，就會導致應用程序一直連接不上redis集群。解決方案就是修改redis客戶端配置，開啟開啟自適應刷新拓撲

配置文件如下

spring.redis.cluster.nodes=${redis.nodes}
spring.redis.password=${redis.pass}
spring.redis.timeout=60000
# 最大重定向次數
spring.redis.cluster.max-redirects=3
spring.redis.lettuce.pool.max-active=64
spring.redis.lettuce.pool.max-idle=16
spring.redis.lettuce.pool.min-idle=0
spring.redis.lettuce.pool.max-wait=60000ms
spring.redis.lettuce.shutdown-timeout=100ms

完整的配置類如下

import com.fasterxml.jackson.annotation.JsonAutoDetect;
import com.fasterxml.jackson.annotation.PropertyAccessor;
import com.fasterxml.jackson.databind.ObjectMapper;
import io.lettuce.core.cluster.ClusterClientOptions;
import io.lettuce.core.cluster.ClusterTopologyRefreshOptions;
import org.apache.commons.pool2.impl.GenericObjectPoolConfig;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.autoconfigure.data.redis.RedisProperties;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.data.redis.connection.RedisClusterConfiguration;
import org.springframework.data.redis.connection.RedisConnectionFactory;
import org.springframework.data.redis.connection.RedisNode;
import org.springframework.data.redis.connection.RedisPassword;
import org.springframework.data.redis.connection.lettuce.LettuceClientConfiguration;
import org.springframework.data.redis.connection.lettuce.LettuceConnectionFactory;
import org.springframework.data.redis.connection.lettuce.LettucePoolingClientConfiguration;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.data.redis.serializer.Jackson2JsonRedisSerializer;
import org.springframework.data.redis.serializer.StringRedisSerializer;
import java.time.Duration;
import java.util.HashSet;
import java.util.List;
import java.util.Set;
@Configuration
public class RedisConfig {
    @Autowired
    private RedisProperties redisProperties;
    @Bean
    @SuppressWarnings("all")
    public RedisTemplate<String, Object> redisTemplate(RedisConnectionFactory factory) {
        RedisTemplate<String, Object> template = new RedisTemplate<String, Object>();
        template.setConnectionFactory(factory);
        Jackson2JsonRedisSerializer jackson2JsonRedisSerializer = new Jackson2JsonRedisSerializer(Object.class);
        ObjectMapper om = new ObjectMapper();
        om.setVisibility(PropertyAccessor.ALL, JsonAutoDetect.Visibility.ANY);
        om.enableDefaultTyping(ObjectMapper.DefaultTyping.NON_FINAL);
        jackson2JsonRedisSerializer.setObjectMapper(om);
        StringRedisSerializer stringRedisSerializer = new StringRedisSerializer();
        // key采用String的序列化方式
        template.setKeySerializer(stringRedisSerializer);
        // hash的key也采用String的序列化方式
        template.setHashKeySerializer(stringRedisSerializer);
        // value序列化方式采用jackson
        template.setValueSerializer(jackson2JsonRedisSerializer);
        // hash的value序列化方式采用jackson
        template.setHashValueSerializer(jackson2JsonRedisSerializer);
        template.afterPropertiesSet();
        return template;
    }
    /**
     * 為RedisTemplate配置Redis連接工廠實現
     * LettuceConnectionFactory實現瞭RedisConnectionFactory接口
     * 這裡要註意的是，在構建LettuceConnectionFactory 時，如果不使用內置的destroyMethod，可能會導致Redis連接早於其它Bean被銷毀
     *
     * @return 返回LettuceConnectionFactory
     */
    @Bean(destroyMethod = "destroy")
    public LettuceConnectionFactory lettuceConnectionFactory() {
        List<String> clusterNodes = redisProperties.getCluster().getNodes();
        Set<RedisNode> nodes = new HashSet<>();
        clusterNodes.forEach(address -> nodes.add(new RedisNode(address.split(":")[0].trim(), Integer.parseInt(address.split(":")[1]))));
        RedisClusterConfiguration clusterConfiguration = new RedisClusterConfiguration();
        clusterConfiguration.setClusterNodes(nodes);
        clusterConfiguration.setPassword(RedisPassword.of(redisProperties.getPassword()));
        clusterConfiguration.setMaxRedirects(redisProperties.getCluster().getMaxRedirects());
        GenericObjectPoolConfig poolConfig = new GenericObjectPoolConfig();
        poolConfig.setMaxIdle(redisProperties.getLettuce().getPool().getMaxIdle());
        poolConfig.setMinIdle(redisProperties.getLettuce().getPool().getMinIdle());
        poolConfig.setMaxTotal(redisProperties.getLettuce().getPool().getMaxActive());
        return new LettuceConnectionFactory(clusterConfiguration, getLettuceClientConfiguration(poolConfig));
    }
    /**
     * 配置LettuceClientConfiguration 開啟自適應刷新拓撲 包括線程池配置和安全項配置
     *
     * @param genericObjectPoolConfig common-pool2線程池
     * @return lettuceClientConfiguration
     */
    private LettuceClientConfiguration getLettuceClientConfiguration(GenericObjectPoolConfig genericObjectPoolConfig) {
        /*
        ClusterTopologyRefreshOptions配置用於開啟自適應刷新和定時刷新。如自適應刷新不開啟，Redis集群變更時將會導致連接異常！
         */
        ClusterTopologyRefreshOptions topologyRefreshOptions = ClusterTopologyRefreshOptions.builder()
                //開啟自適應刷新
                //.enableAdaptiveRefreshTrigger(ClusterTopologyRefreshOptions.RefreshTrigger.MOVED_REDIRECT, ClusterTopologyRefreshOptions.RefreshTrigger.PERSISTENT_RECONNECTS)
                //開啟所有自適應刷新，MOVED，ASK，PERSISTENT都會觸發
                .enableAllAdaptiveRefreshTriggers()
                // 自適應刷新超時時間(默認30秒)
                .adaptiveRefreshTriggersTimeout(Duration.ofSeconds(25)) //默認關閉開啟後時間為30秒
                // 開周期刷新
                .enablePeriodicRefresh(Duration.ofSeconds(20))  // 默認關閉開啟後時間為60秒 ClusterTopologyRefreshOptions.DEFAULT_REFRESH_PERIOD 60  .enablePeriodicRefresh(Duration.ofSeconds(2)) = .enablePeriodicRefresh().refreshPeriod(Duration.ofSeconds(2))
                .build();
        return LettucePoolingClientConfiguration.builder()
                .poolConfig(genericObjectPoolConfig)
                .clientOptions(ClusterClientOptions.builder().topologyRefreshOptions(topologyRefreshOptions).build())
                .build();
    }
}

以上為個人經驗，希望能給大傢一個參考，也希望大傢多多支持WalkonNet。如有錯誤或未考慮完全的地方，望不吝賜教。

推薦閱讀：

    None Found