Lycoris.CSRedisCore.Extensions 6.0.4

CSRedisCore 扩展

当前版本请不要升级，删减了很多代码，因为实际使用中发现csredis会时不时的打不开连接，问题暂时未知

csreids 错误【******:6371/0】：Connection was not opened    at CSRedis.CSRedisClient.GetAndExecuteAsync[T](RedisClientPool pool, Func`2 handerAsync, Int32 jump, Int32 errtimes)

当前版本删减为全静态服务

单实例例服务注册

CSRedisCoreBuilder.AddSingleRedisInstance(opt => 
{
  opt.Host = "your host";
  opt.Port = 6371;
  opt.Password = "your password";
  opt.SSL = false;
  // 是否尝试集群模式，阿里云、腾讯云集群需要设置此选项为 false
  opt.TestCluster = false;
  opt.NewtonsoftJsonSerializerSettings = new JsonSerializerSettings
  {
      ContractResolver = new CamelCasePropertyNamesContractResolver(),
      DateFormatString = "yyyy-MM-dd HH:mm:ss.ffffff",
      ReferenceLoopHandling = ReferenceLoopHandling.Ignore,
      NullValueHandling = NullValueHandling.Ignore
  };
})

单实例服务使用

public class DemoService
{

    public void RedisDemo()
    {
        //模糊查找所有键
        var keys = RedisCache.Key.GetKeys("P:A");

        // 获取缓存
        var value = RedisCache.String.Get("A");
        // 获取缓存
        RedisCache.String.Set("A", "value");

        // 使用方式和之前基本一致。 其他类型不做演示

        // 分布式锁有略微变动

        // 锁超时时间，单位：秒
        var timeout = 10;
        // 自动延长锁超时时间
        var autoDelay = true;
        // 尝试开启分布式锁，若失败立刻返回null
        var Lock = RedisCache.Utils.Lock('key', timeout, autoDelay);
        
        // 延时
        Lock.Delay(1000);
        // 刷新锁时间
        Lock.Delay(10000);
        // 解锁
        Lock.Unlock();

        // 其他玩法自己研究
    }

}

多实例例服务注册

CSRedisCoreBuilder.AddMultipleRedisInstance("instanceA",opt => 
{
  opt.Host = "your host";
  opt.Port = 6371;
  opt.Password = "your password";
  opt.SSL = false;
  // 是否尝试集群模式，阿里云、腾讯云集群需要设置此选项为 false
  opt.TestCluster = false;
  opt.NewtonsoftJsonSerializerSettings = new JsonSerializerSettings
  {
      ContractResolver = new CamelCasePropertyNamesContractResolver(),
      DateFormatString = "yyyy-MM-dd HH:mm:ss.ffffff",
      ReferenceLoopHandling = ReferenceLoopHandling.Ignore,
      NullValueHandling = NullValueHandling.Ignore
  };
});

CSRedisCoreBuilder.AddMultipleRedisInstance("instanceB",opt => 
{
  opt.Host = "your host";
  opt.Port = 6371;
  opt.Password = "your password";
  opt.SSL = false;
  // 是否尝试集群模式，阿里云、腾讯云集群需要设置此选项为 false
  opt.TestCluster = false;
  opt.NewtonsoftJsonSerializerSettings = new JsonSerializerSettings
  {
      ContractResolver = new CamelCasePropertyNamesContractResolver(),
      DateFormatString = "yyyy-MM-dd HH:mm:ss.ffffff",
      ReferenceLoopHandling = ReferenceLoopHandling.Ignore,
      NullValueHandling = NullValueHandling.Ignore
  };
});

多实例服务使用

public class DemoService
{
    public void RedisDemo()
    {
        var client = RedisCacheFactory.GetInstance("instanceA");

        //模糊查找所有键
        var keys = client.Key.GetKeys("P:A");

        // 获取缓存
        var value = client.String.Get("A");
        // 获取缓存
        client.String.Set("A", "value");

        // 使用方式和之前基本一致。 其他类型不做演示

        // 分布式锁有略微变动

        // 锁超时时间，单位：秒
        var timeout = 10;
        // 自动延长锁超时时间
        var autoDelay = true;
        // 尝试开启分布式锁，若失败立刻返回null
        var Lock = client.Utils.Lock('key', timeout, autoDelay);
        
        // 延时
        Lock.Delay(1000);
        // 刷新锁时间
        Lock.Delay(10000);
        // 解锁
        Lock.Unlock();

        // 其他玩法自己研究
    }

}