您現在的位置是:網站首頁> 內容頁

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

  • 明仕娛樂
  • 2019-07-08
  • 122人已閱讀
簡介作者:依樂祝原本鏈接:https://www.cnblogs.com/yilezhu/p/9947905.html引子為什么寫這篇文章呢?因為.NETCore的生態越來越好了!之前玩

作者:依樂祝原本鏈接:https://www.cnblogs.com/yilezhu/p/9947905.html

引子

為什么寫這篇文章呢?因為.NET Core的生態越來越好了!之前玩轉.net的時候操作Redis相信大伙都使用過一些組件,但都有一些缺點,如ServiceStack.Redis 是商業版,免費版有限制;StackExchange.Redis 是免費版,但是內核在 .NETCore 運行時經常有 Timeout的問題,暫無法解決;csredis作者在 2014 年以后就沒有更新了,它不支持 .net core,但是它的源碼可讀性很強非常干凈,幾乎無任何依賴。但是隨著.NET Core生態的越來越好,又涌現了一批我們國人開發的支持.Net Core的Redis組件,供我們選擇。

    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的你開森嘛?

文章評論

Top 镇江全民麻将凡春和 赛马会走势图 123这里上图最快图纸最清晰 天津时时几点开奖 一笑一码中特是真的吗 福建快3开奖一定牛 创富高手心论坛 湖北快三开奖时间 明透i豆app pk10做号软件 老时时骗局