前言

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

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

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

csredis v3.0.0 更新

1、所有方法名與redis-cli保持一持；

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

2、增加反序列對象獲取，如：Get<byte[]>、HGet<byte[]>，所有獲取方法都重載了，默認獲取仍然是string；

3、SafeObjectPool 的引入使用；

使用

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 一定是單例單例單例
 

高級玩法：分區

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

例如：緩存數據達到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");
 

高級玩法：發布訂閱

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

高級玩法：緩存殼

//不加緩存的時候，要從數據庫查詢
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())
});

高級玩法：管道

使用管道模式，打包多條命令一起執行，從而提高性能。

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") 性能相比，經測試差之毫厘

高級玩法：多數據庫

如果確定一定以及肯定非要有切換數據庫的需求，請看以下代碼：

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

性能比拼

結尾

依然是支持開源，感謝觀看！

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

【推薦】.NETCore 簡單且高級的庫 csredis v3.0.0