摘要：一、引用dllusingStackExchange.Redis;二、config配制连接三、建立连接privatestaticConnectionMultip
一、引用dll
using StackExchange.Redis;二、config配制连接
三、建立连接
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 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发布订阅
#region Redis发布订阅public delegate void RedisDeletegate(string str);public event RedisDeletegate RedisSubMessageEvent;/// /// 订阅/// /// public void RedisSub(string subChannel){ redis.GetSubscriber.Subscribe(subChannel, (channel, message) => { RedisSubMessageEvent?.Invoke(message); //触发事件 });}/// /// 发布/// /// /// /// /// public long RedisPub(string channel, T msg){ return redis.GetSubscriber.Publish(channel, msg.ToString);}/// /// 取消订阅/// /// public void Unsubscribe(string channel){ redis.GetSubscriber.Unsubscribe(channel);}/// /// 取消全部订阅/// public void UnsubscribeAll{ redis.GetSubscriber.UnsubscribeAll;}#endregion来源：瞎搞制作
免责声明：本站系转载，并不代表本网赞同其观点和对其真实性负责。如涉及作品内容、版权和其它问题，请在30日内与本站联系，我们将在第一时间删除内容!