redis在.net架构中的应用(1)利用servicestack连接redis

1 using System;2 using System.Collections.Generic;3 using System.Linq;4 using System.Text;5 using System.Threading.Tasks;6 using ServiceStack.Redis;7 namespace TestRedis8 {9 class RedisHelper:IDisposable10 {11 /*copyright&＃64;2013 All Rights Reserved12 * Author:Mars13 * Date:2013.08.2714 * QQ:25824834015 * servicestack.redis为github中的开源项目16 * redis是一个典型的k/v型数据库17 * redis共支持五种类型的数据 string,list,hash,set,sortedset18 * 19 * string是最简单的字符串类型20 * 21 * list是字符串列表&＃xff0c;其内部是用双向链表实现的&＃xff0c;因此在获取/设置数据时可以支持正负索引22 * 也可以将其当做堆栈结构使用23 * 24 * hash类型是一种字典结构&＃xff0c;也是最接近RDBMS的数据类型&＃xff0c;其存储了字段和字段值的映射&＃xff0c;但字段值只能是25 * 字符串类型&＃xff0c;散列类型适合存储对象&＃xff0c;建议使用对象类别和ID构成键名&＃xff0c;使用字段表示对象属性&＃xff0c;字26 * 段值存储属性值&＃xff0c;例如&＃xff1a;car:2 price 500 ,car:2 color black,用redis命令设置散列时&＃xff0c;命令格式27 * 如下&＃xff1a;HSET key field value&＃xff0c;即key&＃xff0c;字段名&＃xff0c;字段值28 * 29 * set是一种集合类型&＃xff0c;redis中可以对集合进行交集&＃xff0c;并集和互斥运算30 * 31 * sorted set是在集合的基础上为每个元素关联了一个“分数”&＃xff0c;我们能够32 * 获得分数最高的前N个元素&＃xff0c;获得指定分数范围内的元素&＃xff0c;元素是不同的&＃xff0c;但是"分数"可以是相同的33 * set是用散列表和跳跃表实现的&＃xff0c;获取数据的速度平均为o(log(N))34 * 35 * 需要注意的是&＃xff0c;redis所有数据类型都不支持嵌套36 * redis中一般不区分插入和更新操作&＃xff0c;只是命令的返回值不同37 * 在插入key时&＃xff0c;如果不存在&＃xff0c;将会自动创建38 * 39 * 在实际生产环境中&＃xff0c;由于多线程并发的关系&＃xff0c;建议使用连接池&＃xff0c;本类只是用于测试简单的数据类型40 */41 42 /*43 * 以下方法为基本的设置数据和取数据44 */45 private static RedisClient redisCli &＃61; null;46 ///

47 /// 建立redis长连接48 ///

49 /// 将此处的IP换为自己的redis实例IP&＃xff0c;如果设有密码&＃xff0c;第三个参数为密码&＃xff0c;string 类型50 public static void CreateClient(string hostIP,int port,string keyword)51 {52 if (redisCli &＃61;&＃61; null)53 {54 redisCli &＃61; new RedisClient(hostIP, port, keyword);55 }56 57 }58 public static void CreateClient(string hostIP, int port)59 {60 if (redisCli &＃61;&＃61; null)61 {62 redisCli &＃61; new RedisClient(hostIP, port);63 }64 65 }66 //private static RedisClient redisCli &＃61; new RedisClient("192.168.101.165", 6379, "123456");67 ///

68 /// 获取key,返回string格式69 ///

70 /// 71 /// 72 public static string getValueString(string key)73 {74 75 string value &＃61; redisCli.GetValue(key);76 return value;77 78 79 }80 ///

81 /// 获取key,返回byte[]格式82 ///

83 /// 84 /// 85 public static byte[] getValueByte(string key)86 {87 byte[] value &＃61; redisCli.Get(key);88 return value;89 }90 ///

91 /// 获得某个hash型key下的所有字段92 ///

93 /// 94 /// 95 public static List GetHashFields(string hashId)96 {97 List hashFields &＃61; redisCli.GetHashKeys(hashId);98 return hashFields;99 }
100 ///

101 /// 获得某个hash型key下的所有值
102 ///

103 ///
104 ///
105 public static List GetHashValues(string hashId)
106 {
107 List hashValues &＃61; redisCli.GetHashKeys(hashId);
108 return hashValues;
109 }
110 ///

111 /// 获得hash型key某个字段的值
112 ///

113 ///
114 ///
115 public static string GetHashField(string key, string field)
116 {
117 string value &＃61; redisCli.GetValueFromHash(key, field);
118 return value;
119 }
120 ///

121 /// 设置hash型key某个字段的值
122 ///

123 ///
124 ///
125 ///
126 public static void SetHashField(string key, string field, string value)
127 {
128 redisCli.SetEntryInHash(key, field, value);
129 }
130 ///

131 ///使某个字段增加
132 ///

133 ///
134 ///
135 ///
136 public static void SetHashIncr(string key, string field, long incre)
137 {
138 redisCli.IncrementValueInHash(key, field, incre);
139
140 }
141 ///

142 /// 向list类型数据添加成员&＃xff0c;向列表底部(右侧)添加
143 ///

144 ///
145 ///
146 public static void AddItemToListRight(string list, string item)
147 {
148 redisCli.AddItemToList(list, item);
149 }
150 ///

151 /// 向list类型数据添加成员&＃xff0c;向列表顶部(左侧)添加
152 ///

153 ///
154 ///
155 public static void AddItemToListLeft(string list, string item)
156 {
157 redisCli.LPush(list, Encoding.Default.GetBytes(item));
158 }
159 ///

160 /// 从list类型数据读取所有成员
161 ///

162 public static List GetAllItems(string list)
163 {
164 List listMembers &＃61; redisCli.GetAllItemsFromList(list);
165 return listMembers;
166 }
167 ///

168 /// 从list类型数据指定索引处获取数据&＃xff0c;支持正索引和负索引
169 ///

170 ///
171 ///
172 public static string GetItemFromList(string list, int index)
173 {
174 string item &＃61; redisCli.GetItemFromList(list, index);
175 return item;
176 }
177 ///

178 /// 向列表底部&＃xff08;右侧&＃xff09;批量添加数据
179 ///

180 ///
181 ///
182 public static void GetRangeToList(string list, List values)
183 {
184 redisCli.AddRangeToList(list, values);
185 }
186 ///

187 /// 向集合中添加数据
188 ///

189 ///
190 ///
191 public static void GetItemToSet(string item, string set)
192 {
193 redisCli.AddItemToSet(item, set);
194 }
195 ///

196 /// 获得集合中所有数据
197 ///

198 ///
199 ///
200 public static HashSet GetAllItemsFromSet(string set)
201 {
202 HashSet items &＃61; redisCli.GetAllItemsFromSet(set);
203 return items;
204 }
205 ///

206 /// 获取fromSet集合和其他集合不同的数据
207 ///

208 ///
209 ///
210 ///
211 public static HashSet GetSetDiff(string fromSet, params string[] toSet)
212 {
213 HashSet diff &＃61; redisCli.GetDifferencesFromSet(fromSet, toSet);
214 return diff;
215 }
216 ///

217 /// 获得所有集合的并集
218 ///

219 ///
220 ///
221 public static HashSet GetSetUnion(params string[] set)
222 {
223 HashSet union &＃61; redisCli.GetUnionFromSets(set);
224 return union;
225 }
226 ///

227 /// 获得所有集合的交集
228 ///

229 ///
230 ///
231 public static HashSet GetSetInter(params string[] set)
232 {
233 HashSet inter &＃61; redisCli.GetIntersectFromSets(set);
234 return inter;
235 }
236 ///

237 /// 向有序集合中添加元素
238 ///

239 ///
240 ///
241 ///
242 public static void AddItemToSortedSet(string set,string value,long score)
243 {
244 redisCli.AddItemToSortedSet(set,value,score);
245 }
246 ///

247 /// 获得某个值在有序集合中的排名&＃xff0c;按分数的降序排列
248 ///

249 ///
250 ///
251 ///
252 public static int GetItemIndexInSortedSetDesc(string set, string value)
253 {
254 int index &＃61; redisCli.GetItemIndexInSortedSetDesc(set, value);
255 return index;
256 }
257 ///

258 /// 获得某个值在有序集合中的排名&＃xff0c;按分数的升序排列
259 ///

260 ///
261 ///
262 ///
263 public static int GetItemIndexInSortedSet(string set, string value)
264 {
265 int index &＃61; redisCli.GetItemIndexInSortedSet(set, value);
266 return index;
267 }
268 ///

269 /// 获得有序集合中某个值得分数
270 ///

271 ///
272 ///
273 ///
274 public static double GetItemScoreInSortedSet(string set, string value)
275 {
276 double score &＃61; redisCli.GetItemScoreInSortedSet(set, value);
277 return score;
278 }
279 ///

280 /// 获得有序集合中&＃xff0c;某个排名范围的所有值
281 ///

282 ///
283 ///
284 ///
285 ///
286 public static List GetRangeFromSortedSet(string set,int beginRank, int endRank)
287 {
288 List valueList&＃61;redisCli.GetRangeFromSortedSet(set,beginRank,endRank);
289 return valueList;
290 }
291 ///

292 /// 获得有序集合中&＃xff0c;某个分数范围内的所有值&＃xff0c;升序
293 ///

294 ///
295 ///
296 ///
297 ///
298 public static List GetRangeFromSortedSet(string set, double beginScore, double endScore)
299 {
300 List valueList &＃61; redisCli.GetRangeFromSortedSetByHighestScore(set, beginScore, endScore);
301 return valueList;
302 }
303 ///

304 /// 获得有序集合中&＃xff0c;某个分数范围内的所有值&＃xff0c;降序
305 ///

306 ///
307 ///
308 ///
309 ///
310 public static List GetRangeFromSortedSetDesc(string set, double beginScore, double endScore)
311 {
312 List vlaueList&＃61;redisCli.GetRangeFromSortedSetByLowestScore(set,beginScore,endScore);
313 return vlaueList;
314 }
315 public void Dispose()
316 {
317 redisCli.Dispose();
318 }
319
320 }
321 }