一、引用dll
using StackExchange.Redis;
二、config配制連接
<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;}
四、redis讀寫刪操作
#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
五、redis發(fā)布訂閱
#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
閱讀原文：原文鏈接
該文章在 2025/1/7 11:47:56 編輯過
400 186 1886
