封裝的Redis操做類名爲RedisHandle,以下代碼塊(只展現部分代碼),它的特色:html
1)使用鏈接池管理鏈接,見代碼中的PooledClientManager屬性。若是不用鏈接池,而是代碼直接RedisClient client = new RedisClient("localhost", 6379, "password");去獲取一個鏈接實例操做,那麼當Redis操做頻繁時,代價很大,不可行。git
2)支持讀寫分離的Redis服務端(若是你只用一個Redis服務端,那麼讀寫服務端鏈接字符串同樣便可)。github
3)操做Redis時,自動切換讀寫Redis鏈接實例,見代碼中的GetRedisClient函數,全部寫操做取「寫鏈接實例」PooledClientManager.GetClient(),全部讀操做取「讀鏈接實例」PooledClientManager.GetReadOnlyClient()。redis
注意:若是你讀寫是兩個作了主從複製的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 { 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 {
...
5)在GetRedisClient函數中有句註釋的代碼//result.ChangeDb(Db);。其中,ChangeDb是切換Redis數據庫(Redis默認有16個數據庫,見redis-server.exe目錄下的redis.conf配置文件中的「databases 16」)。咱們通常默認都是用第0個數據庫,若是須要切換數據庫,則傳入Db值(0~15)。我這邊通常不會用到切換數據庫的需求,若是你的需求須要常常切換Redis數據庫,此句可用。不然通常都只用默認0數據庫,集羣是沒有數據庫的概念。緩存
爲了說明一個Redis服務端有多個數據庫以及數據庫之間的切換,作個小示例,以下圖,我在Redis的第0個數據庫存放了鍵值對數據"test2:1",當我切到第1個數據庫ChangeDb(1)時,GetValue("test2")返回的是null,當切回第0個數據庫時,就取到1的值。框架
如今用命令登陸Redis再演示一遍這個過程,以下圖:編輯器
6)RedisHandle操做類包含的操做,大體以下圖,Redis支持的數據類型比Memcache多,並且很實用,若是你的系統存取緩存會涉及比較複雜的邏輯,推薦使用Redis,Memcache能的Redis都能。函數
完整的源碼請參考:https://gitee.com/donghan/NetDh-Framework/tree/master/Data/NetDh.RedisUtility
此工具類已經併到個人NetDh框架項目中,NetDh框架碼雲地址:https://gitee.com/donghan/NetDh-Framework
我這邊封裝的是ServiceStack.Redis最新版本5.7.0,它在4.0版本以後就商業化,有作限制:每小時只能有6000次的Redis訪問。網上有對ServiceStack.Redis和StackExchange.Reids進行比較,結果是前者性能比較好,無論真假,我是ServiceStack.Redis 3.x就開始用它了,一如既往繼續用唄,有限制就破解唄。
步驟:
1)限制6000次是在ServiceStack.Text.dll中,並且在兩個地方,用ILSpy打開ServiceStack.Text.dll,在搜索欄輸入「RedisRequestPerHour」,能夠看到RedisRequestPerHour=6000的限制,以下圖(第1步你可不作,看看就好):
再搜索「AssertValidUsage」,發現另外一個地方的6000次限制,以下圖:
2)下載一個十六進制編輯器,我網上找的是wxMEdit工具(下載頁面:http://wxmedit.github.io/downloads.html)。
3)先備份ServiceStack.Text.dll,用十六進制編輯器打開ServiceStack.Text.dll。
分析:6000轉換成字節形式是 70 17 00 00(雖然6000的16進制是00001770),int的最大值2147483647轉換成字節形式是 FF FF FF 7F,因此只要把70 17 00 00替換成FF FF FF 7F便可。
以下圖,替換以前點了「查找下一個」發現全局就兩個地方,那就肯定是要修改的值,而後點擊「替換」兩次,ctrl+s保存文件,dll修改完成。
4)再用ILSpy看這兩個值,已經修改了,以下圖(第4步你也可不作,看看就好):
5)把修改的dll覆蓋原來dll,最好在IDE中把原來的引用移除,從新添加引用一次,以防有緩存執行的仍是舊的dll。編寫以下代碼測試:
覆蓋dll以前會報6000限制,覆蓋以後輸出ok正常:
完美,點贊!