1. 程式人生 > >.NET Core開發者的福音之玩轉Redis的又一傻瓜式神器推薦

.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生態的越來越好,又湧現了一批我們國內大牛

開發的支援.Net Core的Redis元件,供我們選擇。

  1. NewLife.Redis 他是NewLife團隊開發的,已經在ZTO大資料實時計算中廣泛應用,200多個Redis例項穩定工作一年多,每天處理近1億包裹資料,日均呼叫量80億次。

  2. 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等提高效率的功能!話不多少下面我們將通過一個個例項來看下他的操作吧。

簡單使用

  1. 獲取Nuget包(目前版本3.0.18)!哈,沒錯,使用前要通過Nuget來安裝下引用,什麼?你不知道怎麼使用Nuget包?對不起,右上角點下“X” 關掉網頁就可以了。

    nuget Install-Package CSRedisCore
  2. 幾種啟動模式介紹:

    • 普通模式:

      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() % 節點總數量,確定連向的節點
      //也可以自定義規則(第一個引數設定)
  3. 今天我只給大家演示怎麼來進行使用,所以採用了普通模式,程式碼如下所示:

     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操作的話都儘量使用同步操作。原因在上篇也進行了介紹!這裡就不再次進行介紹了!。

  4. 執行的結果如下所示:

    1542015107575

大#家可以摘錄程式碼然後拷貝到一個新的控制檯程式中執行即可!

高階使用

上面給大家介紹了一些通用的使用方法,接下來呢我們進行一些高階方法的使用。包括訂閱/釋出,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驅動效能比拼,上面有作者做的測試,大夥可以看下,我也做個截圖分享

1542015308886

作者交流群

作者交流QQ群:8578575

總結

今天給大家介紹了.NET Core玩轉Redis的又一傻瓜式神器CSRedisCore的使用,由於篇幅有限,所以還有很多方法沒有進行演示。大夥可以按照本文的方法自行進行測試!(基本RedisCli裡面有的命令,都有對應的方法實現!)看到.net core的生態越來越好!有很多優秀的工具以及框架在開源!作為.net Corer的你開森嘛?