配置Redis的Sentinel模式

 1 #TwRedis(同一个Sentinel可以同时监听多个Master服务器)
 2 #设置要监听的服务器名称 IP和端口,最后一个2表示至少要两个 Sentinel服务器判定 Master失效 才会执行自动故障迁移
 3 sentinel monitor TwRedis 127.0.0.1 6001 2 
 4 #指定了Sentinel认为Redis实例已经失效所需的毫秒数
 5 sentinel down-after-milliseconds TwRedis 10000
 7 #指定了在执行故障转移时，最多可以有多少个从Redis实例在同步新的主实例，
 8 #在从Redis实例较多的情况下这个数字越小，同步的时间越长，完成故障转移所需的时间就越长
 8 sentinel config-epoch TwRedis 1
 9 #指定Sentinel运行的端口
10 port 5001　

 1  public class RedisConnectionManager
 2     {
 3         /// <summary>
 4         /// redis配置文件信息
 5         /// </summary>
 6         private static RedisConfig redisConfig = RedisConfig.GetConfig();
 7 
 8         private static readonly object Locker = new object();
 9         private static ConnectionMultiplexer _instance;
10 
11         /// <summary>
12         /// 单例获取
13         /// </summary>
14         public static ConnectionMultiplexer Instance
15         {
16             get
17             {
18                 if (_instance == null)
19                 {
20                     lock (Locker)
21                     {
22                         if (_instance == null || !_instance.IsConnected)
23                         {
24                             _instance = GetManager();
25                         }
26                     }
27                 }
28                 return _instance;
29             }
30         }
31 
32         private static ConnectionMultiplexer GetManager()
33         {
34             #region 设置Redis集群
35             ConfigurationOptions option = new ConfigurationOptions
36             {
37                 ServiceName = redisConfig.ServerName,
38                 Proxy = Proxy.Twemproxy,
39                 AbortOnConnectFail = true,
40                 AllowAdmin = true,
41             };
42             redisConfig.MasterHosts.Split(‘,‘).ToList().ForEach(item =>
43             {
44                 option.EndPoints.Add(item);
45             });
46             var connect = ConnectionMultiplexer.Connect(option);
47             #endregion
48 
49 
50             #region 设置Sentinel集群
51             if (string.IsNullOrEmpty(redisConfig.SentinelHosts))
52             {
53                 ConfigurationOptions sentinelConfig = new ConfigurationOptions();
54                 sentinelConfig.ServiceName = redisConfig.ServerName;
55                 redisConfig.SentinelHosts.Split(‘,‘).ToList().ForEach(item =>
56                 {
57                     sentinelConfig.EndPoints.Add(item);
58                 });
59                 sentinelConfig.TieBreaker = "";//这行在sentinel模式必须加上
60                 sentinelConfig.CommandMap = CommandMap.Sentinel;
61                 sentinelConfig.DefaultVersion = new Version(3, 0);
62                 ConnectionMultiplexer conn = ConnectionMultiplexer.Connect(sentinelConfig);
63                 conn.GetSubscriber().Subscribe("+switch-master", (channel, message) =>
64                 {
65                     Console.WriteLine((string)message);
66                 });
67             } 
68             #endregion
69 
70             return connect;
71         }
72 
73     }