1. <i id="s6b2k"><small id="s6b2k"></small></i>
    <b id="s6b2k"><bdo id="s6b2k"></bdo></b>
  2. <wbr id="s6b2k"></wbr>

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

    來源:腳本之家  責任編輯:小易  

    首先原文是用了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();
        }
    }
    

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

    您可能感興趣的文章:簡單粗暴的Redis數據備份和恢復方法Redis 通過 RDB 方式進行數據備份與還原的方法Redis數據導入導出以及數據遷移的4種方法詳解

  3. 本文相關:
  4. redis 執行性能測試
  5. redis簡介_動力節點java學院整理
  6. centos7.3安裝redis4.0.6詳細圖文教程
  7. 為啥懶 redis 是更好的 redis
  8. redis如何存儲對象與集合示例詳解
  9. redis教程(八):事務詳解
  10. redis批量刪除key的方法
  11. spring boot+redis實現消息發布與訂閱的代碼
  12. redis value過大問題(鍵值過大)
  13. redis安裝和配置_動力節點java學院整理
  14. redis做主備時,故障自動切換的應用怎么實現
  15. redis主從配置切換了怎么辦
  16. Redis通過Sentinel可以實現主從切換,客戶端怎么實...
  17. keepalived切換redis主從數據庫時怎么保證同步完成
  18. redis 主從切換時,長連接怎么處理
  19. 怎么用代碼監控redis主從改變
  20. redis 主從同步是雙向的嗎
  21. 怎么查看redis的服務是不是主從備份
  22. 在Redis的主從機制中,如果主服務器down了是否能自...
  23. 如何手動讓redis 主從同步
  24. 網站首頁網頁制作腳本下載服務器操作系統網站運營平面設計媒體動畫電腦基礎硬件教程網絡安全mssqlmysqlmariadboracledb2mssql2008mssql2005sqlitepostgresqlmongodbredisaccess數據庫文摘數據庫其它首頁簡單粗暴的redis數據備份和恢復方法redis 通過 rdb 方式進行數據備份與還原的方法redis數據導入導出以及數據遷移的4種方法詳解redis 執行性能測試redis簡介_動力節點java學院整理centos7.3安裝redis4.0.6詳細圖文教程為啥懶 redis 是更好的 redisredis如何存儲對象與集合示例詳解redis教程(八):事務詳解redis批量刪除key的方法spring boot+redis實現消息發布與訂閱的代碼redis value過大問題(鍵值過大)redis安裝和配置_動力節點java學院整理超強、超詳細redis數據庫入門教程redis常用命令、常見錯誤、配置技redis操作命令總結redis中5種數據結構的使用場景介64位windows下安裝redis教程redis中使用redis-dump導出、導入redis中統計各種數據大小的方法redis 密碼設置和查看密碼的方法redis常用命令小結讓redis在你的系統中發揮更大作用基于redis實現分布式鎖以及任務隊列springsession+redis實現集群會話共享的方redis自動化安裝及集群實現搭建過程redis主從實現讀寫分離解決redis服務啟動失敗的問題redis3.2.11在centos9安裝與卸載過程詳解基于redis集群設置密碼的實例redis常用命令整理關于redis key淘汰策略的實現方法redis命令行查看中文不亂碼的方法(十六進
    免責聲明 - 關于我們 - 聯系我們 - 廣告聯系 - 友情鏈接 - 幫助中心 - 頻道導航
    Copyright © 2017 www.yu113.com All Rights Reserved
    战天txt全集下载