CSReid库在NetCore工作场景中的使用

关于我

作者博客|文章首发

过去 .net 最有名望的 ServiceStack.Redis 早已沦为商业用途,在 .NETCore 中使用只能充值。后来居上的 StackExchange.Redis 虽然能用,但是之前出现的各种Timeout错误也是让人很无语,所以也不作为使用的首选。经过网上的一些整理和推荐,发现了一款开源库CSReidsCore。

CSRedisCore是国人开源的一套Redis操作库,现在最新版本已经V3.6.5,经过几个实际公司项目的使用情况来看,还没有出现什么大的问题,本文主要介绍一下在使用这个库的过程中的一些自己的想法。

特征

  • CSRedisClient和RedisHelper保持所有方法名称与redis-cli一致
  • 支持地理类型命令(需要redis-server 3.2或更高版本)
  • 支持Redis集群redis-trib.rb
  • 支持Redis Sentinel和主从
  • 支持流类型命令(需要redis-server 5.0及更高版本)

官方参数

范围默认解释
密码<空>Redis服务器密码
defaultDatabase0Redis服务器数据库
asyncPipeline错误的异步方法自动使用管道,并且10W并发时间为450ms(欢迎反馈)
池大小50连接池大小
空闲超时20000连接池(MS)中元素的空闲时间,适用于连接到远程Redis服务器
connectTimeout5000连接超时(MS)
syncTimeout10000发送/接收超时(MS)
预热5预热连接,接收预热等值= 5个预热5个连接
自动处置真的跟踪系统退出事件以自动释放
ssl错误的启用加密传输
测试集群真的是否尝试正常模式,阿里云,腾讯云合并需要设置此选项为false
试试吧0执行错误,重试尝试
姓名<空>连接名称,使用客户端列表命令查看
字首<空>key前辍,所有方法都会附有海军辍,csredis.Set(前缀+“ key”,111);

开始使用

Redis单机

Redis唯一Db使用

根据Github作者推荐,如果你是唯一DB的使用场景,推荐使用这种方式初始化和使用

使用RedisHelper初始化和调用,是唯一Db下的推荐方式

1var rds = new CSRedis.CSRedisClient("127.0.0.1:6379,password=123,defaultDatabase=0,poolsize=50,ssl=false,writeBuffer=10240"); 2RedisHelper.Initialization(rds); 3 4//使用RedisHelper 5RedisHelper.Set("test", DateTime.Now.ToString()); 6RedisHelper.Get("test");

Redis多个Db使用

实例数组作为单例注入

推荐方式:

将实例后的各个RedisDb整合在数组中,单例截注入services

1var connectionString = "127.0.0.1:6379,password=123,poolsize=10"; 2var redis = new CSRedisClient[14]; 3for (var a = 0; a < redis.Length; a++) 4redis[a] = new CSRedisClient(connectionString + ",defaultDatabase=" + a); 5 6service.AddSingleton(redis);

创建多个ReidsHepler

每一个库对应一个RedisHelper,初始化指定Helper的Client实例

1public abstract class MyHelper1 : RedisHelper<MyHelper1> {} 2public abstract class MyHelper2 : RedisHelper<MyHelper2> {} 3 4MyHelper1.Initialization(new CSRedisClient("....")); 5MyHelper2.Initialization(new CSRedisClient("...."));

Redis集群

1var csredis = new CSRedis.CSRedisClient(null, 2"127.0.0.1:6371,password=123,defaultDatabase=11,poolsize=10,ssl=false,writeBuffer=10240", 3"127.0.0.1:6372,password=123,defaultDatabase=12,poolsize=11,ssl=false,writeBuffer=10240", 4"127.0.0.1:6373,password=123,defaultDatabase=13,poolsize=12,ssl=false,writeBuffer=10240", 5"127.0.0.1:6374,password=123,defaultDatabase=14,poolsize=13,ssl=false,writeBuffer=10240"); 6 7csredis.Set("test", DateTime.Now.ToString()); 8csredis.Get("test");

哨兵模式

1var csredis = new CSRedis.CSRedisClient("mymaster,password=123", 2new[] { "192.169.1.10:26379", "192.169.1.11:26379", "192.169.1.12:26379" }); 3csredis.Set("test", DateTime.Now.ToString()); 4csredis.Get("test");

分布式缓存

基于CSRedisCore开源库的分布式缓存用法也很简单,大体的思路和上文一致只是方法体变了而已

普通模式

1var csredis = new CSRedis.CSRedisClient("127.0.0.1:6379,password=123,defaultDatabase=13,ssl=false,writeBuffer=10240,poolsize=50,prefix=key前辍"); 2services.AddSingleton<IDistributedCache>(new Microsoft.Extensions.Caching.Redis.CSRedisCache(csredis));

集群模式

1var csredis = new CSRedis.CSRedisClient(null, 2 "127.0.0.1:6371,password=123,defaultDatabase=11,poolsize=10,ssl=false,writeBuffer=10240,prefix=key前辍", 3 "127.0.0.1:6372,password=123,defaultDatabase=12,poolsize=11,ssl=false,writeBuffer=10240,prefix=key前辍", 4 "127.0.0.1:6373,password=123,defaultDatabase=13,poolsize=12,ssl=false,writeBuffer=10240,prefix=key前辍", 5 "127.0.0.1:6374,password=123,defaultDatabase=14,poolsize=13,ssl=false,writeBuffer=10240,prefix=key前辍"); 6services.AddSingleton<IDistributedCache>(new Microsoft.Extensions.Caching.Redis.CSRedisCache(csredis));

如果你存在多数据库切换的需求,可以参照”Redis多个Db使用“标签进行设置

高级用法

CSRedis的高级用法可以参考这篇文章 .NETCore 简单且高级的库 csredis v3.0.0和Github官方库。一般情况使用不到,等到需要用到的时候再来回顾一下即可。

文章参考

https://www.cnblogs.com/kellynic/p/9803314.html

https://github.com/2881099/csredis

_https://github.com/2881099/csredis/blob/master/src/Microsoft.Extensions.Caching.CSRedis/README.md

推荐阅读

Redis工具收费后新的开源已出现

GitHub上Star最高的工程师技能图谱

最后

本文到此结束,希望对你有帮助 😃

如果还有什么疑问或者建议,可以多多交流,原创文章,文笔有限,才疏学浅,文中若有不正之处,万望告知。

更多精彩技术文章汇总在我的 公众号【程序员工具集】,持续更新,欢迎关注订阅收藏。

点赞
收藏

评论区

加载中...

相关推荐

MySQL:[Err] 1292 - Incorrect datetime value: ‘0000-00-00 00:00:00‘ for column ‘CREATE_TIME‘ at row 1

文章目录问题用navicat导入数据时,报错:原因这是因为当前的MySQL不支持datetime为0的情况。解决修改sql\mode:sql\mode:SQLMode定义了MySQL应支持的SQL语法、数据校验等,这样可以更容易地在不同的环境中使用MySQL。全局s

Oracle 分组与拼接字符串同时使用

SELECTT.,ROWNUMIDFROM(SELECTT.EMPLID,T.NAME,T.BU,T.REALDEPART,T.FORMATDATE,SUM(T.S0)S0,MAX(UPDATETIME)CREATETIME,LISTAGG(TOCHAR(

皕杰报表之UUID

​在我们用皕杰报表工具设计填报报表时,如何在新增行里自动增加id呢?能新增整数排序id吗?目前可以在新增行里自动增加id,但只能用uuid函数增加UUID编码,不能新增整数排序id。uuid函数说明:获取一个UUID,可以在填报表中用来创建数据ID语法:uuid()或uuid(sep)参数说明:sep布尔值,生成的uuid中是否包含分隔符'',缺省为

手写Java HashMap源码

HashMap的使用教程HashMap的使用教程HashMap的使用教程HashMap的使用教程HashMap的使用教程22

2020年前端实用代码段,为你的工作保驾护航

有空的时候,自己总结了几个代码段,在开发中也经常使用,谢谢。1、使用解构获取json数据let jsonData  id: 1,status: "OK",data: 'a', 'b';let  id, status, data: number   jsonData;console.log(id, status, number )

KVM调整cpu和内存

一.修改kvm虚拟机的配置1、virsheditcentos7找到“memory”和“vcpu”标签,将<namecentos7</name<uuid2220a6d1a36a4fbb8523e078b3dfe795</uuid