NetPro.CsRedis 6.0.5-beta.10

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)
  {
    //自定义的连接串获取实现类CustomConnector
   services.AddCsRedis<CustomConnector>().Build<SystemTextJsonSerializer>(configuration);
  }

 public class CustomConnector : IConnectionsFactory//继承此接口实现自定义读取连接串
    {
        public IList<ConnectionString> GetConnectionStrings()
        {
            var connector = new List<ConnectionString>();
            connector.Add(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" });
            return connector;
        }
    }

构造函数注入

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