redis StackExchange 主备 实现 demo

网上关于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());
            }
        }
    }

View Code