满怀忧思,不如先干再说! 主从复制出现的问题 上篇文章《Redis主从复制》中我们说到可以对Redis单节点数据进行备份实现Redis高可用,但是如果master节点宕机并不会自动做故障切换等,导致项目中更可能需要接入多数据源,编写代码实现故障切换非常麻烦,Redis考虑到这个问题提供了哨兵模式,也就是RedisSentinel! RedisSentinel基本架构 看图我们说一下RedisSentinel架构,首先我们需要加入Sentinel节点,Sentinel节点去监控Redis中Master和Slave的运行状态,判断是否可用,当然Sentinel节点也是有多个的,实现Sentinel节点的高可用和多节点判断Redis节点是否可用不会出现误判情况 客户端不再直接操作Redis的Master或者Slave节点,而是去访问Sentinel节点!所以我们的客户端会记录RedisSentinel的地址!我们的客户端不关心谁是Master而是Sentinel告诉客户端谁是Master,后台Master切换了,客户端也不会受到影响! 当多个sentinel发现并确认master出现问题,会选举出一个sentinel作为领导,选举出一个slave为新的master,通知其余的slave有新的master产生,通知客户端master发生变化,等待老的master复活成为新的master的slave! 一套sentinel可以同时监控多套master和slave!节省资源!每套masterslave会有一个mastername作为标识以示区别 安装和配置 集群规划 配置开启主从节点,一个master端口号为7000,两个slave节点分别问7001和7002;配置开启sentinel监控主节点。(sentinel是特殊的redis节点,不存储数据),三个sentinel分别为26379,26380,26381; 配置描述 master port7000daemonizeyespidfilevarrunredisredis7000。pidlogfile7000。logdirusrlocalredis5。0。5data slave7001 命令:seds70007001gredis7000。confredis7001。conf 将7000替换为7001 命令:echoslaveofstt1017000redis7001。conf 重定向slaveofstt1017000到redis7001。conf文件末尾 port7001daemonizeyespidfilevarrunredisredis7001。pidlogfile7001。logdirusrlocalredis5。0。5dataslaveofstt1017000 slave7002 port7002daemonizeyespidfilevarrunredisredis7002。pidlogfile7002。logdirusrlocalredis5。0。5dataslaveofstt1017000 配置完之后启动三个节点查看主从关系: redisclip7000inforeplication sentinel主要配置 三台sentinel使用端口区别port{port}dirusrlocalredis5。0。5datalogfile{port}。log监控主节点名字为mymaster,ip,端口,2台sentinel认为master有问题就会故障转移sentinelmonitormymasteripport230000毫秒ping不通认为出现问题sentineldownaftermillisecondsmymaster30000选择了新的master之后老的slave会对新的slave进行复制,1代表每次只有一个slave进行复制,减轻master压力sentinelparallelsyncsmymaster1故障转移时间sentinelfailovertimeoutmymaster180000 注意:在redis的安装目录下有一个sentinel。conf文件就是sentinel的配置文件,我们将这个文件拷贝到conf目录下,去除注释等。给出一个26739的配置,其余的两台大家只需修改端口号了pid文件即可 第一台的配置port26379daemonizeyespidfilevarrunredisredissentinel26379。pidlogfile26379。logdirusrlocalredis5。0。5datastt101为ip映射sentinelmonitormymasterstt10170002sentineldownaftermillisecondsmymaster30000sentinelparallelsyncsmymaster1sentinelfailovertimeoutmymaster180000protectedmodeno通过该命令将sentinel。conf文件去掉注释和换行将内容放到redissentinel26739。conf文件中catsentinel。confgrepvgrepv34;redissentinel26739。conf启动redissentinelredissentinel26739。conf配置其他两台,三台配置是一样的,修改端口和日志文件,pid文件即可seds2637926380gredissentinel26379。confredissentinel26380。confseds2637926381gredissentinel26379。confredissentinel26381。conf 启动 使用redissentinel命令读取配置文件分别启动三台sentinel节点记得修改文件名哦redissentinelredissentinel26739。conf分别启动三台Redis节点redisserverredis6379。conf通过客户端连接上sentinel节点redisclih192。168。109。101p26379 这里大家注意一下:有些可能有疑问,上边端口不是7000吗下边咋变成6379了,搞咩啊,之前在写的时候,这里有一点小瑕疵,我直接重写了,端口号上下没有对应起来,这里声明一下,之前的7000,7001,7002分别对应下文的6379,6380,6381,如果没有发现问题,是不没认真看啊! 启动之后查看状态 大家看下边动图,名字为6379,6380,6381的为redis节点,名字为26379的为sentinel节点,演示节点状态和故障转移 首先在redissentinel下查看address是6381,说明其为主节点之后将6381kill掉,等待一段时间,这里时间大概在30S左右,这段时间我暂停了之后再查看info信息,发现address变为6380 SpringBoot集成RedisSentinel演示 这个思路也很简单,我们循环添加或者查询数据,将主节点手动宕机,查看日志打印是否成功切换继续读写数据即可,我们只需要修改application。yml配置文件即可 配置文件 spring:redis:host:192。168。109。101这是之前单机时的ip配置port:6379这个是单机时的端口配置,现在都不用写了sentinel:写sentinel节点的ip:portnodes:192。168。109。101:26379,192。168。109。102:26380,192。168。109。103:26381写sentinel节点的名字,因为sentinel可以有很多组,每一组使用名字区分master:mymastertimeout:2s连接池最大连接数(使用负值表示没有限制)maxactive:2000连接池最大阻塞等待时间(使用负值表示没有限制)maxwait:1ms连接池中的最大空闲连接maxidle:1024连接池中的最小空闲连接minidle:100 代码 添加数据Testpublicvoidtest7(){循环,添加数据for(inti0;i200;i){SStry{redisTemplate。opsForValue()。set(key,value);慢一点Thread。sleep(500);System。out。println(当前插入:keyvalue);}catch(InterruptedExceptione){e。printStackTrace();}catch(Exceptione){e。printStackTrace();}}System。out。println(数据插入完成);}查询数据Testpublicvoidtest8(){编写循环,添加数据for(inti0;i200;i){Stry{ObjectoredisTemplate。opsForValue()。get(key);慢一点Thread。sleep(500);System。out。println(当前获取:o);}catch(InterruptedExceptione){e。printStackTrace();}catch(Exceptione){e。printStackTrace();}}} 演示 这里我又将刚刚关闭的6381节点启动,三个节点提供服务,进行演示,一样的动图送给大家,这里只贴出插入数据的动图了,查询的类似,大家动手做一做试一下! 基本原理 由三个定时任务实现的切换 每10S一个info 每10秒每个sentinel节点会对master和slave发送一个info命令,一是为了发现slave节点,二是为了确认主从关系 每2秒交换信息 每2秒每个sentinel通过master节点的channel交换信息(pubsub),相当于一个sentinel的交互平台,交互对masterslave状态的监听情况和自身的信息。通过一个名为sentinel:hello的频道交互,每个sentinel节点都会订阅这个频道 每秒1ping 每一秒每个sentinel节点对其他sentinel和redis执行一次ping,这一步基于第一步sentinel掌握redis的master和slave节点的状况,基于第二步sentinel节点知道其他的sentinel节点,对他们进行心跳检测,判断是否在正常工作 收藏等于学会!别忘了点赞,关注哦,高频推出技术文章,有问题记得评论或者私信!