Redis哨兵

Redis Sentinel基本架构

多个sentinel发现并确认master有问题
选举出一个sentinel作为领导
选出一个salve作为master
通知其余slave成为新的master的slave
通知客户端主从变化
等待master复活成为新的master的slave

安装与配置

配置开启主从节点
配置开启sentinel监控master节点

Redis主节点
启动redis-server redis-7000.conf

redis配置:

主节点:

port 7000
daemonize yes
pidfile /var/run/redis/7000.pid
logfile 7000.log
dir "${redis-src}/data/"

从节点:

port 7001
daemonize yes
pidfile /var/run/redis/7001.pid
logfile 7001.log
dir "${redis-src}/data/"
slaveof 127.0.0.1 7000

port 7002
daemonize yes
pidfile /var/run/redis/7002.pid
logfile 7002.log
dir "${redis-src}/data/"
slaveof 127.0.0.1 7000

sentinel配置:

port ${port}
dir "${redis-src}/data/"
logfile ${port}.log
sentinel monitor mymaster 127.0.0.1 7000 2 #监控主节点的名字 2对应当两个sentinel发现主节点有问题就发生故障转移
sentinel down-after-millisenconds mymaster 30000 #ping30秒后不通认为有问题
sentinel parallel-sync mymaster 1
sentinel failover-timeout mymaster 180000

安装演示

配置redis

单机演示实际为能相互ping通的多台机器

1：创建master节点配置

2：创建7000,7001节点配置

3：查看主从状态

到此为止主从的配置搭建完毕了

配置sentinel

通过官方提供的配置模板导入sentinel配置

配置信息：

查看Sentinel监控状态：

到此我们可以发现Sentinel已经检测到了matser节点的主从信息，由于我们只启动一个Sentinel所以Sentinel发现的数目为1

再去看看redis-sentinel-26379.conf的变化:

发现他已经把7000的两个slave节点的信息配置自动写入到了配置文件中

生成另外两个Sentinel配置

查看sentinel状态

发现26380的Sentinel并没有发现其他节点

查看原因：

1
2
3

cat /var/log/redis/26379.log
cat /var/log/redis/26380.log
cat /var/log/redis/26381.log

我们发现三个节点的pid都是一样的，所以需要配置pid
编辑26379,26380,26381.conf 去掉配置文件自动生成的myid,并加入

1
2
3

pidfile "/var/run/redis/redis-sentinel-26379.pid"
pidfile "/var/run/redis/redis-sentinel-26380.pid"
pidfile "/var/run/redis/redis-sentinel-26381.pid"

状态已正常

go客户端

package main

import (
	"fmt"
	"github.com/gomodule/redigo/redis"
	"github.com/letsfire/redigo"
	"github.com/letsfire/redigo/mode"
	"github.com/letsfire/redigo/mode/sentinel"
	"strconv"
	"time"
	"log"
)

func main(){
	var (
		i int
		sentinelMode mode.IMode
	)
	sentinelMode = sentinel.New(
		sentinel.Addrs([]string{"127.0.0.1:26379", "127.0.0.1:26380", "127.0.0.1:26381"}),
		sentinel.PoolOpts(
			mode.MaxActive(20),       // 最大连接数，默认0无限制
			mode.MaxIdle(0),         // 最多保持空闲连接数，默认2*runtime.GOMAXPROCS(0)
			mode.Wait(false),        // 连接耗尽时是否等待，默认false
			mode.IdleTimeout(0),     // 空闲连接超时时间，默认0不超时
			mode.MaxConnLifetime(0), // 连接的生命周期，默认0不失效
			mode.TestOnBorrow(nil),  // 空间连接取出后检测是否健康，默认nil
		),
		sentinel.DialOpts(
			redis.DialReadTimeout(time.Second),    // 读取超时，默认time.Second
			redis.DialWriteTimeout(time.Second),   // 写入超时，默认time.Second
			redis.DialConnectTimeout(time.Second), // 连接超时，默认500*time.Millisecond
			redis.DialPassword(""),                // 鉴权密码，默认空
			redis.DialDatabase(0),                 // 数据库号，默认0
			redis.DialKeepAlive(time.Minute*5),    // 默认5*time.Minute
			redis.DialNetDial(nil),                // 自定义dial，默认nil
			redis.DialUseTLS(false),               // 是否用TLS，默认false
			redis.DialTLSSkipVerify(false),        // 服务器证书校验，默认false
			redis.DialTLSConfig(nil),              // 默认nil，详见tls.Config
		),
		// 连接哨兵配置，用法于sentinel.DialOpts()一致
		// 默认未配置的情况则直接使用sentinel.DialOpts()的配置
		// sentinel.SentinelDialOpts()
	)

	var instance = redigo.New(sentinelMode)

	for  {
		res, err := instance.String(func(c redis.Conn) (res interface{}, err error) {
			return c.Do("set", "test" + strconv.Itoa(i), i)
		})
		if err != nil {
			log.Println(err)
		} else {
			fmt.Println(res)
		}
		i++
		time.Sleep(1 * time.Second)
	}
}