CSRedisCore 在net core中的使用

背景：與net core配套的StackExchange.Redis客戶端總是間歇性的發生timeout異常。 由complexer單例對象創建的IDatabase對象，在產生Timeout異常后會導致這個complexer單例對象超時，即由其創建的新的IDatabase對象也會繼續Timeout，實際使用過程中，由於網絡各種原因，出現Timeout異常難免，但是無法恢復確實很麻煩。測試complexer對象無法dispose,close后重建。暫時沒有好的解決方案，所以轉戰CSRedis。

 使用方法：

             1.網上git源碼或者動態鏈接庫。

             2.項目引用

             3.具體使用方式如下：

                 （1）創建讀寫連接客戶端（單例模式）

  public class RedisBase
    {
        protected static string _connect_str_write;
        protected static string _connect_str_read;


        protected static CSRedisClient  rds_write=null;
        protected static CSRedisClient rds_read = null;

        private static object _lockObj_write = new object();
        private static object _lockObj_read = new object();

        public static CSRedisClient GetWriteClient()
        {
            if (string.IsNullOrEmpty(_connect_str_write))
            {
                Console.WriteLine("Write Connectstring is not set");
            }
            if (rds_write == null)
            {
                lock (_lockObj_write)
                {
                    if (rds_write == null)
                    {
                        rds_write = new CSRedisClient($"{_connect_str_write},poolsize=50,ssl=false,writeBuffer=10240");
                        RedisHelper.Initialization(rds_write);
                    }
                }
            }
            return rds_write;
    }
        public static CSRedisClient GetReadClient()
        {
            if (string.IsNullOrEmpty(_connect_str_read))
            {
                Console.WriteLine("Read Connectstring is not set");
            }
            if (rds_read == null)
            {
                lock (_lockObj_read)
                {
                    if (rds_read == null)
                    {
                        rds_read = new CSRedisClient($"{_connect_str_read},poolsize=50,ssl=false,writeBuffer=10240");
                    }
                }
            }
            return rds_read;
        }
    }

          （2）調用方式：

           

            if (rds_write == null)
                   rds_write = GetWriteClient();
            rds_write.Del(key);