封装的Redis操做类名为RedisHandle,以下代码块(只展现部分代码),它的特色:html
1)使用链接池管理链接,见代码中的PooledClientManager属性。若是不用链接池,而是代码直接RedisClient client = new RedisClient("localhost", 6379, "password");去获取一个链接实例操做,那么当Redis操做频繁时,代价很大,不可行。git
2)支持读写分离的Redis服务端(若是你只用一个Redis服务端,那么读写服务端链接字符串同样便可)。github
3)操做Redis时,自动切换读写Redis链接实例,见代码中的GetRedisClient函数,全部写操做取“写链接实例”PooledClientManager.GetClient(),全部读操做取“读链接实例”PooledClientManager.GetReadOnlyClient()。redis
注意:若是你读写是两个作了主从复制的Redis服务端,那么要考虑主从复制是否有延迟,是否有一些读操做要求实时数据,若是是,那么须要在GetXX读数据时用写链接实例。这时候,能够改写此GetXX函数,可在函数参数末尾增长 bool? isReadOnly = null 带默认值的参数,即支持外部调用指定用哪一种链接实例操做。这种状况通常是系统把Redis看成一个NoSql数据库;而更多时候咱们系统是把Redis看成一个缓存,不须要作主从复制,读写链接实例指向的是同一个Redis服务端,当系统比较大时可能会用到缓存集群(好比一致性哈希缓存等)。算法
4)后继若是Redis须要作一致性哈希等集群,那么能够实例化多个RedisHandle实例,而后撰写算法来取相应的RedisHandle实例。 数据库
1 namespace NetDh.RedisUtility 2 { 3 /* 4 * 一个RedisHandle实例对应一个Redis服务端或者一组主从复制Redis服务端。 5 * 若是Redis须要作一致性哈希等集群,则要本身撰写算法来取相应的RedisHandle实例。 6 */ 7 8 /// <summary> 9 /// Redis操做类 10 /// </summary> 11 public class RedisHandle 12 { 13 /// <summary> 14 /// Redis链接池管理实例 15 /// </summary> 16 public PooledRedisClientManager PooledClientManager { get; set; } 17 18 /* 若是你的需求须要常常切换Redis数据库,则可把Db当属性,这样每个RedisHandle实例能够对应操做某Redis的某个数据库。此时,可在构造函数中增长int db参数。*/ 19 ///// <summary> 20 ///// 一个Redis服务端默认有16个数据库,默认都是用第0个数据库。若是须要切换数据库,则传入db值(0~15) 21 ///// </summary> 22 //public int Db { get; set; } 23 24 /// <summary> 25 /// 构造函数 26 /// </summary> 27 public RedisHandle() 28 { 29 #region 此代码为建立“链接池示例”,配置信息直接用静态类RedisClientConfig1承载,你也能够选择用配置文件承载 30 var config = new RedisClientManagerConfig 31 { 32 AutoStart = true, 33 MaxWritePoolSize = RedisClientConfig1.MaxWritePoolSize, 34 MaxReadPoolSize = RedisClientConfig1.MaxReadPoolSize, 35 DefaultDb = RedisClientConfig1.DefaultDb, 36 }; 37 //若是你只用到一个Redis服务端,那么配置读写时就指定同样的链接字符串便可。 38 PooledClientManager = new PooledRedisClientManager(RedisClientConfig1.ReadWriteServers 39 , RedisClientConfig1.ReadOnlyServers, config) 40 { 41 ConnectTimeout = RedisClientConfig1.ConnectTimeout, 42 SocketSendTimeout = RedisClientConfig1.SendTimeout, 43 SocketReceiveTimeout = RedisClientConfig1.ReceiveTimeout, 44 IdleTimeOutSecs = RedisClientConfig1.IdleTimeOutSecs, 45 PoolTimeout = RedisClientConfig1.PoolTimeout 46 }; 47 #endregion 48 } 49 /// <summary> 50 /// 构造函数 51 /// </summary> 52 /// <param name="poolManager">链接池,外部传入本身建立的PooledRedisClientManager链接池对象, 53 /// 能够把其它RedisHandle实例的PooledClientManager传入,共用链接池</param> 54 public RedisHandle(PooledRedisClientManager poolManager) 55 { 56 PooledClientManager = poolManager; 57 58 } 59 /// <summary> 60 /// 获取Redis客户端链接对象,有链接池管理。 61 /// </summary> 62 /// <param name="isReadOnly">是否取只读链接。Get操做通常是读,Set操做通常是写</param> 63 /// <returns></returns> 64 public RedisClient GetRedisClient(bool isReadOnly = false) 65 { 66 RedisClient result; 67 if (!isReadOnly) 68 { 69 //RedisClientManager.GetCacheClient()会返回一个新实例,并且只提供一小部分方法,它的做用是帮你判断是否用写实例仍是读实例 70 result = PooledClientManager.GetClient() as RedisClient; 71 } 72 else 73 { 74 //若是你读写是两个作了主从复制的Redis服务端,那么要考虑主从复制是否有延迟。有一些读操做是不是即时的,须要在写实例中获取。 75 result = PooledClientManager.GetReadOnlyClient() as RedisClient; 76 } 77 //若是你的需求须要常常切换Redis数据库,则下一句能够用。不然通常都只用默认0数据库,集群是没有数据库的概念。 78 //result.ChangeDb(Db); 79 return result; 80 } 81 82 #region 存储单值 key-value,其中value是string,使用时若是value是int,能够把好比int转成string存储 83 public void SetValue(string key, string value, int expirySeconds = -1) 84 { 85 using (RedisClient redisClient = GetRedisClient()) 86 { 87 //redisClient.SetEntry(key, value, expireIn); 88 if (expirySeconds == -1) 89 { 90 redisClient.SetValue(key, value); 91 } 92 else 93 { 94 redisClient.SetValue(key, value, new TimeSpan(0, 0, 0, expirySeconds)); 95 } 96 } 97 } 98 99 public string GetValue(string key) 100 { 101 using (RedisClient redisClient = GetRedisClient(true)) 102 { 103 var val = redisClient.GetValue(key); 104 105 return val; 106 } 107 } 108 109 public bool Remove(string key) 110 {
...
5)在GetRedisClient函数中有句注释的代码//result.ChangeDb(Db);。其中,ChangeDb是切换Redis数据库(Redis默认有16个数据库,见redis-server.exe目录下的redis.conf配置文件中的“databases 16”)。咱们通常默认都是用第0个数据库,若是须要切换数据库,则传入Db值(0~15)。我这边通常不会用到切换数据库的需求,若是你的需求须要常常切换Redis数据库,此句可用。不然通常都只用默认0数据库,集群是没有数据库的概念。缓存
为了说明一个Redis服务端有多个数据库以及数据库之间的切换,作个小示例,以下图,我在Redis的第0个数据库存放了键值对数据"test2:1",当我切到第1个数据库ChangeDb(1)时,GetValue("test2")返回的是null,当切回第0个数据库时,就取到1的值。框架
如今用命令登陆Redis再演示一遍这个过程,以下图:编辑器
6)RedisHandle操做类包含的操做,大体以下图,Redis支持的数据类型比Memcache多,并且很实用,若是你的系统存取缓存会涉及比较复杂的逻辑,推荐使用Redis,Memcache能的Redis都能。函数
完整的源码请参考:https://gitee.com/donghan/NetDh-Framework/tree/master/Data/NetDh.RedisUtility
此工具类已经并到个人NetDh框架项目中,NetDh框架码云地址:https://gitee.com/donghan/NetDh-Framework
我这边封装的是ServiceStack.Redis最新版本5.7.0,它在4.0版本以后就商业化,有作限制:每小时只能有6000次的Redis访问。网上有对ServiceStack.Redis和StackExchange.Reids进行比较,结果是前者性能比较好,无论真假,我是ServiceStack.Redis 3.x就开始用它了,一如既往继续用呗,有限制就破解呗。
步骤:
1)限制6000次是在ServiceStack.Text.dll中,并且在两个地方,用ILSpy打开ServiceStack.Text.dll,在搜索栏输入“RedisRequestPerHour”,能够看到RedisRequestPerHour=6000的限制,以下图(第1步你可不作,看看就好):
再搜索“AssertValidUsage”,发现另外一个地方的6000次限制,以下图:
2)下载一个十六进制编辑器,我网上找的是wxMEdit工具(下载页面:http://wxmedit.github.io/downloads.html)。
3)先备份ServiceStack.Text.dll,用十六进制编辑器打开ServiceStack.Text.dll。
分析:6000转换成字节形式是 70 17 00 00(虽然6000的16进制是00001770),int的最大值2147483647转换成字节形式是 FF FF FF 7F,因此只要把70 17 00 00替换成FF FF FF 7F便可。
以下图,替换以前点了“查找下一个”发现全局就两个地方,那就肯定是要修改的值,而后点击“替换”两次,ctrl+s保存文件,dll修改完成。
4)再用ILSpy看这两个值,已经修改了,以下图(第4步你也可不作,看看就好):
5)把修改的dll覆盖原来dll,最好在IDE中把原来的引用移除,从新添加引用一次,以防有缓存执行的仍是旧的dll。编写以下代码测试:
覆盖dll以前会报6000限制,覆盖以后输出ok正常:
完美,点赞!