using StackExchange.Redis;

<appSettings>  <add key="RedisConnectionString" value="192.168.200.84:6379,password=123456,abortConnect=false" /></appSettings>

private static ConnectionMultiplexer redis = null;private static bool connected = false;private IDatabase db = null;private int current = 0;public static bool IsConnected { get { Open(); return redis.IsConnected; } }private static Configuration config = new Configuration();private static int Open(){	if (connected) return 1;	redis = ConnectionMultiplexer.Connect(config.GetAppSetting("RedisConnectionString"));	connected = true;	return 1;}public static void Using(Action<Redis> a){	using (var red = new Redis())	{		a(red);	}}public Redis Use(int i){	Open();	current = i;	db = redis.GetDatabase(i);	var t = db.Ping();	return this;}

#region Redis緩存public void Set(string key, string val, TimeSpan? ts = null){	db.StringSet(key, val, ts);}
public string Get(string key){	return db.StringGet(key);}
public void Remove(string key){	db.KeyDelete(key, CommandFlags.HighPriority);}
public bool Exists(string key){	return db.KeyExists(key);}
public void Dispose(){	db = null;}#endregion

#region Redis發(fā)布訂閱public delegate void RedisDeletegate(string str);public event RedisDeletegate RedisSubMessageEvent;
/// <summary>/// 訂閱/// </summary>/// <param name="subChannel"></param>public void RedisSub(string subChannel){
	redis.GetSubscriber().Subscribe(subChannel, (channel, message) => {		RedisSubMessageEvent?.Invoke(message); //觸發(fā)事件	});
}
/// <summary>/// 發(fā)布/// </summary>/// <typeparam name="T"></typeparam>/// <param name="channel"></param>/// <param name="msg"></param>/// <returns></returns>public long RedisPub<T>(string channel, T msg){
	return redis.GetSubscriber().Publish(channel, msg.ToString());}
/// <summary>/// 取消訂閱/// </summary>/// <param name="channel"></param>public void Unsubscribe(string channel){	redis.GetSubscriber().Unsubscribe(channel);}
/// <summary>/// 取消全部訂閱/// </summary>public void UnsubscribeAll(){	redis.GetSubscriber().UnsubscribeAll();}#endregion