👁 Image
NetPro.CsRedis 6.0.16

RedisManager使用

支持CsRedis，支持分布式锁,支持多个Redis server

appsetting.json

"RedisCacheOption": {
		"Enabled": true,
		"ConnectionString": [//如配置远程获取此节点可删除
			{
				"Key": "1", //连接串key别名，唯一,用来物理隔离
				"Value": "127.0.0.1:6379,password=123,defaultDatabase=0,poolsize=10,preheat=20,ssl=false,writeBuffer=10240,prefix=key前辍,testcluster=false,idleTimeout=10" //别名key对应的连接串
			}
		]
}

使用

启用redis服务

• 默认注入方式，读取本地配置

 public void ConfigureServices(IServiceCollection services)
 {
 //新增redis缓存注入
 services.AddCsRedis().Build<SystemTextJsonSerializer>(configuration);//连接串默认读取配置文件的RedisCacheOption节点

 }

• 自定义连接

public void ConfigureServices(IServiceCollection services, IConfiguration configuration = null, ITypeFinder typeFinder = null)
{
 //基于NetPro.Web.Api的程序，CsRedis支持自动根据配置文件初始化，如需覆盖默认初始化逻辑可在此重新初始化。
 services.AddCsRedis<SystemTextJsonSerializer>(configuration, GetConnectionString);
}

public List<ConnectionString> GetConnectionString(IServiceProvider serviceProvider)
{
 return new List<ConnectionString>
 {
 new ConnectionString
 {
 Key = "2",
 Value = "192.168.100.187:6379,password=,defaultDatabase=0,poolsize=10,preheat=20,ssl=false,writeBuffer=10240,prefix=key前辍,testcluster=false,idleTimeout=10"
 }
 };
}

构造函数注入

public class WeatherForecastController : ControllerBase
{
 private readonly IRedisManager _redisManager;

 /// <summary>
 /// 
 /// </summary>
 /// <param name="redisManager"></param>
 public WeatherForecastController(
 IRedisManager redisManager)
 {
 _redisManager = redisManager;
 }
}

方法说明
 /// <summary>
 ///获取或者创建缓存 
 /// localExpiredTime参数大于0并且小于expiredTime数据将缓存到本地内存
 /// </summary>
 /// <typeparam name="T"></typeparam>
 /// <param name="key"></param>
 /// <param name="func"></param>
 /// <param name="expiredTime"></param>
 /// <param name="localExpiredTime">本地过期时间</param>
 T GetOrSet<T>(string key, Func<T> func = null, TimeSpan? expiredTime = null, int localExpiredTime = 0, string dbKey = default);

方法中调用

//同步方法
 var result = _redisManager.GetOrCreate<string>("1",func: ()=>//获取key的值，没有找到则执行委托并将委托返回的值插入redis缓存
 {
 return "1";
 },TimeSpan.FromeSecond(66));


//异步方法
 var resultAsync = await _redisManager.GetOrCreateAsync<string>("1",func: async()=>//获取key的值，没有找到则执行委托并将委托返回的值插入redis缓存
 {
 return await Task.FromResult("1") ;
 });