1.ServiceStack.Redis封装
封装的Redis操作类名为RedisHandle,如下代码块(只展示部分代码),它的特点:
1)使用连接池管理连接,见代码中的PooledClientManager属性。如果不用连接池,而是代码直接RedisClient client = new RedisClient("localhost", 6379, "password");去获取一个连接实例操作,那么当Redis操作频繁时,代价很大,不可行。
2)支持读写分离的Redis服务端(如果你只用一个Redis服务端,那么读写服务端连接字符串一样即可)。
3)操作Redis时,自动切换读写Redis连接实例,见代码中的GetRedisClient函数,所有写操作取“写连接实例”PooledClientManager.GetClient(),所有读操作取“读连接实例”PooledClientManager.GetReadOnlyClient()。
注意:如果你读写是两个做了主从复制的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; 17 18 /// <summary> 19 /// 构造函数 20 /// </summary> 21 /// <param></param> 22 public RedisHandle() 23 { 24 #region 此代码为创建“连接池示例”,配置信息直接用静态类RedisClientConfig1承载,你也可以选择用配置文件承载 25 var config = new RedisClientManagerConfig 26 { 27 AutoStart = true, 28 MaxWritePoolSize = RedisClientConfig1.MaxWritePoolSize, 29 MaxReadPoolSize = RedisClientConfig1.MaxReadPoolSize, 30 DefaultDb = RedisClientConfig1.DefaultDb, 31 }; 32 //如果你只用到一个Redis服务端,那么配置读写时就指定一样的连接字符串即可。 33 PooledClientManager = new PooledRedisClientManager(RedisClientConfig1.ReadWriteServers 34 , RedisClientConfig1.ReadOnlyServers, config) 35 { 36 ConnectTimeout = RedisClientConfig1.ConnectTimeout, 37 SocketSendTimeout = RedisClientConfig1.SendTimeout, 38 SocketReceiveTimeout = RedisClientConfig1.ReceiveTimeout, 39 IdleTimeOutSecs = RedisClientConfig1.IdleTimeOutSecs, 40 PoolTimeout = RedisClientConfig1.PoolTimeout 41 }; 42 #endregion 43 } 44 /// <summary> 45 /// 构造函数 46 /// </summary> 47 /// <param></param> 48 public RedisHandle(PooledRedisClientManager poolManager) 49 { 50 //也可外部传入自己创建的PooledRedisClientManager对象 51 PooledClientManager = poolManager; 52 } 53 /// <summary> 54 /// 获取Redis客户端连接实例,有连接池管理。 55 /// </summary> 56 /// <param>是否取只读连接。Get操作一般是读,Set操作一般是写</param> 57 /// <param>一个Redis服务端默认有16个数据库,默认都是用第0个数据库。如果需要切换数据库,则传入db值(0~15)</param> 58 /// <returns></returns> 59 public RedisClient GetRedisClient(bool isReadOnly = false, int db = 0) 60 { 61 RedisClient result; 62 if (!isReadOnly) 63 { 64 //RedisClientManager.GetCacheClient()会返回一个新实例,而且只提供一小部分方法,它的作用是帮你判断是否用写实例还是读实例 65 result = PooledClientManager.GetClient() as RedisClient; 66 } 67 else 68 { 69 //如果你读写是两个做了主从复制的Redis服务端,那么要考虑主从复制是否有延迟。有一些读操作是否是即时的,需要在写实例中获取。 70 result = PooledClientManager.GetReadOnlyClient() as RedisClient; 71 } 72 73 if (db > 0) 74 result.ChangeDb(db); 75 return result; 76 } 77 78 #region 存储单值 key-value,其中value是string,使用时如果value是int,可以把比如int转成string存储 79 public void SetValue(string key, string value, int expirySeconds = -1) 80 { 81 using (RedisClient redisClient = GetRedisClient()) 82 { 83 //redisClient.SetEntry(key, value, expireIn); 84 if (expirySeconds == -1) 85 { 86 redisClient.SetValue(key, value); 87 } 88 else 89 { 90 redisClient.SetValue(key, value, new TimeSpan(0, 0, 0, expirySeconds)); 91 } 92 } 93 } 94 95 public string GetValue(string key) 96 { 97 using (RedisClient redisClient = GetRedisClient(true)) 98 { 99 var val = redisClient.GetValue(key); 100 101 return val; 102 } 103 } 104 105 public bool Remove(string key) 106 { 107 ...