Redis之Hash___redis中哈希(Hash)在.net中的运用

2331

一、下载redis安装文件redis-2.4.6-setup-32-bit.exe。这里一个32位的，本人现在用的XP系统，貌似影响不是很大。详情附件。

安装好之后在服务里面启动

二、用vs新建一个小程序，引用4个redis需要的dll文件，详情附件。


三、建一个RedisHelper类,引用4个dll。

1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 112 113 114 115 116 117 118 119 120 121 122 123 124 125 126 127 128 129 130 131 132 133 134 135 136 137 138 139 140 141 142 143 144 145 146 147 148 149 150 151 152 153 154 155 156 157 158 159 160 161 162 163 164 165 166 167 168 169 170 171 172 173 174 175 176 177 178 179 180 181 182 183

public class RedisHelper : IDisposable     {         private static string strRedis = System.Configuration.ConfigurationManager.AppSettings["RedisPath"].ToString();//web.config中配置我本机的一个IP         public RedisClient Redis = new RedisClient(strRedis, 6379);         //缓存池         PooledRedisClientManager prcm = new PooledRedisClientManager();         //默认缓存过期时间单位秒         public int secondsTimeOut = 30 * 60;         /// <summary>         /// 缓冲池         /// </summary>         /// <param name="readWriteHosts"></param>         /// <param name="readOnlyHosts"></param>         /// <returns></returns>         public static PooledRedisClientManager CreateManager(          string[] readWriteHosts, string[] readOnlyHosts)         {             return new PooledRedisClientManager(readWriteHosts, readOnlyHosts,                 new RedisClientManagerConfig                 {                     MaxWritePoolSize = readWriteHosts.Length * 5,                     MaxReadPoolSize = readOnlyHosts.Length * 5,                     AutoStart = true,                 });         }         /// <summary>         /// 构造函数         /// </summary>         /// <param name="OpenPooledRedis">是否开启缓冲池</param>         public RedisHelper(bool OpenPooledRedis = false)         {             if (OpenPooledRedis)             {                 prcm = CreateManager(new string[] { strRedis + ":6379" }, new string[] { strRedis + ":6379" });                 Redis = prcm.GetClient() as RedisClient;             }         }         #region Key/Value存储         /// <summary>         /// 设置缓存         /// </summary>         /// <typeparam name="T"></typeparam>         /// <param name="key">缓存建</param>         /// <param name="t">缓存值</param>         /// <param name="timeout">过期时间，单位秒,-1：不过期，0：默认过期时间</param>         /// <returns></returns>         public bool Set<T>(string key, T t, int timeout = 0)         {             if (timeout >= 0)             {                 if (timeout > 0)                 {                     secondsTimeOut = timeout;                 }                 Redis.Expire(key, secondsTimeOut);             }             return Redis.Add<T>(key, t);         }         /// <summary>         /// 获取(根据key来获取value)         /// </summary>         /// <typeparam name="T"></typeparam>         /// <param name="key"></param>         /// <returns></returns>         public T Get<T>(string key)         {             return Redis.Get<T>(key);         }         /// <summary>         /// 移除整个类型的key         /// </summary>         /// <param name="key"></param>         /// <returns></returns>         public bool Remove(string key)         {             return Redis.Remove(key);         }         /// <summary>         /// key是否存在(0:不存在；1;存在)         /// </summary>         /// <param name="key"></param>         /// <returns></returns>         public int IsExists(string key)         {             return Convert.ToInt32(Redis.Exists(key));         }         public bool Add<T>(string key, T t, int timeout)         {             if (timeout >= 0)             {                 if (timeout > 0)                 {                     secondsTimeOut = timeout;                 }                 Redis.Expire(key, secondsTimeOut);             }             return Redis.Add<T>(key, t);         }         #endregion         /// <summary>         /// 释放资源         /// </summary>         public void Dispose()         {             if (Redis != null)             {                 Redis.Dispose();                 Redis = null;             }             GC.Collect();         }         #region Hash的方法         /// <summary>         /// 判断某个数据是否已经被缓存         /// </summary>         public bool Exist<T>(string hashId, string key)         {             return Redis.HashContainsEntry(hashId, key);         }         /// <summary>         /// 存储数据到hash表         /// </summary>         public bool Set1<T>(string hashId, string key, string value)         {             return Redis.SetEntryInHash(hashId, key, value);         }         /// <summary>         /// 移除hash中的某值         /// </summary>         public bool Remove(string hashId, string key)         {             return Redis.RemoveEntryFromHash(hashId, key);         }         /// <summary>         /// 从hash表获取数据         /// </summary>         public string Get1<T>(string hashId, string key)         {             return Redis.GetValueFromHash(hashId, key);         }         /// <summary>         /// 获取整个hash的数据         /// </summary>         public string GetAll1(string hashId)         {             string result = "";             var list = Redis.GetHashValues(hashId);             if (list != null && list.Count > 0)             {                 for (int i = 0; i < list.Count; i++)                 {                     var aa = list;                     result += aa + ",";                 }                 result = result.Trim(',');             }             return result;         }         /// <summary>         /// 设置缓存过期         /// </summary>         public void SetExpire(string key, DateTime datetime)         {             Redis.ExpireEntryAt(key, datetime);         }         #endregion     }

四、再建一个ashx一般处理程序。

1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39

public class UserTest     {         public int userId { get; set; }         public string userName { get; set; }         public string userPwd { get; set; }         public int userAge { get; set; }     }     public class RedisSelectTset1 : IHttpHandler     {         public void ProcessRequest(HttpContext context)         {             context.Response.ContentType = "text/plain";             RedisHelper redis = new RedisHelper(true);             UserTest user = null;             for (int i = 0; i < 10; i++)             {                 user = new UserTest() { userId = i, userName = "admin" + i, userPwd = "123456", userAge = 20 + i };                 var value = JsonSerializer.SerializeToString<UserTest>(user);//序列化json格式                 redis.Set1<byte>("userHash", "user_Id" + i, value);//第一插入返回Ture，覆盖重复的返回Flash             }             string getAll = redis.GetAll1("userHash");//获得所有的数据             DateTime dateTime = Convert.ToDateTime("2099-12-31 00:00:00");//设置缓存过期时间             redis.SetExpire("userHash", dateTime);             context.Response.Write(getAll);         }         public bool IsReusable         {             get             {                 return false;             }         }     }

运行页面之后如何显示：

之后可以在cmd中打开客户端链接：hgetall userHash 根据key取出所有的value
就能在你的内存中看到你刚刚运行的页面保存的数据
根据redis的命令，可以去除单条数据，如何下图：

关于redis跟多有趣的东西，楼主也在尝试。
redis安装文件和客户端服务端.zip (1.2 MB, 下载次数: 0)

2016-1-7 09:18 上传

点击文件名下载附件

redis引用的dll文件.zip (322.09 KB, 下载次数: 0)

2016-1-7 09:18 上传

点击文件名下载附件