redis在.net架構中的應用(1)--使用servicestack鏈接redis

引言:做爲少有的.net架構下的大型網站,stackoverflow曾發表了一篇文章,介紹了其技術體系,原文連接http://highscalability.com/blog/2011/3/3/stack-overflow-architecture-update-now-at-95-million-page-vi.html。從文中能夠看到,該網站運用了redis做爲其緩存層。而新浪微博早就已經大量使用redis。做爲一個新興的nosql數據庫,redis既解決了memcached持久化的問題,又在性能上和傳統的memcached+mysql不相上下。html

1 redis安裝與配置mysql

目前redis在windows上的運行還不穩定,通常都是將其部署在linux服務器下,網上能夠搜到不少安裝教程,本文再也不贅述http://www.oschina.net/question/12_18065linux

2下載servicestack.Redisgit

目前redis官方版本不支持.net直接進行鏈接,須要使用一些開源類庫。目前最流行的就是ServiceStack.redis,github連接爲https://github.com/ServiceStack/ServiceStack.Redisgithub

點擊頁面右側的DownLoad.Zip,下載後解壓,在build\release\MonoDevelop\ServiceStack.Redis下找到所須要的四個dllredis

3 利用servicestack鏈接redissql

新建一個VS project,引入以上四個dll,接下來咱們就能夠利用C#鏈接redis數據庫了,一個最簡單的例子:數據庫

4 目前servicestack.redis仍然在不斷髮展和改進中,因此一些方法描述並非很清晰,因此提供一個已經封裝好的類共你們使用,windows

redis的網絡鏈接方式和傳統的rdbms類似,一種是長鏈接,一種是鏈接池,此處使用長鏈接進行鏈接緩存

強烈建議在使用以前閱讀註釋

 

  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 TestRedis
  8 {
  9     class RedisHelper:IDisposable
 10     {
 11         /*copyright@2013 All Rights Reserved
 12          * Author:Mars
 13          * Date:2013.08.27
 14          * QQ:258248340
 15          * servicestack.redis爲github中的開源項目
 16          * redis是一個典型的k/v型數據庫
 17          * redis共支持五種類型的數據 string,list,hash,set,sortedset
 18          * 
 19          * string是最簡單的字符串類型
 20          * 
 21          * list是字符串列表,其內部是用雙向鏈表實現的,所以在獲取/設置數據時能夠支持正負索引
 22          * 也能夠將其當作堆棧結構使用
 23          * 
 24          * hash類型是一種字典結構,也是最接近RDBMS的數據類型,其存儲了字段和字段值的映射,但字段值只能是
 25          * 字符串類型,散列類型適合存儲對象,建議使用對象類別和ID構成鍵名,使用字段表示對象屬性,字
 26          * 段值存儲屬性值,例如:car:2 price 500 ,car:2  color black,用redis命令設置散列時,命令格式
 27          * 以下:HSET key field value,即key,字段名,字段值
 28          * 
 29          * set是一種集合類型,redis中能夠對集合進行交集,並集和互斥運算
 30          *           
 31          * sorted set是在集合的基礎上爲每一個元素關聯了一個「分數」,咱們可以
 32          * 得到分數最高的前N個元素,得到指定分數範圍內的元素,元素是不一樣的,可是"分數"能夠是相同的
 33          * set是用散列表和跳躍表實現的,獲取數據的速度平均爲o(log(N))
 34          * 
 35          * 須要注意的是,redis全部數據類型都不支持嵌套
 36          * redis中通常不區分插入和更新操做,只是命令的返回值不一樣
 37          * 在插入key時,若是不存在,將會自動建立
 38          * 
 39          * 在實際生產環境中,因爲多線程併發的關係,建議使用鏈接池,本類只是用於測試簡單的數據類型
 40          */
 41 
 42         /*
 43          * 如下方法爲基本的設置數據和取數據
 44          */
 45         private static RedisClient redisCli = null;
 46         /// <summary>
 47         /// 創建redis長鏈接
 48         /// </summary>
 49         /// 將此處的IP換爲本身的redis實例IP,若是設有密碼,第三個參數爲密碼,string 類型
 50         public static void CreateClient(string hostIP,int port,string keyword)
 51         {
 52             if (redisCli == null)
 53             {
 54                 redisCli = new RedisClient(hostIP, port, keyword);
 55             }
 56  
 57         }
 58         public static void CreateClient(string hostIP, int port)
 59         {
 60             if (redisCli == null)
 61             {
 62                 redisCli = new RedisClient(hostIP, port);
 63              }
 64  
 65         }
 66         //private static RedisClient redisCli = new RedisClient("192.168.101.165", 6379, "123456");
 67         /// <summary>
 68         /// 獲取key,返回string格式
 69         /// </summary>
 70         /// <param name="key"></param>
 71         /// <returns></returns>
 72         public static string getValueString(string key)
 73         {
 74         
 75                 string value = redisCli.GetValue(key);
 76                 return value;
 77            
 78           
 79         }
 80         /// <summary>
 81         /// 獲取key,返回byte[]格式
 82         /// </summary>
 83         /// <param name="key"></param>
 84         /// <returns></returns>
 85         public static byte[] getValueByte(string key)
 86         {
 87             byte[] value = redisCli.Get(key);
 88             return value;
 89         }
 90         /// <summary>
 91         /// 得到某個hash型key下的全部字段
 92         /// </summary>
 93         /// <param name="hashId"></param>
 94         /// <returns></returns>
 95         public static List<string> GetHashFields(string hashId)
 96         {
 97             List<string> hashFields = redisCli.GetHashKeys(hashId);
 98             return hashFields;
 99         }
100         /// <summary>
101         /// 得到某個hash型key下的全部值
102         /// </summary>
103         /// <param name="hashId"></param>
104         /// <returns></returns>
105         public static List<string> GetHashValues(string hashId)
106         {
107             List<string> hashValues = redisCli.GetHashKeys(hashId);
108             return hashValues;
109         }
110         /// <summary>
111         /// 得到hash型key某個字段的值
112         /// </summary>
113         /// <param name="key"></param>
114         /// <param name="field"></param>
115         public static string GetHashField(string key, string field)
116         {
117             string value = redisCli.GetValueFromHash(key, field);
118             return value;
119         }
120         /// <summary>
121         /// 設置hash型key某個字段的值
122         /// </summary>
123         /// <param name="key"></param>
124         /// <param name="field"></param>
125         /// <param name="value"></param>
126         public static void SetHashField(string key, string field, string value)
127         {
128             redisCli.SetEntryInHash(key, field, value);
129         }
130         /// <summary>
131         ///使某個字段增長
132         /// </summary>
133         /// <param name="key"></param>
134         /// <param name="field"></param>
135         /// <returns></returns>
136         public static void SetHashIncr(string key, string field, long incre)
137         {
138             redisCli.IncrementValueInHash(key, field, incre);
139 
140         }
141         /// <summary>
142         /// 向list類型數據添加成員,向列表底部(右側)添加
143         /// </summary>
144         /// <param name="Item"></param>
145         /// <param name="list"></param>
146         public static void AddItemToListRight(string list, string item)
147         {
148             redisCli.AddItemToList(list, item);
149         }
150         /// <summary>
151         /// 向list類型數據添加成員,向列表頂部(左側)添加
152         /// </summary>
153         /// <param name="list"></param>
154         /// <param name="item"></param>
155         public static void AddItemToListLeft(string list, string item)
156         {
157             redisCli.LPush(list, Encoding.Default.GetBytes(item));
158         }
159         /// <summary>
160         /// 從list類型數據讀取全部成員
161         /// </summary>
162         public static List<string> GetAllItems(string list)
163         {
164             List<string> listMembers = redisCli.GetAllItemsFromList(list);
165             return listMembers;
166         }
167         /// <summary>
168         /// 從list類型數據指定索引處獲取數據,支持正索引和負索引
169         /// </summary>
170         /// <param name="list"></param>
171         /// <returns></returns>
172         public static string GetItemFromList(string list, int index)
173         {
174             string item = redisCli.GetItemFromList(list, index);
175             return item;
176         }
177         /// <summary>
178         /// 向列表底部(右側)批量添加數據
179         /// </summary>
180         /// <param name="list"></param>
181         /// <param name="values"></param>
182         public static void GetRangeToList(string list, List<string> values)
183         {
184             redisCli.AddRangeToList(list, values);
185         }
186         /// <summary>
187         /// 向集合中添加數據
188         /// </summary>
189         /// <param name="item"></param>
190         /// <param name="set"></param>
191         public static void GetItemToSet(string item, string set)
192         {
193             redisCli.AddItemToSet(item, set);
194         }
195         /// <summary>
196         /// 得到集合中全部數據
197         /// </summary>
198         /// <param name="set"></param>
199         /// <returns></returns>
200         public static HashSet<string> GetAllItemsFromSet(string set)
201         {
202             HashSet<string> items = redisCli.GetAllItemsFromSet(set);
203             return items;
204         }
205         /// <summary>
206         /// 獲取fromSet集合和其餘集合不一樣的數據
207         /// </summary>
208         /// <param name="fromSet"></param>
209         /// <param name="toSet"></param>
210         /// <returns></returns>
211         public static HashSet<string> GetSetDiff(string fromSet, params string[] toSet)
212         {
213             HashSet<string> diff = redisCli.GetDifferencesFromSet(fromSet, toSet);
214             return diff;
215         }
216         /// <summary>
217         /// 得到全部集合的並集
218         /// </summary>
219         /// <param name="set"></param>
220         /// <returns></returns>
221         public static HashSet<string> GetSetUnion(params string[] set)
222         {
223             HashSet<string> union = redisCli.GetUnionFromSets(set);
224             return union;
225         }
226         /// <summary>
227         /// 得到全部集合的交集
228         /// </summary>
229         /// <param name="set"></param>
230         /// <returns></returns>
231         public static HashSet<string> GetSetInter(params string[] set)
232         {
233             HashSet<string> inter = redisCli.GetIntersectFromSets(set);
234             return inter;
235         }
236         /// <summary>
237         /// 向有序集合中添加元素
238         /// </summary>
239         /// <param name="set"></param>
240         /// <param name="value"></param>
241         /// <param name="score"></param>
242         public static void AddItemToSortedSet(string set,string value,long score)
243         {
244             redisCli.AddItemToSortedSet(set,value,score);
245         }
246         /// <summary>
247         /// 得到某個值在有序集合中的排名,按分數的降序排列
248         /// </summary>
249         /// <param name="set"></param>
250         /// <param name="value"></param>
251         /// <returns></returns>
252         public static int GetItemIndexInSortedSetDesc(string set, string value)
253         {
254             int index = redisCli.GetItemIndexInSortedSetDesc(set, value);
255             return index;
256         }
257         /// <summary>
258         /// 得到某個值在有序集合中的排名,按分數的升序排列
259         /// </summary>
260         /// <param name="set"></param>
261         /// <param name="value"></param>
262         /// <returns></returns>
263         public static int GetItemIndexInSortedSet(string set, string value)
264         {
265             int index = redisCli.GetItemIndexInSortedSet(set, value);
266             return index;
267         }
268         /// <summary>
269         /// 得到有序集合中某個值得分數
270         /// </summary>
271         /// <param name="set"></param>
272         /// <param name="value"></param>
273         /// <returns></returns>
274         public static double GetItemScoreInSortedSet(string set, string value)
275         {
276             double score = redisCli.GetItemScoreInSortedSet(set, value);
277             return score;
278         }
279         /// <summary>
280         /// 得到有序集合中,某個排名範圍的全部值
281         /// </summary>
282         /// <param name="set"></param>
283         /// <param name="beginRank"></param>
284         /// <param name="endRank"></param>
285         /// <returns></returns>
286         public static List<string> GetRangeFromSortedSet(string set,int beginRank, int endRank)
287         {
288             List<string> valueList=redisCli.GetRangeFromSortedSet(set,beginRank,endRank);
289             return valueList;
290         }
291         /// <summary>
292         /// 得到有序集合中,某個分數範圍內的全部值,升序
293         /// </summary>
294         /// <param name="set"></param>
295         /// <param name="beginScore"></param>
296         /// <param name="endScore"></param>
297         /// <returns></returns>
298         public static List<string> GetRangeFromSortedSet(string set, double beginScore, double endScore)
299         {
300             List<string> valueList = redisCli.GetRangeFromSortedSetByHighestScore(set, beginScore, endScore);
301             return valueList;
302         }
303         /// <summary>
304         /// 得到有序集合中,某個分數範圍內的全部值,降序
305         /// </summary>
306         /// <param name="set"></param>
307         /// <param name="beginScore"></param>
308         /// <param name="endScore"></param>
309         /// <returns></returns>
310         public static List<string> GetRangeFromSortedSetDesc(string set, double beginScore, double endScore)
311         {
312             List<string> vlaueList=redisCli.GetRangeFromSortedSetByLowestScore(set,beginScore,endScore);
313             return vlaueList;
314         }
315         public void Dispose()
316         {
317             redisCli.Dispose();
318         }
319  
320     }
321 }

 

本文就到這裏,在接下來,我會跟你們討論redis中的鏈接池、鎖、線程安全、分佈式等機制。

 

做者:Mars

 

出處:http://www.cnblogs.com/marsblog/

 

本文基於署名-非商業性使用 3.0中國大陸許可協議發佈,歡迎轉載,演繹或用於商業目的,可是必須保留本文的署名 Mars (包含連接)

相關文章
相關標籤/搜索