RedisRepository 分享和纠错

一.   写在前面

毕业工作后，今天终于能回家了，回想了一些这半年来所做的内容，总是觉得还停留在那么基础的水平 ，在解决各种问题的过程中，自己的创新思路比较少，靠搜索来的比较多 。不想做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中的两个帮助类：

最新ASPCMS网络公司模板

发现一套比较好的网络公司模板，试了下效果还不错，代码和后台都很完整，分享出来！

下载

RedisInnerTypeHelper.cs

using StackExchange.Redis;
using System.Collections.Generic;
using System.Linq;
namespace Fantasy.RedisRepository.CommonHelper
{
 internal class RedisInnerTypeHelper
 {
 public static List RedisValuesToGenericList(RedisValue[] redisValues)
 {
  var result = new List();
  redisValues.ToList().ForEach(r => result.Add(SerializeHelper.Deserialize(r)));
  return result;
 }
 public static RedisValue[] GenericListToRedisValues(List values)
 {
  var redisValues = new List();
  values.ForEach(v => redisValues.Add(SerializeHelper.Serialize(values)));
  return redisValues.ToArray();
 }
 public static RedisKey[] GenericListToRedisKeys(List keys)
 {
  var redisKeys = new List();
  keys.ForEach(k => redisKeys.Add(k));
  return redisKeys.ToArray();
 }
 }
}

SerializeHelper.cs

using System.IO;
using System.Runtime.Serialization.Formatters.Binary;
namespace Fantasy.RedisRepository.CommonHelper
{
 internal static class SerializeHelper
 {
 /// 

 /// 字节数组序列化
 /// 
 /// 
 /// 
 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;
  }
 }
 /// 

 /// 字节数组反序列化
 /// 
 /// 
 /// 
 /// 
 internal static T Deserialize(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;
  }
 }
 }
}

using System;
using System.Configuration;
namespace Fantasy.RedisRepository.Config
{
 internal class ConfigHelper
 {
 internal static T Get(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;
  }
 }
 }
}

RedisClientConfig.cs

namespace Fantasy.RedisRepository.Config
{
 internal class RedisClientConfig
 {
 private static string _server = ConfigHelper.Get("RedisServer", "115.xx.xx.31");
 /// 

 /// 节点IP
 /// 
 public static string Server
 {
  get { return _server; }
  set { _server = value; }
 }
 private static int _port = ConfigHelper.Get("RedisPort", 6380);
 /// 

 /// 节点端口
 /// 
 public static int Port
 {
  get { return _port; }
  set { _port = value; }
 }
 private static string _slaveServer = ConfigHelper.Get("SlaveServer", "115.xx.xx.31");
 /// 

 /// 节点IP
 /// 
 public static string SlaveServer
 {
  get { return _slaveServer; }
  set { _slaveServer = value; }
 }
 private static int _slavePort = ConfigHelper.Get("SlavePort", 6381);
 /// 

 /// 节点端口
 /// 
 public static int SlavePort
 {
  get { return _slavePort; }
  set { _slavePort = value; }
 }
 private static string _auth = ConfigHelper.Get("RedisAuth", "fantasy..");
 /// 

 /// 节点密码
 /// 
 public static string RedisAuth
 {
  get { return _auth; }
  set { _auth = value; }
 }
 private static int _defaultDatabase = ConfigHelper.Get("RedisDataBase", 0);
 /// 

 /// redis默认0号库
 /// 
 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; }
 }
 }
}

RedisConnection.cs

using Fantasy.RedisRepository.Config;
using StackExchange.Redis;
namespace Fantasy.RedisRepository
{
 /// 

 /// Redis连接类
 /// 
 public static class RedisConnection
 {
 private static ConnectionMultiplexer _connection;
 private static readonly object SyncObject = new object();
 /// 

 /// redis连接对象，单例加锁不影响性能
 /// 
 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

实际上就是做了层序列化包装而已。

IRedisHelper：

using System;
using StackExchange.Redis;
using System.Collections.Generic;
using System.Threading.Tasks;
namespace Fantasy.RedisRepository.RedisHelpers
{
 /// 

 /// 异步方法接口 --Author 吴双 www.cnblogs.com/tdws
 /// 存入数据均为方法内部序列化后的byte,所以取数据的时候需要反序列化时，请指定正确的数据类型
 /// 
 public partial interface IRedisHelper
 {
 #region Redis数据类型—String
 /// 

 /// 将任何数据以redis string存储
 /// 
 /// 
 /// 
 /// 
 /// 
 /// 
 Task StringSetAsync(string key, T value, TimeSpan? timeout = null);
 /// 

 /// 对数值进行减法操作，默认-1
 /// 
 /// 
 /// 
 /// 操作后的结果
 Task StringDecrementAsync(string key, long value = 1L);
 /// 

 /// 对数值进行加法操作，默认+1
 /// 
 /// 
 /// 
 /// 操作后的结果
 Task StringIncrementAsync(string key, long value = 1L);
 /// 

 /// 从redis string中以指定类型取出
 /// 
 /// 
 /// 
 /// 
 Task StringGetAsync(string key);
 #endregion
 #region Redis数据类型—Hash
 /// 

 /// 向Hash key中存储任意类型任意值
 /// 
 /// 
 /// 
 /// 
 /// 
 /// 是否成功
 Task HashSetAsync(string key, string field, T value);
 /// 

 /// 批量 向Hash key中存储任意类型任意值
 /// 
 /// 
 /// 
 /// 
 /// 无返回值
 Task HashMultiSetAsync(string key, Dictionary hashFields);
 /// 

 /// 对指定hash key中制定field做数量增加操作 默认自增1 
 /// 如果此操作前key不存在 则创建。 如果此操作前该field不存在或者非数字 则先被置0，再被继续操作
 /// 
 /// 
 /// 
 /// 
 /// 操作后的结果
 Task HashIncrementAsync(string key, string field, long incrCount = 1);
 /// 

 /// 对指定hash key中制定field做数量增加操作 默认自减1 
 /// 如果此操作前key不存在 则创建。 如果此操作前该field不存在或者非数字 则先被置0，再被继续操作
 /// 
 /// 
 /// 
 /// 
 /// 操作后的结果
 Task HashDecrementAsync(string key, string field, long decrCount = 1);
 /// 

 /// 从指定Hash中 删除指定field
 /// 如果key或者field不存在，则false
 /// 
 /// 
 /// 
 /// 是否成功
 Task HashDeleteFieldAsync(string key, string field);
 /// 

 /// 从指定Hash key中 批量删除指定field
 /// 如果key或者field不存在，则false
 /// 
 /// 
 /// 
 /// 移除数量
 Task HashMultiDeleteFieldAsync(string key, List fields);
 /// 

 /// 从指定Hash key中获取指定field值
 /// 
 /// 
 /// 
 /// 
 /// 
 Task HashGetAsync(string key, string field);
 /// 

 /// 从指定Hash key中判断field是否存在
 /// 
 /// 
 /// 
 /// 
 Task HashFieldExistAsync(string key, string field);
 /// 

 /// 获取指定Hash key中的所有field的值 
 /// 
 /// 
 /// 
 /// 
 Task> HashValuesAsync(string key);
 /// 

 /// 获取指定Hash key中所有 field名称及其Value
 /// 
 /// 
 /// 
 /// 
 Task> HashGetAllAsync(string key);
 /// 

 /// 获取指定Hash key中所有field
 /// 
 /// 
 /// 
 Task> HashFieldsAsync(string key);
 #endregion
 #region Redis数据类型—List 
 /// 

 /// 在指定pivot后插入value, 如果pivot不存在，则返回-1, 如果key不存在，则返回0
 /// 如果存在多个相同指定的的pivot,则插入第一个指定pivot后面.
 /// 即链表从左向右查找，遇到指定pivot，则确定位置
 /// 
 /// 
 /// 
 /// list中的一个值
 /// 
 /// 
 Task ListInsertAfterAsync(string key, string pivot, T value);
 /// 

 /// 在指定pivot前插入value, 如果pivot不存在，则返回-1, 如果key不存在，则返回0
 /// 如果存在多个相同指定的的pivot,则插入第一个指定pivot前面.
 /// 即链表从左向右查找，遇到指定pivot，则确定位置
 /// 
 /// 
 /// 
 /// 
 /// 
 /// 
 Task ListInsertBeforeAsync(string key, string pivot, T value);
 /// 

 /// 从链表左侧弹出第一个元素（弹出能获取到该元素并且被删除）
 /// 如果key不存在 或者链表为空 则为null
 /// 
 /// 
 /// 
 /// 
 Task ListLeftPopAsync(string key);
 /// 

 /// 从链表左侧增加一个元素,key不存在则被创建
 /// 
 /// 
 /// 
 /// 
 /// 返回操作后的链表长度
 Task ListLeftPushAsync(string key, T value);
 /// 

 /// 从链表左侧批量增加元素，如果 a b c 则c会在链表左侧第一位 b第二位 a第三位
 /// 
 /// 
 /// 
 /// 
 /// 返回操作后的链表长度
 Task ListLeftMultiPushAsync(string key, List values);
 /// 

 /// 获取链表长度，不存在key则为0
 /// 
 /// 
 /// 
 /// 
 Task ListLengthAsync(string key);
 /// 

 /// 获取链表中所有数据，从左侧start开始到stop结束，从0—-1则认为获取全部，默认获取全部
 /// start为负数则代表从链表右侧开始，-1为右侧第一位，-2为右侧第二位
 /// start要小于stop,否则返回null
 /// 
 /// 
 /// 
 /// 
 /// 
 /// 
 Task> ListRangeAsync(string key, long start = 0L, long stop = -1L);
 /// 

 /// 从链表中一处count数量的value. count大于0则从左至右，count小于0则从右至左，count=0则移除全部
 /// 
 /// 
 /// 
 /// 
 /// 
 /// 
 Task ListRemoveAsync(string key, T value, long count = 0L);
 /// 

 /// 从右侧弹出第一个元素（弹出能获取到该元素并且被删除）
 /// 
 /// 
 /// 
 /// 
 Task ListRightPopAsync(string key);
 /// 

 /// 从链表右侧加入元素，如果 rpush a b c 则c为右侧第一位 b第二位 c第三位
 /// 
 /// 
 /// 
 /// 
 /// 
 Task ListRightPushAsync(string key, T value);
 /// 

 /// 从右侧批量插入，和左侧相反
 /// 
 /// 
 /// 
 /// 
 /// 
 Task ListRightMultiPushAsync(string key, List values);
 /// 

 /// 在链表指定索引处，插入元素
 /// 正数索引从0开始，代表左侧。负数从-1开始 代表从右侧。-1为右侧第一位
 /// 
 /// 
 /// 
 /// 
 /// 
 /// 
 Task ListSetByIndexAsync(string key, int index, T value);
 /// 

 /// 留下start到stop之间的数据。负数代表从右侧寻找 -1为右侧第一位
 /// 
 /// 
 /// 
 /// 
 /// 
 Task ListTrimAsync(string key, long start, long stop);
 /// 

 /// 获取指定index的值，负数代表从右侧寻找 -1为右侧第一位
 /// 
 /// 
 /// 
 /// 
 /// 
 Task ListGetByIndexAsync(string key, long index);
 #endregion
 #region Redis数据类型—Set
 /// 

 /// 向指定集合中增加一个元素
 /// 
 /// 
 /// 
 /// 
 /// 
 Task SetAddAsync(string key, T value);
 /// 

 /// 指定集合计算操作operation枚举，指定计算结果将存的目标destKey，指定需要参与计算的多个key
 /// 
 /// 
 /// 
 /// 
 /// 
 Task SetCombineAndStoreAsync(SetOperation operation, string destKey, List combineKeys);
 /// 

 /// 指定集合计算操作operation枚举，指定需要参与计算的多个key
 /// 
 /// 
 /// 
 /// 
 /// 
 Task> SetCombineAsync(SetOperation operation, List combineKeys);
 /// 

 /// 指定值是否存在于指定集合中
 /// 
 /// 
 /// 
 /// 
 /// 
 Task SetContainsAsync(string key, T value);
 /// 

 /// 获取指定集合中元素个数
 /// 
 /// 
 /// 
 Task SetLengthAsync(string key);
 /// 

 /// 获取指定集合中的所有元素
 /// 
 /// 
 /// 
 /// 
 /// 
 Task> SetMembersAsync(string key, T value);
 /// 

 /// 从sourceKey移除指定value到目标distKey集合当中
 /// 如果sourceKey存在指定value则返回true，否则不做任何操作返回false
 /// 
 /// 
 /// 
 /// 
 /// 
 /// 
 Task SetMoveAsync(string sourcekey, string distKey, T value);
 /// 

 /// 从指定集合当中随机取出一个元素
 /// 
 /// 
 /// 
 /// 
 Task SetRandomMemberAsync(string key);
 /// 

 /// 从指定集合随机弹出（删除并获取）一个元素
 /// 
 /// 
 /// 
 /// 
 Task SetPopAsync(string key);
 /// 

 /// 从集合中随机弹出（删除并获取）多个元素
 /// 
 /// 
 /// 
 /// 
 Task> SetRandomMembersAsync(string key);
 /// 

 /// 从集合中移除指定元素
 /// 
 /// 
 /// 
 /// 
 /// 
 Task SetRemoveAsync(string key, T value);
 /// 

 /// 从集合中批量移除元素
 /// 
 /// 
 /// 
 /// 
 /// 
 Task SetMultiRemoveAsync(string key, List values);
 #endregion
 #region Redis数据类型—SortSet
 #endregion
 #region Redis Key操作
 /// 

 /// 删除指定key
 /// 
 /// 
 /// 
 Task KeyDeleteAsync(string key);
 /// 

 /// 设置key过期时间具体DateTime
 /// 
 /// 
 /// 
 /// 
 Task KeyExpireAtAsync(string key, DateTime expireAt);
 /// 

 /// 设置key在将来的timeout后过期（TimeSpan）
 /// 
 /// 
 /// 
 /// 
 Task KeyExpireInAsync(string key, TimeSpan timeout);
 /// 

 /// key重命名
 /// 
 /// 
 /// 
 /// 
 Task KeyRenameAsync(string key, string newKey);
 /// 

 /// 判断key是否已存在
 /// 
 /// 
 /// 
 Task KeyExistsAsync(string key);
 #endregion
 #region Redis Transcation
 /// 

 /// 在事务中执行一系列redis命令。注意：在委托中的一系列命令的所有 值 都需要进行字节数组序列化
 /// 
 /// 
 /// 
 Task DoInTranscationAsync(Action ranOperations);
 #endregion
 Task Test();
 }
}

RedisHelper部分类RedisStringHelperAsync.cs

using System;
using Fantasy.RedisRepository.CommonHelper;
using StackExchange.Redis;
using System.Threading.Tasks;
namespace Fantasy.RedisRepository.RedisHelpers
{
 /// 

 /// Redis异步操作类 String部分类
 /// 
 internal partial class RedisHelper// : IRedisHelper
 {
 private static IDatabase _client;
 
 internal RedisHelper()
 {
  _client = RedisConnection.GenerateConnection.GetDatabase();
 }
 #region String 写操作
 /// 

 /// 将任何数据添加到redis中
 /// 
 /// 
 /// 
 /// 
 /// 
 /// 
 public async Task StringSetAsync(string key, T value, TimeSpan? timeout = null)
 {
  return await _client.StringSetAsync(key, SerializeHelper.Serialize(value), timeout); 
 }
 public async Task StringDecrementAsync(string key, long value = 1L)
 {
  return await _client.StringDecrementAsync(key, value);
 }
 public async Task StringIncrementAsync(string key, long value = 1L)
 {
  return await _client.StringIncrementAsync(key, value);
 }
 #endregion
 #region String 读操作
 /// 

 /// 根据key获取指定类型数据
 /// 
 /// 
 /// 
 /// 
 public async Task StringGetAsync(string key)
 {
  return SerializeHelper.Deserialize(await _client.StringGetAsync(key, CommandFlags.PreferSlave));
 }
 #endregion
 }
}

RedisHelper部分类RedisHashHelperAsync.cs

using Fantasy.RedisRepository.CommonHelper;
using StackExchange.Redis;
using System.Collections.Generic;
using System.Linq;
using System.Threading.Tasks;
namespace Fantasy.RedisRepository.RedisHelpers
{
 /// 

 /// Redis异步操作类 Hash部分类
 /// 
 internal partial class RedisHelper
 {
 #region Hash 写操作
 public async Task HashSetAsync(string key, string field, T value)
 {
  return await _client.HashSetAsync(key, field, SerializeHelper.Serialize(value));
 }
 public async Task HashMultiSetAsync(string key, Dictionary hashFields)
 {
  List entries = new List();
  hashFields.ToList().ForEach(d => entries.Add(new HashEntry(d.Key, SerializeHelper.Serialize(d.Value))));
  await _client.HashSetAsync(key, entries.ToArray());
 }
 public async Task HashIncrementAsync(string key, string field, long incrCount = 1)
 {
  return await _client.HashIncrementAsync(key, field, incrCount);
 }
 public async Task HashDecrementAsync(string key, string field, long decrCount = 1)
 {
  return await _client.HashDecrementAsync(key, field, decrCount);
 }
 public async Task HashDeleteFieldAsync(string key, string field)
 {
  return await _client.HashDeleteAsync(key, field);
 }
 public async Task HashMultiDeleteFieldAsync(string key, List fields)
 {
  List values = new List();
  fields.ForEach(f => values.Add(f));
  return await _client.HashDeleteAsync(key, values.ToArray());
 }
 #endregion
 #region Hash 读操作
 /// 

 /// Redis 指定hash类型key中field是否存在
 /// 
 /// 
 /// 
 /// 
 public async Task HashFieldExistAsync(string key, string field)
 {
  return await _client.HashExistsAsync(key, field, CommandFlags.PreferSlave);
 }
 public async Task> HashFieldsAsync(string key)
 {
  RedisValue[] values = await _client.HashKeysAsync(key, CommandFlags.PreferSlave);
  return RedisInnerTypeHelper.RedisValuesToGenericList(values);
 }
 public async Task> HashValuesAsync(string key)
 {
  var values = await _client.HashValuesAsync(key, CommandFlags.PreferSlave);
  return RedisInnerTypeHelper.RedisValuesToGenericList(values);
 }
 public async Task HashGetAsync(string key, string field)
 {
  return SerializeHelper.Deserialize(await _client.HashGetAsync(key, field, CommandFlags.PreferSlave));
 }
 public async Task> HashGetAllAsync(string key)
 {
  HashEntry[] entries = await _client.HashGetAllAsync(key, CommandFlags.PreferSlave);
  Dictionary dic = new Dictionary();
  entries.ToList().ForEach(e => dic.Add(e.Name, SerializeHelper.Deserialize(e.Value)));
  return dic;
 }
 #endregion
 }
}

RedisHelper部分类RedisListHelperAsync.cs

using Fantasy.RedisRepository.CommonHelper;
using StackExchange.Redis;
using System.Collections.Generic;
using System.Linq;
using System.Threading.Tasks;
namespace Fantasy.RedisRepository.RedisHelpers
{
 /// 

 /// Redis异步操作类 Hash部分类
 /// 
 internal partial class RedisHelper
 {
 #region Hash 写操作
 public async Task HashSetAsync(string key, string field, T value)
 {
  return await _client.HashSetAsync(key, field, SerializeHelper.Serialize(value));
 }
 public async Task HashMultiSetAsync(string key, Dictionary hashFields)
 {
  List entries = new List();
  hashFields.ToList().ForEach(d => entries.Add(new HashEntry(d.Key, SerializeHelper.Serialize(d.Value))));
  await _client.HashSetAsync(key, entries.ToArray());
 }
 public async Task HashIncrementAsync(string key, string field, long incrCount = 1)
 {
  return await _client.HashIncrementAsync(key, field, incrCount);
 }
 public async Task HashDecrementAsync(string key, string field, long decrCount = 1)
 {
  return await _client.HashDecrementAsync(key, field, decrCount);
 }
 public async Task HashDeleteFieldAsync(string key, string field)
 {
  return await _client.HashDeleteAsync(key, field);
 }
 public async Task HashMultiDeleteFieldAsync(string key, List fields)
 {
  List values = new List();
  fields.ForEach(f => values.Add(f));
  return await _client.HashDeleteAsync(key, values.ToArray());
 }
 #endregion
 #region Hash 读操作
 /// 

 /// Redis 指定hash类型key中field是否存在
 /// 
 /// 
 /// 
 /// 
 public async Task HashFieldExistAsync(string key, string field)
 {
  return await _client.HashExistsAsync(key, field, CommandFlags.PreferSlave);
 }
 public async Task> HashFieldsAsync(string key)
 {
  RedisValue[] values = await _client.HashKeysAsync(key, CommandFlags.PreferSlave);
  return RedisInnerTypeHelper.RedisValuesToGenericList(values);
 }
 public async Task> HashValuesAsync(string key)
 {
  var values = await _client.HashValuesAsync(key, CommandFlags.PreferSlave);
  return RedisInnerTypeHelper.RedisValuesToGenericList(values);
 }
 public async Task HashGetAsync(string key, string field)
 {
  return SerializeHelper.Deserialize(await _client.HashGetAsync(key, field, CommandFlags.PreferSlave));
 }
 public async Task> HashGetAllAsync(string key)
 {
  HashEntry[] entries = await _client.HashGetAllAsync(key, CommandFlags.PreferSlave);
  Dictionary dic = new Dictionary();
  entries.ToList().ForEach(e => dic.Add(e.Name, SerializeHelper.Deserialize(e.Value)));
  return dic;
 }
 #endregion
 }
}

RedisLuaHelper.cs 这里打算装一些功能行lua脚本， 外部依然是传key一类的参数，这个不完整，只是个实例。

using StackExchange.Redis;
using System.Threading.Tasks;
namespace Fantasy.RedisRepository.RedisHelpers
{
 internal partial class RedisHelper
 {
 public async Task LuaMutilGetHash()
 {
  string lua = @"local result={}
  for i, v in ipairs(KEYS) do
   result[i] = redis.call('hgetall',v) 
  end
  return result";
  var res = await _client.ScriptEvaluateAsync(lua, new RedisKey[] { "people:1", "people:2", "people:3" });
  var res1= LuaScript.GetCachedScriptCount();
  return res;
 }
 }
}

关于Transcation的封装，我个人没有什么好的方法，提供了这样一个方法

public async Task DoInTranscationAsync(Action runOperations)
 {
  var tran = RedisConnection.GenerateConnection.GetDatabase().CreateTransaction();
  runOperations(tran);
  return await tran.ExecuteAsync();
 }

RedisFactory.cs

using Fantasy.RedisRepository.RedisHelpers;
 
namespace Fantasy.RedisRepository
{
 public class RedisFactory
 {
 /// 

 /// 外部访问redis入口，暂时只暴露异步方法
 /// 
 /// 
 public static IRedisHelper CreateRedisRepository()
 {
  return new RedisHelper();
 }
 }
}

以上就是本文的全部内容，希望本文的内容对大家的学习或者工作能带来一定的帮助，同时也希望多多支持PHP中文网！

更多RedisRepository 分享和纠错相关文章请关注PHP中文网！