网上关于redis高可用基本都是用redis-sentinel 哨兵 或者 redis cluster 集群来实现， 但是有没有更简单的方式，比如我现在就只有2个redis实例。我试验的结果是我们可用采用主备的方式来实现（我们的实际需求很简单，有2个redis实例分布在不同的计算机，在一个实例down掉后我们的应用程序有继续读写redis，主从配置可用手动修改）。需求很简单， 实现也就很简单。首先下载 https://github.com/StackExchange/StackExchange.Redis 源码。启动StackExchange.Redis-master\Redis Configs里面的主从2个实例，我最终demo的code如下：
class Program { static IDatabase database; static ConnectionMultiplexer conn; static void Main(string[] args) { ConfigurationOptions option = new ConfigurationOptions() { EndPoints = { { "127.0.0.1", 6379 }, { "127.0.0.1", 6380 } }, AllowAdmin =true, }; conn = ConnectionMultiplexer.Connect(option); database = conn.GetDatabase(); Random rand = new Random(); while (true) { string val = "gavin_" + rand.Next(1, 999999).ToString(); TestWriteRead(val); Thread.Sleep(100); } } static void TestWriteRead(string value) { string key = "gavinteststring"; try { database.StringSet(key, value); Console.WriteLine($"写入{key}={value}成功"); } catch (Exception ex) { var points = conn.GetEndPoints(); foreach (var item in points) { var server = conn.GetServer(item); if (server.IsConnected) { server.MakeMaster(ReplicationChangeOptions.All); } else { server.SlaveOf(points[1],CommandFlags.FireAndForget); } } database.StringSet(key, value); Console.WriteLine($"写入{key}={value}成功"); //Console.WriteLine($"写入{key}={value}失败:"+ex.ToString()); // Console.ReadKey(); } string temp = string.Empty; try { temp=database.StringGet(key); Console.WriteLine($"读取{key}={temp}成功"); } catch (Exception ex) { Console.WriteLine($"读取{key}失败:" + ex.ToString()); } } }
大家请先忽略我catch里面的code，当我把redis的master关闭后，程序报错：
No connection is available to service this operation: SET gavinteststring; 远程主机强迫关闭了一个现有的连接。; IOCP: (Busy=0,Free=1000,Min=4,Max=1000), WORKER: (Busy=0,Free=1023,Min=4,Max=1023), Local-CPU: 100%
找到源码后发现在ConnectionMultiplexer的ExecuteSyncImpl方法里面有这么一段：
if (!TryPushMessageToBridge(message, processor, source, ref server))
{
throw ExceptionFactory.NoConnectionAvailable(IncludeDetailInExceptions, message.Command, message, server, GetServerSnapshot());
}
也就是说StackExchange没有找到redis的服务器实例，继续跟踪code发现具体查找server的code在ConnectionMultiplexer的AnyConnected方法里面：
internal ServerEndPoint AnyConnected(ServerType serverType, uint startOffset, RedisCommand command, CommandFlags flags) { var tmp = serverSnapshot; int len = tmp.Length; ServerEndPoint fallback = null; for (int i = 0; i < len; i++) { var server = tmp[(int)(((uint)i + startOffset) % len)]; if (server != null && server.ServerType == serverType && server.IsSelectable(command)) { if (server.IsSlave) { switch (flags) { case CommandFlags.DemandSlave: case CommandFlags.PreferSlave: return server; case CommandFlags.PreferMaster: fallback = server; break; } } else { switch (flags) { case CommandFlags.DemandMaster: case CommandFlags.PreferMaster: return server; case CommandFlags.PreferSlave: fallback = server; break; } } } } return fallback; }
因为主的server已经down掉了，所以可用访问的server就是Slave，但是这里的flags默认是CommandFlags.DemandMaster。所以是找不到server。那么我们把现在的从的server改为主的server如： server.MakeMaster(ReplicationChangeOptions.All); 我以为就可以了，但是还是不行。 后来我想 如果我把主的也改为从是否可以了 server.SlaveOf(points[1],CommandFlags.FireAndForget);（我测试的时候还用过quit方法，调试有，但是release的时候说没有该方法）。
redis StackExchange 主备 实现 demo
原文：http://www.cnblogs.com/majiang/p/6476823.html
