Mikel
RedisHelper
来源： csredis – 在西天取经的路上…… – 博客园
源码地址：https://github.com/2881099/csredis
1、增加了 CSRedisClient 现实集群与连接池管理，和 RedisHelper 静态类快速上手
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
|
//普通模式var csredis = new CSRedis.CSRedisClient("127.0.0.1:6379,password=123,defaultDatabase=13,poolsize=50,ssl=false,writeBuffer=10240,prefix=key前辍"); //集群模式 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() % 节点总数量，确定连向的节点//也可以自定义规则(第一个参数设置) //mvc分布式缓存注入 nuget Install-Package Caching.CSRedis //初始化 RedisHelperRedisHelper.Initialization(csredis, value => Newtonsoft.Json.JsonConvert.SerializeObject(value), deserialize: (data, type) => Newtonsoft.Json.JsonConvert.DeserializeObject(data, type));//注册mvc分布式缓存services.AddSingleton<IDistributedCache>(new Microsoft.Extensions.Caching.Redis.CSRedisCache(RedisHelper.Instance)); //提示：CSRedis.CSRedisClient 单例模式够用了，强烈建议使用 RedisHelper 静态类RedisHelper.Set("test1", "123123", 60);RedisHelper.Get("test1");//...函数名基本与 redis-cli 的命令相同 |
2、订阅与发布（分布式读写分离的场景）
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
|
//普通订阅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 都能正常通信 |
3、缓存壳
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
|
//不加缓存的时候，要从数据库查询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())}); |
