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         {
　　　　　　　　...