设为首页 加入收藏

TOP

ServiceStack.Redis高效封装和简易破解(一)
2019-10-09 19:59:04 】 浏览:104
Tags:ServiceStack.Redis 高效 封装 简易 破解

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 name="poolManager"></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 name="poolManager"></param>
 48         public RedisHandle(PooledRedisClientManager poolManager)
 49         {
 50             //也可外部传入自己创建的PooledRedisClientManager对象
 51             PooledClientManager = poolManager;
 52         }
 53         /// <summary>
 54         /// 获取Redis客户端连接实例,有连接池管理。
 55         /// </summary>
 56         /// <param name="isReadOnly">是否取只读连接。Get操作一般是读,Set操作一般是写</param>
 57         /// <param name="db">一个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 = PooledC
首页 上一页 1 2 下一页 尾页 1/2/2
】【打印繁体】【投稿】【收藏】 【推荐】【举报】【评论】 【关闭】 【返回顶部
上一篇wpf dual monitor 下一篇C# QRBarCode

最新文章

热门文章

Hot 文章

Python

C 语言

C++基础

大数据基础

linux编程基础

C/C++面试题目