.NET Core開發者的福音之玩轉Redis的又一傻瓜式神器推薦
引子
為什麼寫這篇文章呢?因為.NET Core的生態越來越好了!之前玩轉.net的時候操作Redis相信大夥都使用過一些元件,但都有一些缺點,如ServiceStack.Redis 是商業版,免費版有限制;StackExchange.Redis 是免費版,但是核心在 .NETCore 執行時經常有 Timeout的問題,暫無法解決(據農碼一生大佬說:https://github.com/StackExchange/StackExchange.Redis/issues/871 試試StackExchange.Redis 2.0 呢,超時問題好像解決了。但還是有朋友說,2.0也還是會出現超時的問題)有興趣的可以試試;csredis作者在 2014 年以後就沒有更新了,它不支援 .net core,但是它的原始碼可讀性很強非常乾淨,幾乎無任何依賴。但是隨著.NET Core生態的越來越好,又湧現了一批我們國內大牛
NewLife.Redis 他是NewLife團隊開發的,已經在ZTO大資料實時計算中廣泛應用,200多個Redis例項穩定工作一年多,每天處理近1億包裹資料,日均呼叫量80億次。
CSRedis (這裡我更喜歡把它叫做CSRedisCore)這是另一個國內大牛nicye 開發的,為人很低調,所以瞭解他的人很少!目前我專案中廣泛使用的也是這個。作者前不久剛做了一個幾大Redis元件的效能測試.net core 2.0 redis驅動效能比拼 有興趣的可以開啟連結看一下。
注:此CSRedis(今天本文的主角CSRedisCore) 非彼CSRedis(.net 時代的元件,很久沒更新了,不支援.net core)
NewLife.Redis的使用方法在前兩天的Redis基本使用及百億資料量中的使用技巧分享(附視訊地址及觀看指南)文章中已經分享了!文章也有視訊教程。所以今天的文章將介紹另一個玩轉Redis的神器-CSRedis了!
基本使用
CSRedisCore的使用很簡單,就需要例項化一個CSRedisClient(叢集連線池)物件然後初始化一下RedisHelper就可以了,他的方法名與redis-cli基本保持一致。所以說你可以像使用redis-cli命令一樣來使用它。作者最近也支援了Pipeline功能以及MGet,MSet等提高效率的功能!話不多少下面我們將通過一個個例項來看下他的操作吧。
簡單使用
獲取Nuget包(目前版本3.0.18)!哈,沒錯,使用前要通過Nuget來安裝下引用,什麼?你不知道怎麼使用Nuget包?對不起,右上角點下“X” 關掉網頁就可以了。
nuget Install-Package CSRedisCore
幾種啟動模式介紹:
普通模式:
var csredis = new CSRedis.CSRedisClient("127.0.0.1:6379,password=123,defaultDatabase=13,poolsize=50,ssl=false,writeBuffer=10240,prefix=key前輟");
官方叢集模式:假設你已經配置好 redis-trib 叢集,定義一個【普通模式】的 CSRedisClient 物件,它會根據 redis-server 返回的 MOVED | ASK 錯誤記錄slot,自動增加節點 Nodes 屬性。
127.0.0.1:6379,password=123,defaultDatabase=0,poolsize=50,ssl=false,writeBuffer=10240,prefix=
其他節點在執行過程中自動增加,確保每個節點密碼一致。
警告:本模式與【分割槽模式】同時使用時,切記不可設定“prefix=key前輟”(或者全部設定成一樣),否則會導致 keySlot 計算結果與服務端不匹配,無法記錄 slotCache。
注意:官方叢集不支援多 keys 的命令、【管道】、Eval(指令碼)等眾多殺手級功能。
分割槽模式:本功能實現多個服務節點分擔儲存(作者自己實現的一種方式),與官方的分割槽、叢集、高可用方案不同。
例如:快取資料達到500G,如果使用一臺redis-server伺服器光靠記憶體儲存將非常吃力,使用硬碟又影響效能。
可以使用此功能自動管理N臺redis-server伺服器分擔儲存,每臺伺服器只需約 (500/N)G 記憶體,且每臺伺服器勻可以配置官方高可用架構。var csredis = new CSRedis.CSRedisClient(null, "127.0.0.1:6371,password=123,defaultDatabase=11,poolsize=10,ssl=false,writeBuffer=10240,prefix=key前輟", "127.0.0.1:6372,password=123,defaultDatabase=12,poolsize=11,ssl=false,writeBuffer=10240,prefix=key前輟", "127.0.0.1:6373,password=123,defaultDatabase=13,poolsize=12,ssl=false,writeBuffer=10240,prefix=key前輟", "127.0.0.1:6374,password=123,defaultDatabase=14,poolsize=13,ssl=false,writeBuffer=10240,prefix=key前輟"); //實現思路:根據key.GetHashCode() % 節點總數量,確定連向的節點 //也可以自定義規則(第一個引數設定)
今天我只給大家演示怎麼來進行使用,所以採用了普通模式,程式碼如下所示:
static void Main(string[] args) { //普通模式 var csredis = new CSRedis.CSRedisClient("127.0.0.1:6379,password=123,defaultDatabase=1,poolsize=50,ssl=false,writeBuffer=10240"); //初始化 RedisHelper RedisHelper.Initialization(csredis); //Install-Package Caching.CSRedis (本篇不需要) //註冊mvc分散式快取 //services.AddSingleton<IDistributedCache>(new Microsoft.Extensions.Caching.Redis.CSRedisCache(RedisHelper.Instance)); Test(); Console.ReadKey(); } static void Test() { RedisHelper.Set("name", "祝雷");//設定值。預設永不過期 //RedisHelper.SetAsync("name", "祝雷");//非同步操作 Console.WriteLine(RedisHelper.Get<String>("name")); RedisHelper.Set("time", DateTime.Now, 1); Console.WriteLine(RedisHelper.Get<DateTime>("time")); Thread.Sleep(1100); Console.WriteLine(RedisHelper.Get<DateTime>("time")); // 列表 RedisHelper.RPush("list", "第一個元素"); RedisHelper.RPush("list", "第二個元素"); RedisHelper.LInsertBefore("list", "第二個元素", "我是新插入的第二個元素!"); Console.WriteLine($"list的長度為{RedisHelper.LLen("list")}"); //Console.WriteLine($"list的長度為{RedisHelper.LLenAsync("list")}");//非同步 Console.WriteLine($"list的第二個元素為{RedisHelper.LIndex("list",1)}"); //Console.WriteLine($"list的第二個元素為{RedisHelper.LIndexAsync("list",1)}");//非同步 // 雜湊 RedisHelper.HSet("person","name", "zhulei"); RedisHelper.HSet("person", "sex", "男"); RedisHelper.HSet("person", "age", "28"); RedisHelper.HSet("person", "adress", "hefei"); Console.WriteLine($"person這個雜湊中的age為{RedisHelper.HGet<int>("person","age")}"); //Console.WriteLine($"person這個雜湊中的age為{RedisHelper.HGetAsync<int>("person", "age")}");//非同步 // 集合 RedisHelper.SAdd("students","zhangsan", "lisi"); RedisHelper.SAdd("students", "wangwu"); RedisHelper.SAdd("students", "zhaoliu"); Console.WriteLine($"students這個集合的大小為{RedisHelper.SCard("students")}"); Console.WriteLine($"students這個集合是否包含wagnwu:{RedisHelper.SIsMember("students", "wangwu")}"); }
通過上面的程式碼大家可以看到對於Redis的操作都是使用RedisHelper這個類來實現的。而且,對Redis的所有操作名稱都跟Redis-Cli命令高度一致!這樣就會方便很多!同時對所有的方法在實現上都有同步非同步的操作!這裡建議進行Redis操作的話都儘量使用同步操作。原因在上篇也進行了介紹!這裡就不再次進行介紹了!。
執行的結果如下所示:
大#家可以摘錄程式碼然後拷貝到一個新的控制檯程式中執行即可!
高階使用
上面給大家介紹了一些通用的使用方法,接下來呢我們進行一些高階方法的使用。包括訂閱/釋出,PipeLine,快取殼等等。
訂閱與釋出
//普通訂閱
RedisHelper.Subscribe(
("chan1", msg => Console.WriteLine(msg.Body)),
("chan2", msg => Console.WriteLine(msg.Body)));
//模式訂閱(萬用字元)
RedisHelper.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" 訂閱全部節點時,需要解決同一條訊息不可執行多次
//釋出
RedisHelper.Publish("chan1", "123123123");
//無論是分割槽或普通模式,RedisHelper.Publish 都可以正常通訊
//不加快取的時候,要從資料庫查詢
var t1 = Test.Select.WhereId(1).ToOne();
//一般的快取程式碼,如不封裝還挺繁瑣的
var cacheValue = RedisHelper.Get("test1");
if (!string.IsNullOrEmpty(cacheValue)) {
try {
return JsonConvert.DeserializeObject(cacheValue);
} catch {
//出錯時刪除key
RedisHelper.Remove("test1");
throw;
}
}
var t1 = Test.Select.WhereId(1).ToOne();
RedisHelper.Set("test1", JsonConvert.SerializeObject(t1), 10); //快取10秒
//使用快取殼效果同上,以下示例使用 string 和 hash 快取資料
var t1 = RedisHelper.CacheShell("test1", 10, () => Test.Select.WhereId(1).ToOne());
var t2 = RedisHelper.CacheShell("test", "1", 10, () => Test.Select.WhereId(1).ToOne());
var t3 = RedisHelper.CacheShell("test", new [] { "1", "2" }, 10, notCacheFields => new [] {
("1", Test.Select.WhereId(1).ToOne()),
("2", Test.Select.WhereId(2).ToOne())
});
Pipeline及MGet,MSet
使用管道模式,打包多條命令一起執行,從而提高效能。
var ret1 = RedisHelper.StartPipe().Set("a", "1").Get("a").EndPipe();
var ret2 = RedisHelper.StartPipe(p => p.Set("a", "1").Get("a"));
var ret3 = RedisHelper.StartPipe().Get("b").Get("a").Get("a").EndPipe();
//與 RedisHelper.MGet("b", "a", "a") 效能相比,經測試差之毫釐
壓力測試對比
到這裡你可能要問了,CSRedisCore效能如何呢?跟其他的Redis元件相比又如何呢、這裡給出一個連結.net core 2.0 redis驅動效能比拼?.net core 2.0 redis驅動效能比拼,上面有作者做的測試,大夥可以看下,我也做個截圖分享
作者交流群
作者交流QQ群:8578575
總結
今天給大家介紹了.NET Core玩轉Redis的又一傻瓜式神器CSRedisCore的使用,由於篇幅有限,所以還有很多方法沒有進行演示。大夥可以按照本文的方法自行進行測試!(基本RedisCli裡面有的命令,都有對應的方法實現!)看到.net core的生態越來越好!有很多優秀的工具以及框架在開源!作為.net Corer的你開森嘛?