using ServiceStack.Redis;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;

namespace BP.Difference.Redis
{
    public  class RedisManager
    {
        /// <summary>
        /// redis配置文件信息
        /// </summary>
        private static readonly RedisConfigInfo RedisConfigInfo = RedisConfigInfo.GetConfig();
 
        private static PooledRedisClientManager _prcm;
 
         /// <summary>
         /// 静态构造方法，初始化链接池管理对象
         /// </summary>
         public RedisManager()
         {
             CreateManager();
         }
         /// <summary>
         /// 创建链接池管理对象
         /// </summary>
         private  void CreateManager()
         {
             var writeServerList = SplitString(RedisConfigInfo.WriteServerList, ",");
             var readServerList = SplitString(RedisConfigInfo.ReadServerList, ",");
 
             _prcm = new PooledRedisClientManager(writeServerList, readServerList,
                    new RedisClientManagerConfig
                    {
                        MaxWritePoolSize = RedisConfigInfo.MaxWritePoolSize,
                        MaxReadPoolSize = RedisConfigInfo.MaxReadPoolSize,
                        AutoStart = RedisConfigInfo.AutoStart,
                        DefaultDb = RedisConfigInfo.DefaultDb,
                        
                    });
         }
         private static IEnumerable<string> SplitString(string strSource, string split)
         {
             return strSource.Split(split.ToArray());
         }
         /// <summary>
        /// 客户端缓存操作对象
         /// </summary>
         public  IRedisClient GetClient()
         {
            if (_prcm == null)
            {
                 CreateManager();
            }
            IRedisClient redisClient =  _prcm.GetClient();
            return redisClient;
         }
    }
}