123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962 |
- using System;
- using System.Collections.Generic;
- using System.Linq;
- using System.Text;
- using System.Threading.Tasks;
- using Newtonsoft.Json;
- using StackExchange.Redis;
- namespace ProjectBase.Data.Redis
- {
- public class RedisHelper
- {
- private int DbNum { get; set; } // 数据库连接数量
- private readonly ConnectionMultiplexer _conn;
- public string CustomKey;
- #region 构造函数
- public RedisHelper(int dbNum = 0)
- : this(dbNum, null)
- {
- }
- public RedisHelper(int dbNum, string readWriteHosts)
- {
- DbNum = dbNum;
- _conn =
- string.IsNullOrWhiteSpace(readWriteHosts) ?
- RedisConnection.Instance :
- RedisConnection.GetConnectionMultiplexer(readWriteHosts);
- }
- #endregion 构造函数
- #region String
- #region 同步方法
- /// <summary>
- /// 保存单个key value
- /// </summary>
- /// <param name="key">Redis Key</param>
- /// <param name="value">保存的值</param>
- /// <param name="expiry">过期时间</param>
- /// <returns></returns>
- public bool SetString(string key, string value, TimeSpan? expiry = default(TimeSpan?))
- {
- key = AddSysCustomKey(key);
- return Do(db => db.StringSet(key, value, expiry));
- }
- /// <summary>
- /// 保存多个key value
- /// </summary>
- /// <param name="keyValues">键值对</param>
- /// <returns></returns>
- public bool SetString(List<KeyValuePair<RedisKey, RedisValue>> keyValues)
- {
- List<KeyValuePair<RedisKey, RedisValue>> newkeyValues =
- keyValues.Select(p => new KeyValuePair<RedisKey, RedisValue>(AddSysCustomKey(p.Key), p.Value)).ToList();
- return Do(db => db.StringSet(newkeyValues.ToArray()));
- }
- /// <summary>
- /// 保存一个对象
- /// </summary>
- /// <typeparam name="T"></typeparam>
- /// <param name="key"></param>
- /// <param name="obj"></param>
- /// <param name="expiry"></param>
- /// <returns></returns>
- public bool SetString<T>(string key, T obj, TimeSpan? expiry = default(TimeSpan?))
- {
- key = AddSysCustomKey(key);
- string json = ConvertJson(obj);
- return Do(db => db.StringSet(key, json, expiry));
- }
- /// <summary>
- /// 获取单个key的值
- /// </summary>
- /// <param name="key">Redis Key</param>
- /// <returns></returns>
- public string GetString(string key)
- {
- key = AddSysCustomKey(key);
- return Do(db => db.StringGet(key));
- }
- /// <summary>
- /// 获取多个Key
- /// </summary>
- /// <param name="listKey">Redis Key集合</param>
- /// <returns></returns>
- public RedisValue[] GetString(List<string> listKey)
- {
- List<string> newKeys = listKey.Select(AddSysCustomKey).ToList();
- return Do(db => db.StringGet(ConvertRedisKeys(newKeys)));
- }
- /// <summary>
- /// 获取一个key的对象
- /// </summary>
- /// <typeparam name="T"></typeparam>
- /// <param name="key"></param>
- /// <returns></returns>
- public T GetString<T>(string key)
- {
- key = AddSysCustomKey(key);
- return Do(db => ConvertObj<T>(db.StringGet(key)));
- }
- /// <summary>
- /// 为数字增长val
- /// </summary>
- /// <param name="key"></param>
- /// <param name="val">可以为负</param>
- /// <returns>增长后的值</returns>
- public double IncrementString(string key, double val = 1)
- {
- key = AddSysCustomKey(key);
- return Do(db => db.StringIncrement(key, val));
- }
- /// <summary>
- /// 为数字减少val
- /// </summary>
- /// <param name="key"></param>
- /// <param name="val">可以为负</param>
- /// <returns>减少后的值</returns>
- public double DecrementString(string key, double val = 1)
- {
- key = AddSysCustomKey(key);
- return Do(db => db.StringDecrement(key, val));
- }
- #endregion 同步方法
- #region 异步方法
- /// <summary>
- /// 保存单个key value
- /// </summary>
- /// <param name="key">Redis Key</param>
- /// <param name="value">保存的值</param>
- /// <param name="expiry">过期时间</param>
- /// <returns></returns>
- public async Task<bool> SetAsyncString(string key, string value, TimeSpan? expiry = default(TimeSpan?))
- {
- key = AddSysCustomKey(key);
- return await Do(db => db.StringSetAsync(key, value, expiry));
- }
- /// <summary>
- /// 保存多个key value
- /// </summary>
- /// <param name="keyValues">键值对</param>
- /// <returns></returns>
- public async Task<bool> SetAsyncString(List<KeyValuePair<RedisKey, RedisValue>> keyValues)
- {
- List<KeyValuePair<RedisKey, RedisValue>> newkeyValues =
- keyValues.Select(p => new KeyValuePair<RedisKey, RedisValue>(AddSysCustomKey(p.Key), p.Value)).ToList();
- return await Do(db => db.StringSetAsync(newkeyValues.ToArray()));
- }
- /// <summary>
- /// 保存一个对象
- /// </summary>
- /// <typeparam name="T"></typeparam>
- /// <param name="key"></param>
- /// <param name="obj"></param>
- /// <param name="expiry"></param>
- /// <returns></returns>
- public async Task<bool> SetAsyncString<T>(string key, T obj, TimeSpan? expiry = default(TimeSpan?))
- {
- key = AddSysCustomKey(key);
- string json = ConvertJson(obj);
- return await Do(db => db.StringSetAsync(key, json, expiry));
- }
- /// <summary>
- /// 获取单个key的值
- /// </summary>
- /// <param name="key">Redis Key</param>
- /// <returns></returns>
- public async Task<string> GetAsyncString(string key)
- {
- key = AddSysCustomKey(key);
- return await Do(db => db.StringGetAsync(key));
- }
- /// <summary>
- /// 获取多个Key
- /// </summary>
- /// <param name="listKey">Redis Key集合</param>
- /// <returns></returns>
- public async Task<RedisValue[]> GetAsyncString(List<string> listKey)
- {
- List<string> newKeys = listKey.Select(AddSysCustomKey).ToList();
- return await Do(db => db.StringGetAsync(ConvertRedisKeys(newKeys)));
- }
- /// <summary>
- /// 获取一个key的对象
- /// </summary>
- /// <typeparam name="T"></typeparam>
- /// <param name="key"></param>
- /// <returns></returns>
- public async Task<T> GetAsyncString<T>(string key)
- {
- key = AddSysCustomKey(key);
- string result = await Do(db => db.StringGetAsync(key));
- return ConvertObj<T>(result);
- }
- /// <summary>
- /// 为数字增长val
- /// </summary>
- /// <param name="key"></param>
- /// <param name="val">可以为负</param>
- /// <returns>增长后的值</returns>
- public async Task<double> IncrementAsyncString(string key, double val = 1)
- {
- key = AddSysCustomKey(key);
- return await Do(db => db.StringIncrementAsync(key, val));
- }
- /// <summary>
- /// 为数字减少val
- /// </summary>
- /// <param name="key"></param>
- /// <param name="val">可以为负</param>
- /// <returns>减少后的值</returns>
- public async Task<double> DecrementAsyncString(string key, double val = 1)
- {
- key = AddSysCustomKey(key);
- return await Do(db => db.StringDecrementAsync(key, val));
- }
- #endregion 异步方法
- #endregion String
- #region Hash
- #region 同步方法
- /// <summary>
- /// 判断某个数据是否已经被缓存
- /// </summary>
- /// <param name="key"></param>
- /// <param name="dataKey"></param>
- /// <returns></returns>
- public bool IsExistsHash(string key, string dataKey)
- {
- key = AddSysCustomKey(key);
- return Do(db => db.HashExists(key, dataKey));
- }
- /// <summary>
- /// 存储数据到hash表
- /// </summary>
- /// <typeparam name="T"></typeparam>
- /// <param name="key"></param>
- /// <param name="dataKey"></param>
- /// <param name="t"></param>
- /// <returns></returns>
- public bool SetHash<T>(string key, string dataKey, T t)
- {
- key = AddSysCustomKey(key);
- return Do(db =>
- {
- string json = ConvertJson(t);
- return db.HashSet(key, dataKey, json);
- });
- }
- /// <summary>
- /// 移除hash中的某值
- /// </summary>
- /// <param name="key"></param>
- /// <param name="dataKey"></param>
- /// <returns></returns>
- public bool DeleteHash(string key, string dataKey)
- {
- key = AddSysCustomKey(key);
- return Do(db => db.HashDelete(key, dataKey));
- }
- /// <summary>
- /// 移除hash中的多个值
- /// </summary>
- /// <param name="key"></param>
- /// <param name="dataKeys"></param>
- /// <returns></returns>
- public long DeleteHash(string key, List<RedisValue> dataKeys)
- {
- key = AddSysCustomKey(key);
- //List<RedisValue> dataKeys1 = new List<RedisValue>() {"1","2"};
- return Do(db => db.HashDelete(key, dataKeys.ToArray()));
- }
- /// <summary>
- /// 从hash表获取数据
- /// </summary>
- /// <typeparam name="T"></typeparam>
- /// <param name="key"></param>
- /// <param name="dataKey"></param>
- /// <returns></returns>
- public T GetHash<T>(string key, string dataKey)
- {
- key = AddSysCustomKey(key);
- return Do(db =>
- {
- string value = db.HashGet(key, dataKey);
- return ConvertObj<T>(value);
- });
- }
- /// <summary>
- /// 为数字增长val
- /// </summary>
- /// <param name="key"></param>
- /// <param name="dataKey"></param>
- /// <param name="val">可以为负</param>
- /// <returns>增长后的值</returns>
- public double IncrementHash(string key, string dataKey, double val = 1)
- {
- key = AddSysCustomKey(key);
- return Do(db => db.HashIncrement(key, dataKey, val));
- }
- /// <summary>
- /// 为数字减少val
- /// </summary>
- /// <param name="key"></param>
- /// <param name="dataKey"></param>
- /// <param name="val">可以为负</param>
- /// <returns>减少后的值</returns>
- public double DecrementHash(string key, string dataKey, double val = 1)
- {
- key = AddSysCustomKey(key);
- return Do(db => db.HashDecrement(key, dataKey, val));
- }
- /// <summary>
- /// 获取hashkey所有Redis key
- /// </summary>
- /// <typeparam name="T"></typeparam>
- /// <param name="key"></param>
- /// <returns></returns>
- public List<T> KeysHash<T>(string key)
- {
- key = AddSysCustomKey(key);
- return Do(db =>
- {
- RedisValue[] values = db.HashKeys(key);
- return ConvetList<T>(values);
- });
- }
- #endregion 同步方法
- #region 异步方法
- /// <summary>
- /// 判断某个数据是否已经被缓存
- /// </summary>
- /// <param name="key"></param>
- /// <param name="dataKey"></param>
- /// <returns></returns>
- public async Task<bool> IsExistsAsyncHash(string key, string dataKey)
- {
- key = AddSysCustomKey(key);
- return await Do(db => db.HashExistsAsync(key, dataKey));
- }
- /// <summary>
- /// 存储数据到hash表
- /// </summary>
- /// <typeparam name="T"></typeparam>
- /// <param name="key"></param>
- /// <param name="dataKey"></param>
- /// <param name="t"></param>
- /// <returns></returns>
- public async Task<bool> SetAsyncHash<T>(string key, string dataKey, T t)
- {
- key = AddSysCustomKey(key);
- return await Do(db =>
- {
- string json = ConvertJson(t);
- return db.HashSetAsync(key, dataKey, json);
- });
- }
- /// <summary>
- /// 移除hash中的某值
- /// </summary>
- /// <param name="key"></param>
- /// <param name="dataKey"></param>
- /// <returns></returns>
- public async Task<bool> DeleteAsyncHash(string key, string dataKey)
- {
- key = AddSysCustomKey(key);
- return await Do(db => db.HashDeleteAsync(key, dataKey));
- }
- /// <summary>
- /// 移除hash中的多个值
- /// </summary>
- /// <param name="key"></param>
- /// <param name="dataKeys"></param>
- /// <returns></returns>
- public async Task<long> DeleteAsyncHash(string key, List<RedisValue> dataKeys)
- {
- key = AddSysCustomKey(key);
- //List<RedisValue> dataKeys1 = new List<RedisValue>() {"1","2"};
- return await Do(db => db.HashDeleteAsync(key, dataKeys.ToArray()));
- }
- /// <summary>
- /// 从hash表获取数据
- /// </summary>
- /// <typeparam name="T"></typeparam>
- /// <param name="key"></param>
- /// <param name="dataKey"></param>
- /// <returns></returns>
- public async Task<T> GeAsyncHash<T>(string key, string dataKey)
- {
- key = AddSysCustomKey(key);
- string value = await Do(db => db.HashGetAsync(key, dataKey));
- return ConvertObj<T>(value);
- }
- /// <summary>
- /// 为数字增长val
- /// </summary>
- /// <param name="key"></param>
- /// <param name="dataKey"></param>
- /// <param name="val">可以为负</param>
- /// <returns>增长后的值</returns>
- public async Task<double> IncrementAsyncHash(string key, string dataKey, double val = 1)
- {
- key = AddSysCustomKey(key);
- return await Do(db => db.HashIncrementAsync(key, dataKey, val));
- }
- /// <summary>
- /// 为数字减少val
- /// </summary>
- /// <param name="key"></param>
- /// <param name="dataKey"></param>
- /// <param name="val">可以为负</param>
- /// <returns>减少后的值</returns>
- public async Task<double> DecrementAsyncHash(string key, string dataKey, double val = 1)
- {
- key = AddSysCustomKey(key);
- return await Do(db => db.HashDecrementAsync(key, dataKey, val));
- }
- /// <summary>
- /// 获取hashkey所有Redis key
- /// </summary>
- /// <typeparam name="T"></typeparam>
- /// <param name="key"></param>
- /// <returns></returns>
- public async Task<List<T>> KeysAsyncHash<T>(string key)
- {
- key = AddSysCustomKey(key);
- RedisValue[] values = await Do(db => db.HashKeysAsync(key));
- return ConvetList<T>(values);
- }
- #endregion 异步方法
- #endregion Hash
- #region List
- #region 同步方法
- /// <summary>
- /// 移除指定ListId的内部List的值
- /// </summary>
- /// <param name="key"></param>
- /// <param name="value"></param>
- public void RemoveList<T>(string key, T value)
- {
- key = AddSysCustomKey(key);
- Do(db => db.ListRemove(key, ConvertJson(value)));
- }
- /// <summary>
- /// 获取指定key的List
- /// </summary>
- /// <param name="key"></param>
- /// <returns></returns>
- public List<T> ListRange<T>(string key)
- {
- key = AddSysCustomKey(key);
- return Do(redis =>
- {
- var values = redis.ListRange(key);
- return ConvetList<T>(values);
- });
- }
- /// <summary>
- /// 入队
- /// </summary>
- /// <param name="key"></param>
- /// <param name="value"></param>
- public void ListRightPush<T>(string key, T value)
- {
- key = AddSysCustomKey(key);
- Do(db => db.ListRightPush(key, ConvertJson(value)));
- }
- /// <summary>
- /// 出队
- /// </summary>
- /// <typeparam name="T"></typeparam>
- /// <param name="key"></param>
- /// <returns></returns>
- public T ListRightPop<T>(string key)
- {
- key = AddSysCustomKey(key);
- return Do(db =>
- {
- var value = db.ListRightPop(key);
- return ConvertObj<T>(value);
- });
- }
- /// <summary>
- /// 入栈
- /// </summary>
- /// <typeparam name="T"></typeparam>
- /// <param name="key"></param>
- /// <param name="value"></param>
- public void ListLeftPush<T>(string key, T value)
- {
- key = AddSysCustomKey(key);
- Do(db => db.ListLeftPush(key, ConvertJson(value)));
- }
- /// <summary>
- /// 出栈
- /// </summary>
- /// <typeparam name="T"></typeparam>
- /// <param name="key"></param>
- /// <returns></returns>
- public T ListLeftPop<T>(string key)
- {
- key = AddSysCustomKey(key);
- return Do(db =>
- {
- var value = db.ListLeftPop(key);
- return ConvertObj<T>(value);
- });
- }
- /// <summary>
- /// 获取集合中的数量
- /// </summary>
- /// <param name="key"></param>
- /// <returns></returns>
- public long ListLength(string key)
- {
- key = AddSysCustomKey(key);
- return Do(redis => redis.ListLength(key));
- }
- #endregion 同步方法
- #region 异步方法
- /// <summary>
- /// 移除指定ListId的内部List的值
- /// </summary>
- /// <param name="key"></param>
- /// <param name="value"></param>
- public async Task<long> ListRemoveAsync<T>(string key, T value)
- {
- key = AddSysCustomKey(key);
- return await Do(db => db.ListRemoveAsync(key, ConvertJson(value)));
- }
- /// <summary>
- /// 获取指定key的List
- /// </summary>
- /// <param name="key"></param>
- /// <returns></returns>
- public async Task<List<T>> ListRangeAsync<T>(string key)
- {
- key = AddSysCustomKey(key);
- var values = await Do(redis => redis.ListRangeAsync(key));
- return ConvetList<T>(values);
- }
- /// <summary>
- /// 入队
- /// </summary>
- /// <param name="key"></param>
- /// <param name="value"></param>
- public async Task<long> ListRightPushAsync<T>(string key, T value)
- {
- key = AddSysCustomKey(key);
- return await Do(db => db.ListRightPushAsync(key, ConvertJson(value)));
- }
- /// <summary>
- /// 出队
- /// </summary>
- /// <typeparam name="T"></typeparam>
- /// <param name="key"></param>
- /// <returns></returns>
- public async Task<T> ListRightPopAsync<T>(string key)
- {
- key = AddSysCustomKey(key);
- var value = await Do(db => db.ListRightPopAsync(key));
- return ConvertObj<T>(value);
- }
- /// <summary>
- /// 入栈
- /// </summary>
- /// <typeparam name="T"></typeparam>
- /// <param name="key"></param>
- /// <param name="value"></param>
- public async Task<long> ListLeftPushAsync<T>(string key, T value)
- {
- key = AddSysCustomKey(key);
- return await Do(db => db.ListLeftPushAsync(key, ConvertJson(value)));
- }
- /// <summary>
- /// 出栈
- /// </summary>
- /// <typeparam name="T"></typeparam>
- /// <param name="key"></param>
- /// <returns></returns>
- public async Task<T> ListLeftPopAsync<T>(string key)
- {
- key = AddSysCustomKey(key);
- var value = await Do(db => db.ListLeftPopAsync(key));
- return ConvertObj<T>(value);
- }
- /// <summary>
- /// 获取集合中的数量
- /// </summary>
- /// <param name="key"></param>
- /// <returns></returns>
- public async Task<long> ListLengthAsync(string key)
- {
- key = AddSysCustomKey(key);
- return await Do(redis => redis.ListLengthAsync(key));
- }
- #endregion 异步方法
- #endregion List
- #region SortedSet 有序集合
- #region 同步方法
- /// <summary>
- /// 添加
- /// </summary>
- /// <param name="key"></param>
- /// <param name="value"></param>
- /// <param name="score"></param>
- public bool SortedSetAdd<T>(string key, T value, double score)
- {
- key = AddSysCustomKey(key);
- return Do(redis => redis.SortedSetAdd(key, ConvertJson<T>(value), score));
- }
- /// <summary>
- /// 删除
- /// </summary>
- /// <param name="key"></param>
- /// <param name="value"></param>
- public bool SortedSetRemove<T>(string key, T value)
- {
- key = AddSysCustomKey(key);
- return Do(redis => redis.SortedSetRemove(key, ConvertJson(value)));
- }
- /// <summary>
- /// 获取全部
- /// </summary>
- /// <param name="key"></param>
- /// <returns></returns>
- public List<T> SortedSetRangeByRank<T>(string key)
- {
- key = AddSysCustomKey(key);
- return Do(redis =>
- {
- var values = redis.SortedSetRangeByRank(key);
- return ConvetList<T>(values);
- });
- }
- /// <summary>
- /// 获取集合中的数量
- /// </summary>
- /// <param name="key"></param>
- /// <returns></returns>
- public long SortedSetLength(string key)
- {
- key = AddSysCustomKey(key);
- return Do(redis => redis.SortedSetLength(key));
- }
- #endregion 同步方法
- #region 异步方法
- /// <summary>
- /// 添加
- /// </summary>
- /// <param name="key"></param>
- /// <param name="value"></param>
- /// <param name="score"></param>
- public async Task<bool> SortedSetAddAsync<T>(string key, T value, double score)
- {
- key = AddSysCustomKey(key);
- return await Do(redis => redis.SortedSetAddAsync(key, ConvertJson<T>(value), score));
- }
- /// <summary>
- /// 删除
- /// </summary>
- /// <param name="key"></param>
- /// <param name="value"></param>
- public async Task<bool> SortedSetRemoveAsync<T>(string key, T value)
- {
- key = AddSysCustomKey(key);
- return await Do(redis => redis.SortedSetRemoveAsync(key, ConvertJson(value)));
- }
- /// <summary>
- /// 获取全部
- /// </summary>
- /// <param name="key"></param>
- /// <returns></returns>
- public async Task<List<T>> SortedSetRangeByRankAsync<T>(string key)
- {
- key = AddSysCustomKey(key);
- var values = await Do(redis => redis.SortedSetRangeByRankAsync(key));
- return ConvetList<T>(values);
- }
- /// <summary>
- /// 获取集合中的数量
- /// </summary>
- /// <param name="key"></param>
- /// <returns></returns>
- public async Task<long> SortedSetLengthAsync(string key)
- {
- key = AddSysCustomKey(key);
- return await Do(redis => redis.SortedSetLengthAsync(key));
- }
- #endregion 异步方法
- #endregion SortedSet 有序集合
- #region key
- /// <summary>
- /// 删除单个key
- /// </summary>
- /// <param name="key">redis key</param>
- /// <returns>是否删除成功</returns>
- public bool KeyDelete(string key)
- {
- key = AddSysCustomKey(key);
- return Do(db => db.KeyDelete(key));
- }
- /// <summary>
- /// 删除多个key
- /// </summary>
- /// <param name="keys">rediskey</param>
- /// <returns>成功删除的个数</returns>
- public long KeyDelete(List<string> keys)
- {
- List<string> newKeys = keys.Select(AddSysCustomKey).ToList();
- return Do(db => db.KeyDelete(ConvertRedisKeys(newKeys)));
- }
- /// <summary>
- /// 判断key是否存储
- /// </summary>
- /// <param name="key">redis key</param>
- /// <returns></returns>
- public bool KeyExists(string key)
- {
- key = AddSysCustomKey(key);
- return Do(db => db.KeyExists(key));
- }
- /// <summary>
- /// 重新命名key
- /// </summary>
- /// <param name="key">就的redis key</param>
- /// <param name="newKey">新的redis key</param>
- /// <returns></returns>
- public bool KeyRename(string key, string newKey)
- {
- key = AddSysCustomKey(key);
- return Do(db => db.KeyRename(key, newKey));
- }
- /// <summary>
- /// 设置Key的时间
- /// </summary>
- /// <param name="key">redis key</param>
- /// <param name="expiry"></param>
- /// <returns></returns>
- public bool KeyExpire(string key, TimeSpan? expiry = default(TimeSpan?))
- {
- key = AddSysCustomKey(key);
- return Do(db => db.KeyExpire(key, expiry));
- }
- #endregion key
- #region 发布订阅
- /// <summary>
- /// Redis发布订阅 订阅
- /// </summary>
- /// <param name="subChannel"></param>
- /// <param name="handler"></param>
- public void Subscribe(string subChannel, Action<RedisChannel, RedisValue> handler = null)
- {
- ISubscriber sub = _conn.GetSubscriber();
- sub.Subscribe(subChannel, (channel, message) =>
- {
- if (handler == null)
- {
- Console.WriteLine(subChannel + " 订阅收到消息:" + message);
- }
- else
- {
- handler(channel, message);
- }
- });
- }
- /// <summary>
- /// Redis发布订阅 发布
- /// </summary>
- /// <typeparam name="T"></typeparam>
- /// <param name="channel"></param>
- /// <param name="msg"></param>
- /// <returns></returns>
- public long Publish<T>(string channel, T msg)
- {
- ISubscriber sub = _conn.GetSubscriber();
- return sub.Publish(channel, ConvertJson(msg));
- }
- /// <summary>
- /// Redis发布订阅 取消订阅
- /// </summary>
- /// <param name="channel"></param>
- public void Unsubscribe(string channel)
- {
- ISubscriber sub = _conn.GetSubscriber();
- sub.Unsubscribe(channel);
- }
- /// <summary>
- /// Redis发布订阅 取消全部订阅
- /// </summary>
- public void UnsubscribeAll()
- {
- ISubscriber sub = _conn.GetSubscriber();
- sub.UnsubscribeAll();
- }
- #endregion 发布订阅
- #region 其他
- public ITransaction CreateTransaction()
- {
- return GetDatabase().CreateTransaction();
- }
- public IDatabase GetDatabase()
- {
- return _conn.GetDatabase(DbNum);
- }
- public IServer GetServer(string hostAndPort)
- {
- return _conn.GetServer(hostAndPort);
- }
- /// <summary>
- /// 设置前缀
- /// </summary>
- /// <param name="customKey"></param>
- public void SetSysCustomKey(string customKey)
- {
- CustomKey = customKey;
- }
- #endregion 其他
- #region 辅助方法
- private string AddSysCustomKey(string oldKey)
- {
- var prefixKey = CustomKey ?? RedisConnection.SysCustomKey;
- return prefixKey + oldKey;
- }
- private T Do<T>(Func<IDatabase, T> func)
- {
- var database = _conn.GetDatabase(DbNum);
- return func(database);
- }
- private string ConvertJson<T>(T value)
- {
- string result = value is string ? value.ToString() : JsonConvert.SerializeObject(value);
- return result;
- }
- private T ConvertObj<T>(RedisValue value)
- {
- return JsonConvert.DeserializeObject<T>(value);
- }
- private List<T> ConvetList<T>(RedisValue[] values)
- {
- List<T> result = new List<T>();
- foreach (var item in values)
- {
- var model = ConvertObj<T>(item);
- result.Add(model);
- }
- return result;
- }
- private RedisKey[] ConvertRedisKeys(List<string> redisKeys)
- {
- return redisKeys.Select(redisKey => (RedisKey)redisKey).ToArray();
- }
- #endregion 辅助方法
- }
- }
|