一. 写在前面
毕业工作后，今天终于能回家了，回想了一些这半年来所做的内容，总是觉得还停留在那么基础的水平 ，在解决各种问题的过程中，自己的创新思路比较少，靠搜索来的比较多 。不想做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
using System.IO; using System.Runtime.Serialization.Formatters.Binary; namespace Fantasy.RedisRepository.CommonHelper { internal static class SerializeHelper { /// <summary> /// 字节数组序列化 /// </summary> /// <param></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></typeparam> /// <param></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; } } } }
Config中的配置类：
ConfigHelper.cs