1redis-cli -h redis-redis-ha -p 26479

1$ kubectl get po | grep redis
2
3NAME                                                     READY   STATUS      RESTARTS   AGE
4redis-1-redis-ha-server-0                                3/3     Running     0          3d4h
5redis-1-redis-ha-server-1                                3/3     Running     0          3d5h
6redis-1-redis-ha-server-2                                3/3     Running     0          3d4h

 1sentinel:
 2  port: 26379
 3  quorum: 2
 4  config:
 5    ## Additional sentinel conf options can be added below. Only options that
 6    ## are expressed in the format simialar to 'sentinel xxx mymaster xxx' will
 7    ## be properly templated.
 8    ## For available options see http://download.redis.io/redis-stable/sentinel.conf
 9    down-after-milliseconds: 10000
10    ## Failover timeout value in milliseconds
11    failover-timeout: 180000
12    parallel-syncs: 5
13
14  ## Custom sentinel.conf files used to override default settings. If this file is
15  ## specified then the sentinel.config above will be ignored.
16  # customConfig: |-
17      # Define configuration here
18
19  resources: {}
20  #  requests:
21  #    memory: 200Mi
22  #    cpu: 100m
23  #  limits:
24  #    memory: 200Mi

1kubectl logs -f redis-1-redis-ha-server-0
2
3kubectl delete po redis-1-redis-ha-server-1

 1# 使用 kubectl 連入，多個 container 要明確指出連入的 container
 2kubectl exec -it redis-1-redis-ha-server-0 --container redis sh
 3
 4redis-cli -h redis-redis-ha -p 26479
 5
 6# 近來先 ping 一下
 7$ ping
 8PONG
 9
10# 列出所有 master 的資訊，以及設定資訊
11sentinel master
12redis-2-redis-ha:26379> sentinel masters
131)  1) "name"
14    2) "mymaster"
15    3) "ip"
16    4) "10.15.242.245"
17    5) "port"
18    6) "6379"
19    7) "runid"
20    8) "63a97460b7c3745577931dad406df9609c4e2464"
21    9) "flags"
22   10) "master"
23   11) "link-pending-commands"
24   12) "0"
25   13) "link-refcount"
26   14) "1"
27   15) "last-ping-sent"
28   16) "0"
29   17) "last-ok-ping-reply"
30   18) "479"
31   19) "last-ping-reply"
32   20) "479"
33   21) "down-after-milliseconds"
34   22) "5000"
35   23) "info-refresh"
36   24) "5756"
37   25) "role-reported"
38   26) "master"
39   27) "role-reported-time"
40   28) "348144787"
41   29) "config-epoch"
42   30) "13"
43   31) "num-slaves"
44   32) "2"
45   33) "num-other-sentinels"
46   34) "2"
47   35) "quorum"
48   36) "2"
49   37) "failover-timeout"
50   38) "180000"
51   39) "parallel-syncs"
52   40) "5"
53
54# 取得集群中的 master 訊息，目前有一個 master
55$ sentinel master mymaster
56
57# 取得集群中的 slaves 訊息，目前有兩個 slave
58$ sentinel slaves mymaster
59
60# 取得集群中的 master 訊息
61$ sentinel sentinels mymaster
62
63# 檢查 sentinel 的 quorum
64$ sentinel ckquorum mymaster
65
66OK 3 usable Sentinels. Quorum and failover authorization can be reached
67
68# 強迫觸發一次 failover
69sentinel failover mymaster

 1# 使用獨立的 pod service 連入 sentinel，協助彼此識別
 2sntnl := &sentinel.Sentinel{
 3	Addrs:      []string{"redis-2-redis-ha-announce-0:26379", "redis-2-redis-ha-announce-0:26379", "redis-2-redis-ha-announce-0:26379"},
 4	MasterName: "mymaster",
 5	Dial: func(addr string) (redis.Conn, error) {
 6		timeout := 500 * time.Millisecond
 7		c, err := redis.DialTimeout("tcp", addr, timeout, timeout, timeout)
 8		if err != nil {
 9			return nil, err
10		}
11		return c, nil
12	},
13}
14
15# 產生 connection pool
16return &redis.Pool{
17	MaxIdle:     3,
18	MaxActive:   64,
19	Wait:        true,
20	IdleTimeout: 240 * time.Second,
21	Dial: func() (redis.Conn, error) {
22
23    # 透過 sentinel 取得 master address，如果 master 死了，再執行可以拿到新的 master
24		masterAddr, err := sntnl.MasterAddr()
25		if err != nil {
26			return nil, err
27		}
28		c, err := redis.Dial("tcp", masterAddr)
29		if err != nil {
30			return nil, err
31		}
32		return c, nil
33	},
34	TestOnBorrow: func(c redis.Conn, t time.Time) error {
35		if !sentinel.TestRole(c, "master") {
36			return errors.New("Role check failed")
37		} else {
38			return nil
39		}
40	},
41}