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

時間 2019-11-11

原文原文鏈接

做者：依樂祝
本來連接：http://www.javashuo.com/article/p-xigxefmp-kv.htmlhtml

引子

爲何寫這篇文章呢？由於.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組件，供咱們選擇。git

NewLife.Redis 他是NewLife團隊開發的，已經在ZTO大數據實時計算中普遍應用，200多個Redis實例穩定工做一年多，天天處理近1億包裹數據，日均調用量80億次。github
CSRedis (這裏我更喜歡把它叫作CSRedisCore)這是另外一個國內大牛nicye 開發的，爲人很低調，因此瞭解他的人不多！目前我項目中普遍使用的也是這個。做者前不久剛作了一個幾大Redis組件的性能測試.net core 2.0 redis驅動性能比拼有興趣的能夠打開連接看一下。redis

注：此CSRedis（今天本文的主角CSRedisCore）非彼CSRedis(.net 時代的組件，好久沒更新了，不支持.net core)數據庫

NewLife.Redis的使用方法在前兩天的Redis基本使用及百億數據量中的使用技巧分享（附視頻地址及觀看指南）文章中已經分享了！文章也有視頻教程。因此今天的文章將介紹另外一個玩轉Redis的神器-CSRedis了！c#

基本使用

CSRedisCore的使用很簡單，就須要實例化一個CSRedisClient(集羣鏈接池)對象而後初始化一下RedisHelper就能夠了，他的方法名與redis-cli基本保持一致。因此說你能夠像使用redis-cli命令同樣來使用它。做者最近也支持了Pipeline功能以及MGet,MSet等提升效率的功能！話很少少下面咱們將經過一個個實例來看下他的操做吧。緩存

簡單使用

獲取Nuget包（目前版本3.0.18）！哈，沒錯，使用前要經過Nuget來安裝下引用，什麼？你不知道怎麼使用Nuget包？對不起，右上角點下「X」關掉網頁就能夠了。服務器
```
nuget Install-Package CSRedisCore
```
幾種啓動模式介紹：架構
- 普通模式：mvc
```
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}");
});
//模式訂閱已經解決的難題：
//一、分區的節點匹配規則，致使通配符最大可能匹配所有節點，因此所有節點都要訂閱
//二、本組 "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的你開森嘛？