現在流行的redis連接客戶端有StackExchange.Redis和ServiceStack.Redis,為什么選擇csredis而不是這兩個?
- .net 最有名望的 ServiceStack.Redis 早已淪為商業用途,在 .NETCore 中使用只能充值;
- 后來居上的 StackExchange.Redis 雖然能用,但線上各種 Timeout 錯誤把人坑到沒脾氣,兩年多兩年多兩年多都不解決,最近發布的 2.0 版本不知道是否徹底解決了底層。
- csredis支持.net40/.net45/.netstandard2.0,基本上滿足了常見運行平台,而上面兩個基本已經放棄.net40了。
- csredis所有方法名與redis-cli保持一持,很容易上手!!!
環境:
- redis6.0.6
- window 10
- vs2019
- csredis3.6.5(https://github.com/2881099/csredis)
- .net4/.net 4.5/.netcore 3.1
csredis 源碼地址: https://github.com/2881099/csredis
以windows服務安裝Redis方法:
下載Redis服務安裝包:https://github.com/tporadowski/redis/releases。
下載完成后直接點擊.exe下一步下一步OK。安裝完后我們會在windows服務中找到Redis Service服務。注意啟動服務后在進行相關測試。
1.在.net項目中引入CSRedisCore
包安裝命令:
Install-Package CSRedisCore -Version 3.6.5
2.使用:
//初始化RedisHelper對象 var csredis = new CSRedis.CSRedisClient("127.0.0.1:6379, defaultDatabase = 0, poolsize = 500, ssl = false, writeBuffer = 10240"); RedisHelper.Initialization(csredis); //-------------字符串(string)---------------- // 添加字符串鍵-值對 csredis.Set("hello", "1"); csredis.Set("world", "2"); csredis.Set("hello", "3"); // 根據鍵獲取對應的值 csredis.Get("hello"); // 移除元素 csredis.Del("world"); /* 數值操作 */ csredis.Set("num-key", "24"); // value += 5 csredis.IncrBy("num-key",5); // output -> 29 // value -= 10 csredis.IncrBy("num-key", -10); // output -> 19 /* 字節串操作 */ csredis.Set("string-key", "hello "); // 在指定key的value末尾追加字符串 csredis.Append("string-key", "world"); // output -> "hello world" // 獲取從指定范圍所有字符構成的子串(start:3,end:7) csredis.GetRange("string-key",3,7) // output -> "lo wo" // 用新字符串從指定位置覆寫原value(index:4) csredis.SetRange("string-key", 4, "aa"); // output -> "hellaaword" //-----------------列表(list)---------------- // 從右端推入元素 csredis.RPush("my-list", "item1", "item2", "item3", "item4"); // 從右端彈出元素 csredis.RPop("my-list"); // 從左端推入元素 csredis.LPush("my-list","LeftPushItem"); // 從左端彈出元素 csredis.LPop("my-list"); // 遍歷鏈表元素(start:0,end:-1即可返回所有元素) foreach (var item in csredis.LRange("my-list", 0, -1)) { Console.WriteLine(item); } // 按索引值獲取元素(當索引值大於鏈表長度,返回空值,不會報錯) Console.WriteLine($"{csredis.LIndex("my-list", 1)}"); // 修剪指定范圍內的元素(start:4,end:10) csredis.LTrim("my-list", 4, 10); // 將my-list最后一個元素彈出並壓入another-list的頭部 csredis.RPopLPush("my-list", "another-list"); //------------------集合(set)---------------- // 實際上只插入了兩個元素("item1","item2") csredis.SAdd("my-set", "item1", "item1", "item2"); // 集合的遍歷 foreach (var member in csredis.SMembers("my-set")) { Console.WriteLine($"集合成員:{member.ToString()}"); } // 判斷元素是否存在 string member = "item1"; Console.WriteLine($"{member}是否存在:{csredis.SIsMember("my-set", member)}"); // output -> True // 移除元素 csredis.SRem("my-set", member); Console.WriteLine($"{member}是否存在:{csredis.SIsMember("my-set", member)}"); // output -> False // 隨機移除一個元素 csredis.SPop("my-set"); csredis.SAdd("set-a", "item1", "item2", "item3","item4","item5"); csredis.SAdd("set-b", "item2", "item5", "item6", "item7"); // 差集 csredis.SDiff("set-a", "set-b"); // output -> "item1", "item3","item4" // 交集 csredis.SInter("set-a", "set-b"); // output -> "item2","item5" // 並集 csredis.SUnion("set-a", "set-b"); // output -> "item1","item2","item3","item4","item5","item6","item7" //------------------散列(hashmap)---------------- // 向散列添加元素 csredis.HSet("ArticleID:10001", "Title", "了解簡單的Redis數據結構"); csredis.HSet("ArticleID:10001", "Author", "xscape"); csredis.HSet("ArticleID:10001", "PublishTime", "2019-01-01"); // 根據Key獲取散列中的元素 csredis.HGet("ArticleID:10001", "Title"); // 獲取散列中的所有元素 foreach (var item in csredis.HGetAll("ArticleID:10001")) { Console.WriteLine(item.Value); } //HMGet和HMSet是他們的多參數版本,一次可以處理多個鍵值對 var keys = new string[] { "Title","Author","publishTime"}; csredis.HMGet("ID:10001", keys); //和處理字符串一樣,我們也可以對散列中的值進行自增、自減操作,原理同字符串是一樣的 csredis.HSet("ArticleID:10001", "votes", "257"); csredis.HIncrBy("ID:10001", "votes", 40); // output -> 297 //------------------有序集合---------------- // 向有序集合添加元素 csredis.ZAdd("Quiz", (79, "Math")); csredis.ZAdd("Quiz", (98, "English")); csredis.ZAdd("Quiz", (87, "Algorithm")); csredis.ZAdd("Quiz", (84, "Database")); csredis.ZAdd("Quiz", (59, "Operation System")); //返回集合中的元素數量 csredis.ZCard("Quiz"); // 獲取集合中指定范圍(90~100)的元素集合 csredis.ZRangeByScore("Quiz",90,100); // 獲取集合所有元素並升序排序 csredis.ZRangeWithScores("Quiz", 0, -1); // 移除集合中的元素 csredis.ZRem("Quiz", "Math"); //Key的過期 redis.Set("MyKey", "hello,world"); Console.WriteLine(redis.Get("MyKey")); // output -> "hello,world" redis.Expire("MyKey", 5); // key在5秒后過期,也可以使用ExpireAt方法讓它在指定時間自動過期 Thread.Sleep(6000); // 線程暫停6秒 Console.WriteLine(redis.Get("MyKey")); // output -> ""
https://www.cnblogs.com/xscape/p/10208638.html
3.高級玩法:發布訂閱
//普通訂閱 rds.Subscribe( ("chan1", msg => Console.WriteLine(msg.Body)), ("chan2", msg => Console.WriteLine(msg.Body))); //模式訂閱(通配符) rds.PSubscribe(new[] { "test*", "*test001", "test*002" }, msg => { Console.WriteLine($"PSUB {msg.MessageId}:{msg.Body} {msg.Pattern}: chan:{msg.Channel}"); }); //模式訂閱已經解決的難題: //1、分區的節點匹配規則,導致通配符最大可能匹配全部節點,所以全部節點都要訂閱 //2、本組 "test*", "*test001", "test*002" 訂閱全部節點時,需要解決同一條消息不可執行多次 //發布 rds.Publish("chan1", "123123123"); //無論是分區或普通模式,rds.Publish 都可以正常通信
4.高級玩法:緩存殼
//不加緩存的時候,要從數據庫查詢 var t1 = Test.Select.WhereId(1).ToOne(); //一般的緩存代碼,如不封裝還挺繁瑣的 var cacheValue = rds.Get("test1"); if (!string.IsNullOrEmpty(cacheValue)) { try { return JsonConvert.DeserializeObject(cacheValue); } catch { //出錯時刪除key rds.Remove("test1"); throw; } } var t1 = Test.Select.WhereId(1).ToOne(); rds.Set("test1", JsonConvert.SerializeObject(t1), 10); //緩存10秒 //使用緩存殼效果同上,以下示例使用 string 和 hash 緩存數據 var t1 = rds.CacheShell("test1", 10, () => Test.Select.WhereId(1).ToOne()); var t2 = rds.CacheShell("test", "1", 10, () => Test.Select.WhereId(1).ToOne()); var t3 = rds.CacheShell("test", new [] { "1", "2" }, 10, notCacheFields => new [] { ("1", Test.Select.WhereId(1).ToOne()), ("2", Test.Select.WhereId(2).ToOne()) });
5.高級玩法:管道
使用管道模式,打包多條命令一起執行,從而提高性能。
var ret1 = rds.StartPipe().Set("a", "1").Get("a").EndPipe(); var ret2 = rds.StartPipe(p => p.Set("a", "1").Get("a")); var ret3 = rds.StartPipe().Get("b").Get("a").Get("a").EndPipe(); //與 rds.MGet("b", "a", "a") 性能相比,經測試差之毫厘
6.高級玩法:多數據庫
var connectionString = "127.0.0.1:6379,password=123,poolsize=10,ssl=false,writeBuffer=10240,prefix=key前輟"; var redis = new CSRedisClient[14]; //定義成單例 for (var a = 0; a< redis.Length; a++) redis[a] = new CSRedisClient(connectionString + "; defualtDatabase=" + a); //訪問數據庫1的數據 redis[1].Get("test1");
7.性能比拼
Redis的五種數據類型的簡單介紹和使用 https://www.cnblogs.com/dddyyy/p/9803828.html