Redis项目实战 .net StackExchange.Redis

//
// 摘要:
//     Create a new ConnectionMultiplexer instance
public static ConnectionMultiplexer Connect(string configuration, TextWriter log = null);
//
// 摘要:
//     Create a new ConnectionMultiplexer instance
public static ConnectionMultiplexer Connect(ConfigurationOptions configuration, TextWriter log = null);

//
// 摘要:
//     Provides a way of overriding the default Task Factory. If not set, it will use
//     the default Task.Factory. Useful when top level code sets it‘s own factory which
//     may interfere with Redis queries.
public static TaskFactory Factory { get; set; }
//
// 摘要:
//     Gets the client-name that will be used on all new connections
public string ClientName { get; }
//
// 摘要:
//     Gets the configuration of the connection
public string Configuration { get; }
//
// 摘要:
//     Should exceptions include identifiable details? (key names, additional .Data
//     annotations)
public bool IncludeDetailInExceptions { get; set; }
//
// 摘要:
//     Should exceptions include performance counter details? (CPU usage, etc - note
//     that this can be problematic on some platforms)
public bool IncludePerformanceCountersInExceptions { get; set; }
//
// 摘要:
//     Indicates whether any servers are connected
public bool IsConnected { get; }
//
// 摘要:
//     The number of operations that have been performed on all connections
public long OperationCount { get; }
//
// 摘要:
//     Gets or sets whether asynchronous operations should be invoked in a way that
//     guarantees their original delivery order
public bool PreserveAsyncOrder { get; set; }
//
// 摘要:
//     Limit at which to start recording unusual busy patterns (only one log will be
//     retained at a time; set to a negative value to disable this feature)
public int StormLogThreshold { get; set; }
//
// 摘要:
//     Gets the timeout associated with the connections
public int TimeoutMilliseconds { get; }

//
// 摘要:
//     Raised when configuration changes are detected
public event EventHandler<EndPointEventArgs> ConfigurationChanged;
//
// 摘要:
//     Raised when nodes are explicitly requested to reconfigure via broadcast; this
//     usually means master/slave changes
public event EventHandler<EndPointEventArgs> ConfigurationChangedBroadcast;
//
// 摘要:
//     Raised whenever a physical connection fails
public event EventHandler<ConnectionFailedEventArgs> ConnectionFailed;
//
// 摘要:
//     Raised whenever a physical connection is established
public event EventHandler<ConnectionFailedEventArgs> ConnectionRestored;
//
// 摘要:
//     A server replied with an error message;
public event EventHandler<RedisErrorEventArgs> ErrorMessage;
//
// 摘要:
//     Raised when a hash-slot has been relocated
public event EventHandler<HashSlotMovedEventArgs> HashSlotMoved;
//
// 摘要:
//     Raised whenever an internal error occurs (this is primarily for debugging)
public event EventHandler<InternalErrorEventArgs> InternalError;

ConfigurationOptions config = new ConfigurationOptions() {
    //是一个列表，一个复杂的的场景中可能包含有主从复制 ， 对于这种情况，只需要指定所有地址在连接字符串中
    //（它将会自动识别出主服务器）假设这里找到了两台主服务器，将会对两台服务进行裁决选出一台作为主服务器
    //来解决这个问题 ， 这种情况是非常罕见的 ，我们也应该避免这种情况的发生。
    EndPoints = { { "127.0.0.1", 11111 }, { "127.0.0.1", 12111 } }
};
//服务器秘密
config.Password = "123456";
//客户端名字
config.ClientName = "127.0.0.1";
//服务器名字
config.ServiceName = "127.0.0.1";
//true表示管理员身份，可以用一些危险的指令。
config.AllowAdmin = true;
//获取或设置是否应该通过TimeoutException显式通知连接 / 配置超时。
config.AbortOnConnectFail = true;
//你可以禁用或者重命名一个命令。   配置文件里面也可以配置， 对于敏感的命令做处理（比如说清空整个库  config这种命令）。
config.CommandMap = null;
//每n秒检查配置(默认情况下每分钟)
config.ConfigCheckSeconds = 60;
//如果没有服务器及时响应，重复初始连接周期的次数。
config.ConnectRetry = 1;
//超时时间       指定应该允许连接的毫秒数(默认为5秒，除非SyncTimeout更高)
config.ConnectTimeout = 5;
//默认0到-1          指定要使用的默认数据库当调用ConnectionMultiplexer.GetDatabase()没有任何参数
//config.DefaultDatabase = 1;
//版本号
config.DefaultVersion = new Version(2, 8, 8);
//使用ThreadPriority。对于SocketManager阅读器和写入器线程(默认情况下是正确的)来说，这是正常的。如果错误,ThreadPriority。将使用正常。
//config.HighPrioritySocketThreads = true;
//保存x秒的活动连接
config.KeepAlive = 180;
//代理 枚举类型           http://blog.csdn.net/u010601183/article/details/54426289
config.Proxy = Proxy.Twemproxy;

//准备过程
//1 http://www.cnblogs.com/wudequn/p/8109798.html  页面中有下载主从哨兵配置文件（页面搜索文字   redis哨兵配置下载   ） 并搭redis主从 哨兵。
//2 运行代码测试

public static IConnectionMultiplexer RedisConnect;
public static IDatabase DefaultDB;
public static ISubscriber sentinelsub;
private static ConnectionMultiplexer _sentinel;

/// <summary>
/// 创建redis连接
/// </summary>
/// <param name="sender"></param>
/// <param name="e"></param>
private void button1_Click(object sender, EventArgs e)
{
    ConfigurationOptions config = new ConfigurationOptions()
    {
        //是一个列表，一个复杂的的场景中可能包含有主从复制 ， 对于这种情况，只需要指定所有地址在连接字符串中
        //（它将会自动识别出主服务器 set值得时候用的主服务器）假设这里找到了两台主服务器，将会对两台服务进行裁决选出一台作为主服务器
        //来解决这个问题 ， 这种情况是非常罕见的 ，我们也应该避免这种情况的发生。
        //
        EndPoints = { { "127.0.0.1", 11111 }, { "127.0.0.1", 12111 }, { "127.0.0.1", 13111 } }
    };
    //服务器秘密
    config.Password = "123456";
    //客户端名字
    config.ClientName = "127.0.0.1";
    //服务器名字
    config.ServiceName = "127.0.0.1";
    //true表示管理员身份，可以用一些危险的指令。
    config.AllowAdmin = true;
    RedisConnect = ConnectionMultiplexer.Connect(config);
    DefaultDB = RedisConnect.GetDatabase();
    Console.WriteLine("---------------------------Redis主从连接实例创建---------------------------");
    Console.WriteLine(RedisConnect.GetStatus());
    Console.WriteLine("---------------------------------------------------------------------------");
}

/// <summary>
/// 监控哨兵主从切换
/// </summary>
/// <param name="sender"></param>
/// <param name="e"></param>
private void button2_Click(object sender, EventArgs e)
{
    ConfigurationOptions sentineloption = new ConfigurationOptions();
    sentineloption.TieBreaker = "";//sentinel模式一定要写

    //三个哨兵
    sentineloption.EndPoints.Add("127.0.0.1", 11121);
    sentineloption.EndPoints.Add("127.0.0.1", 11131);
    sentineloption.EndPoints.Add("127.0.0.1", 11141);

    //哨兵连接模式
    sentineloption.CommandMap = CommandMap.Sentinel;
    sentineloption.ServiceName = "mymaster";
    //我们可以成功的连接一个sentinel服务器，对这个连接的实际意义在于：当一个主从进行切换后，如果它外层有Twemproxy代理，我们可以在这个时机（+switch-master事件)通
Twemproxy代理服务器，并更新它的配置文件里的master服务器的地址，然后从起你的Twemproxy服务，这样你的主从切换才算真正完成。
    //一般没有代理服务器，直接更改从数据库配置文件，将其升级为主数据库。
    _sentinel = ConnectionMultiplexer.Connect(sentineloption);
    sentinelsub = _sentinel.GetSubscriber();

    sentinelsub.Subscribe("+switch-master", (ch, mg) =>
    {
        Console.WriteLine((string)mg);
    });
}

/// <summary>
/// 读写测试
/// </summary>
/// <param name="sender"></param>
/// <param name="e"></param>
private void button3_Click(object sender, EventArgs e)
{
    //读写数据
    string key = "WYX";
    string value = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss fff");
    //默认写入主库。
    DefaultDB.StringSet(key, value);
    Console.WriteLine($"写入成功Key{key}:Value{value}");
    Thread.Sleep(2000);
    //CommandFlags.PreferSlave参数表示读取从库数据   貌似是随机你从不同的slave中读取的。


    //关注问题：https://github.com/StackExchange/StackExchange.Redis/issues/593
    //关注问题：https://github.com/StackExchange/StackExchange.Redis/issues/547
    var getvalue = DefaultDB.StringGet(key,CommandFlags.PreferSlave);
    Console.WriteLine($"写入读取Key{key}:Value{getvalue}");
}

private void button4_Click(object sender, EventArgs e)
{
    Console.WriteLine("这样redis就落地了，读写分离。");
}