redis如何實(shí)現(xiàn)主從備份

redis如何實(shí)現(xiàn)主從備份？很多新手對(duì)此不是很清楚，為了幫助大家解決這個(gè)難題，下面小編將為大家詳細(xì)講解，有這方面需求的人可以來學(xué)習(xí)下，希望你能有所收獲。

1.redis-server的主備關(guān)系：

master : redis-1

slave1 : redis-2

slave3 : redis-3

2. 首先進(jìn)行主從備份：

修改從服務(wù) redis-1 redis-2 的redis.conf

在從服務(wù)上 修改redis.conf 加入 slaveof 127.0.0.1 6379

主從備份： 這里設(shè)置成功之后，會(huì)進(jìn)行主服務(wù)進(jìn)行set之后，可在從服務(wù)進(jìn)行g(shù)et key ，可是一旦主服務(wù)宕機(jī)，從服務(wù)無法再進(jìn)行set key

3.設(shè)置主從切換

三個(gè)服務(wù)器都修改 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 去監(jiān)視一個(gè)名為 mymaster 的主服務(wù)器， 這個(gè)主服務(wù)器的 IP 地址為 127.0.0.1 ， 端口號(hào)為 6379 ， 而將這個(gè)主服務(wù)器判斷為失效至少需要 2 個(gè) Sentinel 同意 （只要同意 Sentinel 的數(shù)量不達(dá)標(biāo)，自動(dòng)故障遷移就不會(huì)執(zhí)行）。

第二行down-after-milliseconds 選項(xiàng)指定了 Sentinel 認(rèn)為服務(wù)器已經(jīng)斷線所需的毫秒數(shù)。

如果服務(wù)器在給定的毫秒數(shù)之內(nèi)， 沒有返回 Sentinel 發(fā)送的 PING 命令的回復(fù)， 或者返回一個(gè)錯(cuò)誤， 那么 Sentinel 將這個(gè)服務(wù)器標(biāo)記為主觀下線（subjectively down，簡(jiǎn)稱 SDOWN ）。

不過只有一個(gè) Sentinel 將服務(wù)器標(biāo)記為主觀下線并不一定會(huì)引起服務(wù)器的自動(dòng)故障遷移： 只有在足夠數(shù)量的 Sentinel 都將一個(gè)服務(wù)器標(biāo)記為主觀下線之后， 服務(wù)器才會(huì)被標(biāo)記為客觀下線（objectively down， 簡(jiǎn)稱 ODOWN ）， 這時(shí)自動(dòng)故障遷移才會(huì)執(zhí)行。

將服務(wù)器標(biāo)記為客觀下線所需的 Sentinel 數(shù)量由對(duì)主服務(wù)器的配置決定。

第三行暫時(shí)不知道是什么意思；

第四行 parallel-syncs 選項(xiàng)指定了在執(zhí)行故障轉(zhuǎn)移時(shí)， 最多可以有多少個(gè)從服務(wù)器同時(shí)對(duì)新的主服務(wù)器進(jìn)行同步， 這個(gè)數(shù)字越小， 完成故障轉(zhuǎn)移所需的時(shí)間就越長。

如果從服務(wù)器被設(shè)置為允許使用過期數(shù)據(jù)集（參見對(duì) redis.conf 文件中對(duì) slave-serve-stale-data 選項(xiàng)的說明）， 那么你可能不希望所有從服務(wù)器都在同一時(shí)間向新的主服務(wù)器發(fā)送同步請(qǐng)求， 因?yàn)楸M管復(fù)制過程的絕大部分步驟都不會(huì)阻塞從服務(wù)器， 但從服務(wù)器在載入主服務(wù)器發(fā)來的 RDB 文件時(shí)， 仍然會(huì)造成從服務(wù)器在一段時(shí)間內(nèi)不能處理命令請(qǐng)求： 如果全部從服務(wù)器一起對(duì)新的主服務(wù)器進(jìn)行同步， 那么就可能會(huì)造成所有從服務(wù)器在短時(shí)間內(nèi)全部不可用的情況出現(xiàn)。

你可以通過將這個(gè)值設(shè)為 1 來保證每次只有一個(gè)從服務(wù)器處于不能處理命令請(qǐng)求的狀態(tài)。

4.啟動(dòng)

  啟動(dòng)redis-server
    # ./src/redis-server redis.conf 
    啟動(dòng)redis-sentinel
    # ./src/redis-sentinelsentinel-test.conf

注意： 三臺(tái)服務(wù)器都是這么啟動(dòng)的哦！~

補(bǔ)充：Redis CLuster主備切換、故障轉(zhuǎn)移測(cè)試

redis版本5.0.5

測(cè)試redis Cluster主備切換、故障轉(zhuǎn)移

1.下線一個(gè)從節(jié)點(diǎn)，此時(shí)它的主節(jié)點(diǎn)打印的日志

集群狀態(tài)

2.下線一臺(tái)主節(jié)點(diǎn)，此時(shí)它的從節(jié)點(diǎn)打印的日志

集群狀態(tài)

測(cè)試主備切換時(shí)客戶端狀態(tài)

第一步：查看當(dāng)前集群狀態(tài)

可以看到六個(gè)節(jié)點(diǎn)都是可用狀態(tài)，其中83.46的6379是81.64上的6380的從節(jié)點(diǎn)，計(jì)劃Kill掉81.64上的6380主節(jié)點(diǎn)，然后觀察83.46的6379節(jié)點(diǎn)日志

第二步：kill掉81.64上的6380

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

此時(shí)查看集群的節(jié)點(diǎn)狀態(tài)如下，可以看到槽 5461-10922在這個(gè)主節(jié)點(diǎn)上，此時(shí)整個(gè)reidis集群處于不可用狀態(tài)

10:12:24：應(yīng)用程序報(bào)錯(cuò)，redis操作超時(shí)

10:11:43 ：在重連17次失敗次數(shù)之后，從節(jié)點(diǎn)將主節(jié)點(diǎn)標(biāo)記為失敗，并且整個(gè)集群的狀態(tài)切換為不可用，之后不甘心，又去嘗試連接主節(jié)點(diǎn)

10:12:03：在重連20次失敗后，從節(jié)點(diǎn)打印日志，等待投票選舉，但是沒有達(dá)到多數(shù)贊成，于是繼續(xù)重連之前的主節(jié)點(diǎn)

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

10:12:45：選舉成功勝出，成為了新的主節(jié)點(diǎn)，整個(gè)集群的狀態(tài)變?yōu)榭捎?/p>

10:13:39：大概一分鐘之后，redis客戶端自動(dòng)刷新了集群配置，成功連接上redis集群，此時(shí)主備切換和故障轉(zhuǎn)移完成

此前項(xiàng)目中存在的問題

redis master宕機(jī)之后，會(huì)出現(xiàn)應(yīng)用程序連接不上redis cluster的問題，需要重啟服務(wù)才能解決

排查原因之后發(fā)現(xiàn)是spring boot 2.x版本默認(rèn)使用了lettuce作為redis客戶端，而lettuce默認(rèn)是不開啟自動(dòng)刷新集群拓?fù)涞?，?dāng)redis master宕機(jī)并且集群完成故障轉(zhuǎn)移/主從切換之后，客戶端使用的還是之前錯(cuò)誤的集群信息，就會(huì)導(dǎo)致應(yīng)用程序一直連接不上redis集群。解決方案就是修改redis客戶端配置，開啟開啟自適應(yīng)刷新拓?fù)?/p>

配置文件如下

spring.redis.cluster.nodes=${redis.nodes}
spring.redis.password=${redis.pass}
spring.redis.timeout=60000
# 最大重定向次數(shù)
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連接工廠實(shí)現(xiàn)
     * LettuceConnectionFactory實(shí)現(xiàn)了RedisConnectionFactory接口
     * 這里要注意的是，在構(gòu)建LettuceConnectionFactory 時(shí)，如果不使用內(nèi)置的destroyMethod，可能會(huì)導(dǎo)致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 開啟自適應(yīng)刷新拓?fù)?nbsp;包括線程池配置和安全項(xiàng)配置
     *
     * @param genericObjectPoolConfig common-pool2線程池
     * @return lettuceClientConfiguration
     */
    private LettuceClientConfiguration getLettuceClientConfiguration(GenericObjectPoolConfig genericObjectPoolConfig) {
        /*
        ClusterTopologyRefreshOptions配置用于開啟自適應(yīng)刷新和定時(shí)刷新。如自適應(yīng)刷新不開啟，Redis集群變更時(shí)將會(huì)導(dǎo)致連接異常！
         */
        ClusterTopologyRefreshOptions topologyRefreshOptions = ClusterTopologyRefreshOptions.builder()
                //開啟自適應(yīng)刷新
                //.enableAdaptiveRefreshTrigger(ClusterTopologyRefreshOptions.RefreshTrigger.MOVED_REDIRECT, ClusterTopologyRefreshOptions.RefreshTrigger.PERSISTENT_RECONNECTS)
                //開啟所有自適應(yīng)刷新，MOVED，ASK，PERSISTENT都會(huì)觸發(fā)
                .enableAllAdaptiveRefreshTriggers()
                // 自適應(yīng)刷新超時(shí)時(shí)間(默認(rèn)30秒)
                .adaptiveRefreshTriggersTimeout(Duration.ofSeconds(25)) //默認(rèn)關(guān)閉開啟后時(shí)間為30秒
                // 開周期刷新
                .enablePeriodicRefresh(Duration.ofSeconds(20))  // 默認(rèn)關(guān)閉開啟后時(shí)間為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();
    }
}

看完上述內(nèi)容是否對(duì)您有幫助呢？如果還想對(duì)相關(guān)知識(shí)有進(jìn)一步的了解或閱讀更多相關(guān)文章，請(qǐng)關(guān)注億速云行業(yè)資訊頻道，感謝您對(duì)億速云的支持。