Redis 讲解系列之 Redis的主从复制(二)

怼烎@ 2022-06-07 06:53 193阅读 0赞

## **Redis 讲解系列之 Redis的主从复制(二)** ##

本章节我们将学习一下Redis 的Sentinel(哨兵模式)主从复制机制。  
参考文献：  
Redis Sentinel主从高可用方案：[http://wosyingjun.iteye.com/blog/2289593][http_wosyingjun.iteye.com_blog_2289593]。

## **Sentinel介绍** ##

Sentinel是Redis的高可用性（HA）解决方案，由一个或多个Sentinel实例组成的Sentinel系统可以监视任意多个主服务器，以及这些主服务器属下的所有从服务器，并在被监视的主服务器进行下线状态时，自动将下线主服务器属下的某个从服务器升级为新的主服务器，然后由新的主服务器代替已下线的主服务器继续处理命令请求。Redis提供的sentinel（哨兵）机制，通过sentinel模式启动redis后，自动监控master/slave的运行状态，基本原理是：心跳机制+投票裁决

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

--------------------

## **Sentinel的主从原理** ##

*  服务器与Sentinel系统
    
    ![这里写图片描述][SouthEast]
 *  主服务器下线
    
    ![这里写图片描述][SouthEast 1]
 *  故障转义(Sentinel机制选出新的Master)
    
    ![这里写图片描述][SouthEast 2]
 *  原来的M从新进入S-M Replication将自动降级为 S  
    ![这里写图片描述][SouthEast 3]
    
    之前介绍过为什么Jedis要用2.2.2及以上版本，因为主从实例地址(IP PORT)是不同的，当故障发生进行主从切换后，应用程序无法知道新地址，故在Jedis2.2.2中新增了对Sentinel的支持，应用通过 redis.clients.jedis.JedisSentinelPool.getResource()取得的Jedis实例会及时更新到新的主实例地址。

--------------------

## **Redis Sentinel配置** ##

*  S-M Replication
    
    2个哨兵，1个主redis，2个从redis的方式，配置文件如下：  
    ![这里写图片描述][SouthEast 4]
 *  基本配置(列出的是具体修改的项，其他配置信息请保持不变)
    
     *  sentinel\_63791.conf 配置
        
            port 63791
            daemonize yes
            logfile "/var/log/sentinel_63791.log"
            
            #master-1
            
            sentinel monitor master-1 192.168.78.99 6379 2
            sentinel down-after-milliseconds master-1 5000
            sentinel failover-timeout master-1 18000
            sentinel auth-pass master-1 yingjun
            sentinel parallel-syncs master-1 1
     *  sentinel\_63792.conf 配置
        
            port 63792
            daemonize yes
            logfile "/var/log/sentinel_63792.log"
            
            #master-1
            
            sentinel monitor master-1 192.168.78.99 6379 2
            sentinel down-after-milliseconds master-1 5000
            sentinel failover-timeout master-1 18000
            sentinel auth-pass master-1 yingjun
            sentinel parallel-syncs master-1 1
     *  redis\_master\_6379.conf 配置
        
            port 6379
            daemonize yes
            requirepass yingjun
            masterauth yingjun
     *  redis\_slave\_6380.conf 配置
        
            port 6380
            daemonize yes
            requirepass yingjun
            slaveof 192.168.78.99 6379
            masterauth yingjun
     *  redis\_slave\_6381.conf 配置
        
            port 6381
            daemonize yes
            requirepass yingjun
            slaveof 192.168.78.99 6379
            masterauth yingjun
 *  执行
    
        ./redis-server ../conf/redis_master_6379.conf
        ./redis-server ../conf/redis_slave_6381.conf    
        ./redis-server ../conf/redis_slave_6382.conf    
        ./redis-sentinel ../conf/sentinel_63791.conf
        ./redis-sentinel ../conf/sentinel_63792.conf
 *  检查
    
     *  查看进程
        
        ![这里写图片描述][SouthEast 5]
     *  查看master的状态
        
        ![这里写图片描述][SouthEast 6]
     *  查看slave的状态
        
        ![这里写图片描述][SouthEast 7]
     *  查看sentinel的状态
        
        ![这里写图片描述][SouthEast 8]
     *  接下来验证redis sentinel的主从切换
        
         *  首先关闭主redis（6379）服务（shutdown）。
         *  查看哨兵，发现端口号为6380的从服务变成了主服务,sentinel自动完成了故障切换。
        
        ![这里写图片描述][SouthEast 9]
        
         *  启动刚才被shutdown的6379服务并查看，发现它变成了从服务。
         *  ![这里写图片描述][SouthEast 10]

--------------------

## **Jedis Sentinel教程** ##

*  Maven依赖
    
        <dependency>
                <groupId>redis.clients</groupId>
                <artifactId>jedis</artifactId>
                <version>2.8.0</version>
            </dependency>
            
            <dependency>
                <groupId>org.springframework.data</groupId>
                <artifactId>spring-data-redis</artifactId>
                <version>1.6.4.RELEASE</version>
            </dependency>
 *  redis的配置文件
    
        #redis config
        
        redis.pass=yingjun
        redis.pool.maxTotal=105
        redis.pool.maxIdle=10
        redis.pool.maxWaitMillis=60000
        redis.pool.testOnBorrow=true
        
        sentinel1.ip=192.168.78.99
        sentinel1.port=63791
        
        sentinel2.ip=192.168.78.99
        sentinel2.port=63792
 *  Spring的配置文件
    
        
        <bean id="jedisPoolConfig" class="redis.clients.jedis.JedisPoolConfig">
            <property name="maxTotal" value="${redis.pool.maxTotal}" />
            <property name="maxIdle" value="${redis.pool.maxIdle}" />
            <property name="maxWaitMillis" value="${redis.pool.maxWaitMillis}" />
            <property name="testOnBorrow" value="${redis.pool.testOnBorrow}" />
        </bean>
        
        <bean id="sentinelConfiguration" class="org.springframework.data.redis.connection.RedisSentinelConfiguration">
            <property name="master">
                <bean class="org.springframework.data.redis.connection.RedisNode">
                    <property name="name" value="master-1"></property>
                </bean>
            </property>
            <property name="sentinels">
                <set>
                    <bean class="org.springframework.data.redis.connection.RedisNode">
                        <constructor-arg name="host" value="${sentinel1.ip}"></constructor-arg>
                        <constructor-arg name="port" value="${sentinel1.port}"></constructor-arg>
                    </bean>
                    <bean class="org.springframework.data.redis.connection.RedisNode">
                        <constructor-arg name="host" value="${sentinel2.ip}"></constructor-arg>
                        <constructor-arg name="port" value="${sentinel2.port}"></constructor-arg>
                    </bean>
                </set>
            </property>
        </bean>
        
        
        <bean id="jedisConnectionFactory" class="org.springframework.data.redis.connection.jedis.JedisConnectionFactory">
            <property name="password" value="${redis.pass}"></property>
            <property name="poolConfig" >
                <ref bean="jedisPoolConfig"/>
            </property>
            <constructor-arg name="sentinelConfig" ref="sentinelConfiguration"></constructor-arg>
        </bean>
        
        
        <bean id="redisTemplate" class="org.springframework.data.redis.core.StringRedisTemplate">
            <property name="connectionFactory" ref="jedisConnectionFactory" />
        </bean>
 *  代码中直接用redisTemplate调用
    
        @Override
            public boolean add(final KeyToken tkey) {
                boolean result = redisTemplate.execute(new RedisCallback<Boolean>() {
        
                    @Override
                    public Boolean doInRedis(RedisConnection connection) throws DataAccessException {
                        RedisSerializer<String> serializer = getRedisSerializer();
                        byte[] key = serializer.serialize(tkey.getIndex());
                        byte[] name = serializer.serialize(tkey.getExpire_time());
                        return connection.setNX(key, name);
                    }
        
                });
                return result;
            }

[http_wosyingjun.iteye.com_blog_2289593]: http://wosyingjun.iteye.com/blog/2289593
[SouthEast]: /images/20220607/98b29af5f4524ba587f9e3b590ff932c.png
[SouthEast 1]: /images/20220607/e9c668b5677a4a708ff08a75bb62dace.png
[SouthEast 2]: /images/20220607/0355a1bcea2f49b1a9951ceb1a7fabf7.png
[SouthEast 3]: /images/20220607/6564c043beee4f73a86ff9fda1effdd9.png
[SouthEast 4]: /images/20220607/343cf80b83f14c558e43e0edbc31939c.png
[SouthEast 5]: /images/20220607/cf13f254304b41e3a610a196e2cf9fa4.png
[SouthEast 6]: /images/20220607/cbe9735ad5ff47c89fbcabd78cc259b2.png
[SouthEast 7]: /images/20220607/84b4baedc9754725bbf6e064ca042b43.png
[SouthEast 8]: /images/20220607/f512d961870a4a93a50a4ea4ca7f23bf.png
[SouthEast 9]: /images/20220607/6d0884ecfeaf48c7b4fddcd05611cf2a.png
[SouthEast 10]: /images/20220607/d69f9984f62749e49ad9811338ceb46c.png