一. 寫在前面
畢業工作後,今天終於能回家了,回想了一些這半年來所做的內容,總是覺得還停留在那麼基礎的水平,在解決各種問題的過程中,自己的創新思路比較少,靠搜尋來的比較多。不想做16年的總結了,希望17年能學更多的我愛的技術,看更多的開源程式碼,能學到更多的設計想法和程式碼思路,能再更新這兩年來對程式碼的理解。
這篇分享,主要是彌補我之前RedisRepository的不足。
半年前由於我StackExchange.Redis文件閱讀不足,所分享的RedisRepository有所錯誤。以下列舉我的主要錯誤:
錯誤1,沒有單例化ConnectionMultiplexer Redis連接對象,並且我天真的以為給單例對象加鎖,在並發情況下,會限制了Redis的性能。
錯誤2,在主從情況下,我以為在發生手動切換的時候,我們要訂閱切換事件,並在事件發生後,動態改變連接對象指向的Endpoint。
當我再一次仔細閱讀文件時,才明白我的錯誤,這是一篇遲到的修正,但是我自用的repository自我感覺還是有很多不足之處,所以我真的需要老司機的指點和建議。
修正1,Redis連接物件創建的代價很大,且單例加鎖並不會影響Redis效能,因為在發生網路請求的期間,連接物件並沒有在等待中。
修正2,Redis主從時,在哨兵切換主從關係後,StackExchange.Redis會為我們識別新的主從,不需要我們做任何操作。
目前為止我還有兩個疑問。
疑問1,在看文件後沒有明確結果。當做主從讀寫分離, 我們在Endpoint Collection集合中加入多個節點就會自動讀寫分離?還是說需要 我們在讀取指令的方法中指定CommandFlags.PreferSlave? 我認為是後者吧?所以我在我所有的讀取方法都指定了PreferSlave。 老司機怎麼說?
疑問2,我使用LuaScript.Prepare(lua)後再Load出來,執行lua總是無效果,並且LuaScript.GetCachedScriptCount()為0. 不過我直接使用ScriptEvaluateAsync卻是好用的,老司機如果有好的例子,希望老司機給些指導或分享。
二. 程式碼結構,僅供參考
結構大概就是這樣,RedisAsyncHelper下的所有類別都是部分類,他們的類別名稱是RedisHelper。他們共同實作了IRedisHelper的接口,並且留下了詳細的註解。
同步版本和非同步版本的目錄結構是一樣的。
三. 預備階段
CommonHelper中的兩個幫助類別:
RedisInnerTypeHelper.cs
using StackExchange.Redis; using System.Collections.Generic; using System.Linq; namespace Fantasy.RedisRepository.CommonHelper { internal class RedisInnerTypeHelper { public static List<T> RedisValuesToGenericList<T>(RedisValue[] redisValues) { var result = new List<T>(); redisValues.ToList().ForEach(r => result.Add(SerializeHelper.Deserialize<T>(r))); return result; } public static RedisValue[] GenericListToRedisValues<T>(List<T> values) { var redisValues = new List<RedisValue>(); values.ForEach(v => redisValues.Add(SerializeHelper.Serialize(values))); return redisValues.ToArray(); } public static RedisKey[] GenericListToRedisKeys(List<string> keys) { var redisKeys = new List<RedisKey>(); keys.ForEach(k => redisKeys.Add(k)); return redisKeys.ToArray(); } } }
SerializeHelper.cs
rrre.using System.IO; using System.Runtime.Serialization.Formatters.Binary; namespace Fantasy.RedisRepository.CommonHelper { internal static class SerializeHelper { /// <summary> /// 字节数组序列化 /// </summary> /// <param name="o"></param> /// <returns></returns> internal static byte[] Serialize(object o) { if (o == null) { return null; } BinaryFormatter binaryFormatter = new BinaryFormatter(); using (MemoryStream memoryStream = new MemoryStream()) { binaryFormatter.Serialize(memoryStream, o); byte[] objectDataAsStream = memoryStream.ToArray(); return objectDataAsStream; } } /// <summary> /// 字节数组反序列化 /// </summary> /// <typeparam name="T"></typeparam> /// <param name="stream"></param> /// <returns></returns> internal static T Deserialize<T>(byte[] stream) { if (stream == null) { return default(T); } BinaryFormatter binaryFormatter = new BinaryFormatter(); using (MemoryStream memoryStream = new MemoryStream(stream)) { T result = (T)binaryFormatter.Deserialize(memoryStream); return result; } } } }
RedisConnection.cs
using System; using System.Configuration; namespace Fantasy.RedisRepository.Config { internal class ConfigHelper { internal static T Get<T>(string appSettingsKey, T defaultValue) { string text = ConfigurationManager.AppSettings[appSettingsKey]; if (string.IsNullOrWhiteSpace(text)) return defaultValue; try { var value = Convert.ChangeType(text, typeof(T)); return (T)value; } catch { return defaultValue; } } } }
四. RedisHelper
其實就是做了層序列化包裝而已。
IRedisHelper:
namespace Fantasy.RedisRepository.Config { internal class RedisClientConfig { private static string _server = ConfigHelper.Get("RedisServer", "115.xx.xx.31"); /// <summary> /// 节点IP /// </summary> public static string Server { get { return _server; } set { _server = value; } } private static int _port = ConfigHelper.Get("RedisPort", 6380); /// <summary> /// 节点端口 /// </summary> public static int Port { get { return _port; } set { _port = value; } } private static string _slaveServer = ConfigHelper.Get("SlaveServer", "115.xx.xx.31"); /// <summary> /// 节点IP /// </summary> public static string SlaveServer { get { return _slaveServer; } set { _slaveServer = value; } } private static int _slavePort = ConfigHelper.Get("SlavePort", 6381); /// <summary> /// 节点端口 /// </summary> public static int SlavePort { get { return _slavePort; } set { _slavePort = value; } } private static string _auth = ConfigHelper.Get("RedisAuth", "fantasy.."); /// <summary> /// 节点密码 /// </summary> public static string RedisAuth { get { return _auth; } set { _auth = value; } } private static int _defaultDatabase = ConfigHelper.Get("RedisDataBase", 0); /// <summary> /// redis默认0号库 /// </summary> public static int DefaultDatabase { get { return _defaultDatabase; } set { _defaultDatabase = value; } } private static int _connectTimeout = 10000; public static int ConnectTimeout { get { return _connectTimeout; } set { _connectTimeout = value; } } private static int _connectRetry = 3; public static int ConnectRetry { get { return _connectRetry; } set { _connectRetry = value; } } private static bool _preserveAsyncOrder = false; public static bool PreserveAsyncOrder { get { return _preserveAsyncOrder; } set { _preserveAsyncOrder = value; } } } }
RedisHelper部分類RedisStringHelperAsync.cs
using Fantasy.RedisRepository.Config; using StackExchange.Redis; namespace Fantasy.RedisRepository { /// <summary> /// Redis连接类 /// </summary> public static class RedisConnection { private static ConnectionMultiplexer _connection; private static readonly object SyncObject = new object(); /// <summary> /// redis连接对象,单例加锁不影响性能 /// </summary> public static ConnectionMultiplexer GenerateConnection { get { if (_connection == null || !_connection.IsConnected) { lock (SyncObject) { var configurationOptions = new ConfigurationOptions() { Password = RedisClientConfig.RedisAuth, EndPoints = { {RedisClientConfig.Server, RedisClientConfig.Port}, {RedisClientConfig.SlaveServer, RedisClientConfig.SlavePort} } }; _connection = ConnectionMultiplexer.Connect(configurationOptions); } } return _connection; } } } }
RedisHelper部分類RedisHashHelperAsync.cs
using System; using StackExchange.Redis; using System.Collections.Generic; using System.Threading.Tasks; namespace Fantasy.RedisRepository.RedisHelpers { /// <summary> /// 异步方法接口 --Author 吴双 www.cnblogs.com/tdws /// 存入数据均为方法内部序列化后的byte,所以取数据的时候需要反序列化时,请指定正确的数据类型 /// </summary> public partial interface IRedisHelper { #region Redis数据类型—String /// <summary> /// 将任何数据以redis string存储 /// </summary> /// <typeparam name="T"></typeparam> /// <param name="key"></param> /// <param name="value"></param> /// <param name="timeout"></param> /// <returns></returns> Task<bool> StringSetAsync<T>(string key, T value, TimeSpan? timeout = null); /// <summary> /// 对数值进行减法操作,默认-1 /// </summary> /// <param name="key"></param> /// <param name="value"></param> /// <returns>操作后的结果</returns> Task<long> StringDecrementAsync(string key, long value = 1L); /// <summary> /// 对数值进行加法操作,默认+1 /// </summary> /// <param name="key"></param> /// <param name="value"></param> /// <returns>操作后的结果</returns> Task<long> StringIncrementAsync(string key, long value = 1L); /// <summary> /// 从redis string中以指定类型取出 /// </summary> /// <typeparam name="T"></typeparam> /// <param name="key"></param> /// <returns></returns> Task<T> StringGetAsync<T>(string key); #endregion #region Redis数据类型—Hash /// <summary> /// 向Hash key中存储任意类型任意值 /// </summary> /// <typeparam name="T"></typeparam> /// <param name="key"></param> /// <param name="field"></param> /// <param name="value"></param> /// <returns>是否成功</returns> Task<bool> HashSetAsync<T>(string key, string field, T value); /// <summary> /// 批量 向Hash key中存储任意类型任意值 /// </summary> /// <typeparam name="T"></typeparam> /// <param name="key"></param> /// <param name="hashFields"></param> /// <returns>无返回值</returns> Task HashMultiSetAsync<T>(string key, Dictionary<string, T> hashFields); /// <summary> /// 对指定hash key中制定field做数量增加操作 默认自增1 /// 如果此操作前key不存在 则创建。 如果此操作前该field不存在或者非数字 则先被置0,再被继续操作 /// </summary> /// <param name="key"></param> /// <param name="field"></param> /// <param name="incrCount"></param> /// <returns>操作后的结果</returns> Task<long> HashIncrementAsync(string key, string field, long incrCount = 1); /// <summary> /// 对指定hash key中制定field做数量增加操作 默认自减1 /// 如果此操作前key不存在 则创建。 如果此操作前该field不存在或者非数字 则先被置0,再被继续操作 /// </summary> /// <param name="key"></param> /// <param name="field"></param> /// <param name="decrCount"></param> /// <returns>操作后的结果</returns> Task<long> HashDecrementAsync(string key, string field, long decrCount = 1); /// <summary> /// 从指定Hash中 删除指定field /// 如果key或者field不存在,则false /// </summary> /// <param name="key"></param> /// <param name="field"></param> /// <returns>是否成功</returns> Task<bool> HashDeleteFieldAsync(string key, string field); /// <summary> /// 从指定Hash key中 批量删除指定field /// 如果key或者field不存在,则false /// </summary> /// <param name="key"></param> /// <param name="fields"></param> /// <returns>移除数量</returns> Task<long> HashMultiDeleteFieldAsync(string key, List<string> fields); /// <summary> /// 从指定Hash key中获取指定field值 /// </summary> /// <typeparam name="T"></typeparam> /// <param name="key"></param> /// <param name="field"></param> /// <returns></returns> Task<T> HashGetAsync<T>(string key, string field); /// <summary> /// 从指定Hash key中判断field是否存在 /// </summary> /// <param name="key"></param> /// <param name="field"></param> /// <returns></returns> Task<bool> HashFieldExistAsync(string key, string field); /// <summary> /// 获取指定Hash key中的所有field的值 /// </summary> /// <typeparam name="T"></typeparam> /// <param name="key"></param> /// <returns></returns> Task<List<T>> HashValuesAsync<T>(string key); /// <summary> /// 获取指定Hash key中所有 field名称及其Value /// </summary> /// <typeparam name="T"></typeparam> /// <param name="key"></param> /// <returns></returns> Task<Dictionary<string, T>> HashGetAllAsync<T>(string key); /// <summary> /// 获取指定Hash key中所有field /// </summary> /// <param name="key"></param> /// <returns></returns> Task<List<string>> HashFieldsAsync(string key); #endregion #region Redis数据类型—List /// <summary> /// 在指定pivot后插入value, 如果pivot不存在,则返回-1, 如果key不存在,则返回0 /// 如果存在多个相同指定的的pivot,则插入第一个指定pivot后面. /// 即链表从左向右查找,遇到指定pivot,则确定位置 /// </summary> /// <typeparam name="T"></typeparam> /// <param name="key"></param> /// <param name="pivot">list中的一个值</param> /// <param name="value"></param> /// <returns></returns> Task<long> ListInsertAfterAsync<T>(string key, string pivot, T value); /// <summary> /// 在指定pivot前插入value, 如果pivot不存在,则返回-1, 如果key不存在,则返回0 /// 如果存在多个相同指定的的pivot,则插入第一个指定pivot前面. /// 即链表从左向右查找,遇到指定pivot,则确定位置 /// </summary> /// <typeparam name="T"></typeparam> /// <param name="key"></param> /// <param name="pivot"></param> /// <param name="value"></param> /// <returns></returns> Task<long> ListInsertBeforeAsync<T>(string key, string pivot, T value); /// <summary> /// 从链表左侧弹出第一个元素(弹出能获取到该元素并且被删除) /// 如果key不存在 或者链表为空 则为null /// </summary> /// <typeparam name="T"></typeparam> /// <param name="key"></param> /// <returns></returns> Task<T> ListLeftPopAsync<T>(string key); /// <summary> /// 从链表左侧增加一个元素,key不存在则被创建 /// </summary> /// <typeparam name="T"></typeparam> /// <param name="key"></param> /// <param name="value"></param> /// <returns>返回操作后的链表长度</returns> Task<long> ListLeftPushAsync<T>(string key, T value); /// <summary> /// 从链表左侧批量增加元素,如果 a b c 则c会在链表左侧第一位 b第二位 a第三位 /// </summary> /// <typeparam name="T"></typeparam> /// <param name="key"></param> /// <param name="values"></param> /// <returns>返回操作后的链表长度</returns> Task<long> ListLeftMultiPushAsync<T>(string key, List<T> values); /// <summary> /// 获取链表长度,不存在key则为0 /// </summary> /// <typeparam name="T"></typeparam> /// <param name="key"></param> /// <returns></returns> Task<long> ListLengthAsync<T>(string key); /// <summary> /// 获取链表中所有数据,从左侧start开始到stop结束,从0—-1则认为获取全部,默认获取全部 /// start为负数则代表从链表右侧开始,-1为右侧第一位,-2为右侧第二位 /// start要小于stop,否则返回null /// </summary> /// <typeparam name="T"></typeparam> /// <param name="key"></param> /// <param name="start"></param> /// <param name="stop"></param> /// <returns></returns> Task<List<T>> ListRangeAsync<T>(string key, long start = 0L, long stop = -1L); /// <summary> /// 从链表中一处count数量的value. count大于0则从左至右,count小于0则从右至左,count=0则移除全部 /// </summary> /// <typeparam name="T"></typeparam> /// <param name="key"></param> /// <param name="value"></param> /// <param name="count"></param> /// <returns></returns> Task<long> ListRemoveAsync<T>(string key, T value, long count = 0L); /// <summary> /// 从右侧弹出第一个元素(弹出能获取到该元素并且被删除) /// </summary> /// <typeparam name="T"></typeparam> /// <param name="key"></param> /// <returns></returns> Task<T> ListRightPopAsync<T>(string key); /// <summary> /// 从链表右侧加入元素,如果 rpush a b c 则c为右侧第一位 b第二位 c第三位 /// </summary> /// <typeparam name="T"></typeparam> /// <param name="key"></param> /// <param name="value"></param> /// <returns></returns> Task<long> ListRightPushAsync<T>(string key, T value); /// <summary> /// 从右侧批量插入,和左侧相反 /// </summary> /// <typeparam name="T"></typeparam> /// <param name="key"></param> /// <param name="values"></param> /// <returns></returns> Task<long> ListRightMultiPushAsync<T>(string key, List<T> values); /// <summary> /// 在链表指定索引处,插入元素 /// 正数索引从0开始,代表左侧。负数从-1开始 代表从右侧。-1为右侧第一位 /// </summary> /// <typeparam name="T"></typeparam> /// <param name="key"></param> /// <param name="index"></param> /// <param name="value"></param> /// <returns></returns> Task ListSetByIndexAsync<T>(string key, int index, T value); /// <summary> /// 留下start到stop之间的数据。负数代表从右侧寻找 -1为右侧第一位 /// </summary> /// <param name="key"></param> /// <param name="start"></param> /// <param name="stop"></param> /// <returns></returns> Task ListTrimAsync(string key, long start, long stop); /// <summary> /// 获取指定index的值,负数代表从右侧寻找 -1为右侧第一位 /// </summary> /// <typeparam name="T"></typeparam> /// <param name="key"></param> /// <param name="index"></param> /// <returns></returns> Task<T> ListGetByIndexAsync<T>(string key, long index); #endregion #region Redis数据类型—Set /// <summary> /// 向指定集合中增加一个元素 /// </summary> /// <typeparam name="T"></typeparam> /// <param name="key"></param> /// <param name="value"></param> /// <returns></returns> Task<bool> SetAddAsync<T>(string key, T value); /// <summary> /// 指定集合计算操作operation枚举,指定计算结果将存的目标destKey,指定需要参与计算的多个key /// </summary> /// <param name="operation"></param> /// <param name="destKey"></param> /// <param name="combineKeys"></param> /// <returns></returns> Task<long> SetCombineAndStoreAsync(SetOperation operation, string destKey, List<string> combineKeys); /// <summary> /// 指定集合计算操作operation枚举,指定需要参与计算的多个key /// </summary> /// <typeparam name="T"></typeparam> /// <param name="operation"></param> /// <param name="combineKeys"></param> /// <returns></returns> Task<List<T>> SetCombineAsync<T>(SetOperation operation, List<string> combineKeys); /// <summary> /// 指定值是否存在于指定集合中 /// </summary> /// <typeparam name="T"></typeparam> /// <param name="key"></param> /// <param name="value"></param> /// <returns></returns> Task<bool> SetContainsAsync<T>(string key, T value); /// <summary> /// 获取指定集合中元素个数 /// </summary> /// <param name="key"></param> /// <returns></returns> Task<long> SetLengthAsync(string key); /// <summary> /// 获取指定集合中的所有元素 /// </summary> /// <typeparam name="T"></typeparam> /// <param name="key"></param> /// <param name="value"></param> /// <returns></returns> Task<List<T>> SetMembersAsync<T>(string key, T value); /// <summary> /// 从sourceKey移除指定value到目标distKey集合当中 /// 如果sourceKey存在指定value则返回true,否则不做任何操作返回false /// </summary> /// <typeparam name="T"></typeparam> /// <param name="sourcekey"></param> /// <param name="distKey"></param> /// <param name="value"></param> /// <returns></returns> Task<bool> SetMoveAsync<T>(string sourcekey, string distKey, T value); /// <summary> /// 从指定集合当中随机取出一个元素 /// </summary> /// <typeparam name="T"></typeparam> /// <param name="key"></param> /// <returns></returns> Task<T> SetRandomMemberAsync<T>(string key); /// <summary> /// 从指定集合随机弹出(删除并获取)一个元素 /// </summary> /// <typeparam name="T"></typeparam> /// <param name="key"></param> /// <returns></returns> Task<T> SetPopAsync<T>(string key); /// <summary> /// 从集合中随机弹出(删除并获取)多个元素 /// </summary> /// <typeparam name="T"></typeparam> /// <param name="key"></param> /// <returns></returns> Task<List<T>> SetRandomMembersAsync<T>(string key); /// <summary> /// 从集合中移除指定元素 /// </summary> /// <typeparam name="T"></typeparam> /// <param name="key"></param> /// <param name="value"></param> /// <returns></returns> Task<bool> SetRemoveAsync<T>(string key, T value); /// <summary> /// 从集合中批量移除元素 /// </summary> /// <typeparam name="T"></typeparam> /// <param name="key"></param> /// <param name="values"></param> /// <returns></returns> Task<long> SetMultiRemoveAsync<T>(string key, List<T> values); #endregion #region Redis数据类型—SortSet #endregion #region Redis Key操作 /// <summary> /// 删除指定key /// </summary> /// <param name="key"></param> /// <returns></returns> Task<bool> KeyDeleteAsync(string key); /// <summary> /// 设置key过期时间具体DateTime /// </summary> /// <param name="key"></param> /// <param name="expireAt"></param> /// <returns></returns> Task<bool> KeyExpireAtAsync(string key, DateTime expireAt); /// <summary> /// 设置key在将来的timeout后过期(TimeSpan) /// </summary> /// <param name="key"></param> /// <param name="timeout"></param> /// <returns></returns> Task<bool> KeyExpireInAsync(string key, TimeSpan timeout); /// <summary> /// key重命名 /// </summary> /// <param name="key"></param> /// <param name="newKey"></param> /// <returns></returns> Task<bool> KeyRenameAsync(string key, string newKey); /// <summary> /// 判断key是否已存在 /// </summary> /// <param name="key"></param> /// <returns></returns> Task<bool> KeyExistsAsync(string key); #endregion #region Redis Transcation /// <summary> /// 在事务中执行一系列redis命令。注意:在委托中的一系列命令的所有 值 都需要进行字节数组序列化 /// </summary> /// <param name="ranOperations"></param> /// <returns></returns> Task<bool> DoInTranscationAsync(Action<ITransaction> ranOperations); #endregion Task<RedisResult> Test(); } }
per.cs 這裡打算裝一些功能行lua腳本, 外部依然是傳key一類別的參數,這個不完整,只是個實例。
using System; using Fantasy.RedisRepository.CommonHelper; using StackExchange.Redis; using System.Threading.Tasks; namespace Fantasy.RedisRepository.RedisHelpers { /// <summary> /// Redis异步操作类 String部分类 /// </summary> internal partial class RedisHelper// : IRedisHelper { private static IDatabase _client; internal RedisHelper() { _client = RedisConnection.GenerateConnection.GetDatabase(); } #region String 写操作 /// <summary> /// 将任何数据添加到redis中 /// </summary> /// <typeparam name="T"></typeparam> /// <param name="key"></param> /// <param name="value"></param> /// <param name="timeout"></param> /// <returns></returns> public async Task<bool> StringSetAsync<T>(string key, T value, TimeSpan? timeout = null) { return await _client.StringSetAsync(key, SerializeHelper.Serialize(value), timeout); } public async Task<long> StringDecrementAsync(string key, long value = 1L) { return await _client.StringDecrementAsync(key, value); } public async Task<long> StringIncrementAsync(string key, long value = 1L) { return await _client.StringIncrementAsync(key, value); } #endregion #region String 读操作 /// <summary> /// 根据key获取指定类型数据 /// </summary> /// <typeparam name="T"></typeparam> /// <param name="key"></param> /// <returns></returns> public async Task<T> StringGetAsync<T>(string key) { return SerializeHelper.Deserialize<T>(await _client.StringGetAsync(key, CommandFlags.PreferSlave)); } #endregion } }
關於Transcation的封裝,我個人沒有什麼好的方法,提供了這樣一個方法
using Fantasy.RedisRepository.CommonHelper; using StackExchange.Redis; using System.Collections.Generic; using System.Linq; using System.Threading.Tasks; namespace Fantasy.RedisRepository.RedisHelpers { /// <summary> /// Redis异步操作类 Hash部分类 /// </summary> internal partial class RedisHelper { #region Hash 写操作 public async Task<bool> HashSetAsync<T>(string key, string field, T value) { return await _client.HashSetAsync(key, field, SerializeHelper.Serialize(value)); } public async Task HashMultiSetAsync<T>(string key, Dictionary<string, T> hashFields) { List<HashEntry> entries = new List<HashEntry>(); hashFields.ToList().ForEach(d => entries.Add(new HashEntry(d.Key, SerializeHelper.Serialize(d.Value)))); await _client.HashSetAsync(key, entries.ToArray()); } public async Task<long> HashIncrementAsync(string key, string field, long incrCount = 1) { return await _client.HashIncrementAsync(key, field, incrCount); } public async Task<long> HashDecrementAsync(string key, string field, long decrCount = 1) { return await _client.HashDecrementAsync(key, field, decrCount); } public async Task<bool> HashDeleteFieldAsync(string key, string field) { return await _client.HashDeleteAsync(key, field); } public async Task<long> HashMultiDeleteFieldAsync(string key, List<string> fields) { List<RedisValue> values = new List<RedisValue>(); fields.ForEach(f => values.Add(f)); return await _client.HashDeleteAsync(key, values.ToArray()); } #endregion #region Hash 读操作 /// <summary> /// Redis 指定hash类型key中field是否存在 /// </summary> /// <param name="key"></param> /// <param name="field"></param> /// <returns></returns> public async Task<bool> HashFieldExistAsync(string key, string field) { return await _client.HashExistsAsync(key, field, CommandFlags.PreferSlave); } public async Task<List<string>> HashFieldsAsync(string key) { RedisValue[] values = await _client.HashKeysAsync(key, CommandFlags.PreferSlave); return RedisInnerTypeHelper.RedisValuesToGenericList<string>(values); } public async Task<List<T>> HashValuesAsync<T>(string key) { var values = await _client.HashValuesAsync(key, CommandFlags.PreferSlave); return RedisInnerTypeHelper.RedisValuesToGenericList<T>(values); } public async Task<T> HashGetAsync<T>(string key, string field) { return SerializeHelper.Deserialize<T>(await _client.HashGetAsync(key, field, CommandFlags.PreferSlave)); } public async Task<Dictionary<string, T>> HashGetAllAsync<T>(string key) { HashEntry[] entries = await _client.HashGetAllAsync(key, CommandFlags.PreferSlave); Dictionary<string, T> dic = new Dictionary<string, T>(); entries.ToList().ForEach(e => dic.Add(e.Name, SerializeHelper.Deserialize<T>(e.Value))); return dic; } #endregion } }
RedisFactory.cs
using Fantasy.RedisRepository.CommonHelper; using StackExchange.Redis; using System.Collections.Generic; using System.Linq; using System.Threading.Tasks; namespace Fantasy.RedisRepository.RedisHelpers { /// <summary> /// Redis异步操作类 Hash部分类 /// </summary> internal partial class RedisHelper { #region Hash 写操作 public async Task<bool> HashSetAsync<T>(string key, string field, T value) { return await _client.HashSetAsync(key, field, SerializeHelper.Serialize(value)); } public async Task HashMultiSetAsync<T>(string key, Dictionary<string, T> hashFields) { List<HashEntry> entries = new List<HashEntry>(); hashFields.ToList().ForEach(d => entries.Add(new HashEntry(d.Key, SerializeHelper.Serialize(d.Value)))); await _client.HashSetAsync(key, entries.ToArray()); } public async Task<long> HashIncrementAsync(string key, string field, long incrCount = 1) { return await _client.HashIncrementAsync(key, field, incrCount); } public async Task<long> HashDecrementAsync(string key, string field, long decrCount = 1) { return await _client.HashDecrementAsync(key, field, decrCount); } public async Task<bool> HashDeleteFieldAsync(string key, string field) { return await _client.HashDeleteAsync(key, field); } public async Task<long> HashMultiDeleteFieldAsync(string key, List<string> fields) { List<RedisValue> values = new List<RedisValue>(); fields.ForEach(f => values.Add(f)); return await _client.HashDeleteAsync(key, values.ToArray()); } #endregion #region Hash 读操作 /// <summary> /// Redis 指定hash类型key中field是否存在 /// </summary> /// <param name="key"></param> /// <param name="field"></param> /// <returns></returns> public async Task<bool> HashFieldExistAsync(string key, string field) { return await _client.HashExistsAsync(key, field, CommandFlags.PreferSlave); } public async Task<List<string>> HashFieldsAsync(string key) { RedisValue[] values = await _client.HashKeysAsync(key, CommandFlags.PreferSlave); return RedisInnerTypeHelper.RedisValuesToGenericList<string>(values); } public async Task<List<T>> HashValuesAsync<T>(string key) { var values = await _client.HashValuesAsync(key, CommandFlags.PreferSlave); return RedisInnerTypeHelper.RedisValuesToGenericList<T>(values); } public async Task<T> HashGetAsync<T>(string key, string field) { return SerializeHelper.Deserialize<T>(await _client.HashGetAsync(key, field, CommandFlags.PreferSlave)); } public async Task<Dictionary<string, T>> HashGetAllAsync<T>(string key) { HashEntry[] entries = await _client.HashGetAllAsync(key, CommandFlags.PreferSlave); Dictionary<string, T> dic = new Dictionary<string, T>(); entries.ToList().ForEach(e => dic.Add(e.Name, SerializeHelper.Deserialize<T>(e.Value))); return dic; } #endregion } }
以上就是本文的全部內容,希望本文的內容對大家的學習或工作能帶來一定的幫助,同時也希望多多支援PHP中文網!
更多RedisRepository 分享與糾錯相關文章請關注PHP中文網!