.NET Core 簡單且高級的庫 csredis

.NET Core 簡單且高級的庫 csredis

開源免費的redis包

最後更新 2021/4/11 上午9:50
FreeSql & CSRedis
預計閱讀 5 分鐘
分類
.NET
標籤
.NET C# 開源 Redis csredis

1 前言

.NET Core 從 1.0 發布歷經坎坷,一開始各種庫缺失到現在的部份完善,走到今天實屬不易。

比如 redis-cli SDK 簡直是坑層出不窮。

過去 .net 最有名望的 ServiceStack.Redis 早已淪為商業用途,在 .NETCore 中使用只能充值;後來居上的 StackExchange.Redis 雖然能用,但線上各種 Timeout 錯誤把人坑到沒脾氣,兩年多都不解決,最近發佈的 2.0 版本不知道是否徹底解決了底層。

2 csredis v3.0.0 更新

  1. 所有方法名與 redis-cli 保持一致;

據了解,java/python/go/nodejs/php SDK 方法名基本都與 redis-cli 一致,反對二次命名的庫

  1. 增加反序列化物件獲取,如:Get<byte[]>、HGet<byte[]>,所有獲取方法都重載了,預設獲取仍然是 string;

  2. SafeObjectPool 的引入使用;

3 使用

nuget Install-Package CSRedisCore
var rds = new CSRedis.CSRedisClient("127.0.0.1:6379,password=123,defaultDatabase=13,poolsize=50,ssl=false,writeBuffer=10240,prefix=key前綴");
rds.Set("test1", "123123", 60);
rds.Get("test1");
//函式名與 redis-cli 的命令相同,rds 一定是單例單例單例

4 進階玩法:分割區

實現多個服務節點共同分擔儲存,與官方的分割區、叢集、高可用方案不同。

例如:快取資料達到 500G,如果使用一台 redis-server 伺服器光靠記憶體儲存將非常吃力,使用硬碟又影響效能。

可以使用此功能自動管理 N 台 redis-server 伺服器分擔儲存,每台伺服器只需約 (500/N)G 記憶體,且每台伺服器都可以配置官方高可用架構。

var rds = 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() % 節點總數量,確定連向的節點
//也可以自訂規則(第一個參數設定)

rds.MSet("key1", 1, "key2", 2, "key3", 3, "key4", 4);
rds.MGet("key1", "key2", "key3", "key4");

5 進階玩法:發佈訂閱

//普通訂閱
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 都可以正常通訊

6 進階玩法:快取殼

//不加快取的時候,要從資料庫查詢
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())
});

7 進階玩法:管道

使用管道模式,打包多條指令一起執行,從而提升效能。

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") 效能相比,經測試差之毫釐

8 進階玩法:多資料庫

如果確定一定以及肯定非要有切換資料庫的需求,請看以下程式碼:

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");

9 效能比拼

10 結尾

依然是支持開源,感謝觀看!

csredis 源碼地址: https://github.com/2881099/csredis

本文作者:FreeSql & CSRedis

本文連結:https://www.cnblogs.com/kellynic/p/9803314.html

關於博主:評論和私訊會在第一時間回覆。或者直接私訊我。

版權聲明:本部落格所有文章除特別聲明外,均採用 BY-NC-SA 許可協議。轉載請註明出處!

聲援博主:如果您覺得文章對您有幫助,可以點擊文章右下角【推薦】一下。您的鼓勵是博主的最大動力!

繼續探索

延伸閱讀

更多文章