Service-stack.redis配置连接池与读写分离(处理并发相关等)

 配置连接池与读写分类

  
  //写节点(主节点)
            List<string> writes = new List<string>();
            writes.Add("123456abcdef@127.0.0.1:6379");
            //读节点
            List<string> reads = new List<string>();
            reads.Add("123456abcdef@127.0.0.1:6379");
            reads.Add("123456abcdef@127.0.0.1:6379");
            reads.Add("123456abcdef@127.0.0.1:6379");

            //配置连接池和读写分类
            poolrl = new PooledRedisClientManager(writes, reads, new RedisClientManagerConfig()
            {
                MaxReadPoolSize = 50, //读节点个数
                MaxWritePoolSize = 50,//写节点个数
            });

注意这里配置密码的方式：      密码@ip:端口

如果你想读节点和写节点都一样的话，直接把读节点和写节点配置成一样的就好了

完整一点的代码：

 public class SingletonRedis
    {
        // 定义一个静态变量来保存类的实例
        private static PooledRedisClientManager poolrl;

        private static readonly object obj = new object();

        // 定义私有构造函数，使外界不能创建该类实例
        private SingletonRedis()
        {

        }

        /// <summary>
        /// 获取Redis写节点
        /// </summary>
        /// <returns></returns>
        public static RedisClient GetInstance()
        {
            // 如果连接池的实例不存在则创建，否则直接返回
            if (poolrl == null)
            {
                lock (obj)
                {
                    if (poolrl == null)
                    {
                        CreatePoolManager();
                    }
                }
            }

            return poolrl.GetClient() as RedisClient;
        }

        /// <summary>
        /// 获取Redis读节点(读取的时候就读取本地的，这样效率就会很快)
        /// </summary>
        /// <returns></returns>
        public static RedisClient GetReadOnlyInstance()
        {
            if (poolrl == null)
            {
                lock (obj)
                {
                    if (poolrl == null)
                    {
                        CreatePoolManager();
                    }
                }
            }
            return poolrl.GetReadOnlyClient() as RedisClient;
        }


        private static void CreatePoolManager()
        {
            ////写节点(主节点)
            List<string> writes = new List<string>();
            writes.Add("127.0.0.1:6379");
            //读节点(本地)
            List<string> reads = new List<string>();
            reads.Add("127.0.0.1:6379");
            reads.Add("127.0.0.1:6380");

            //配置连接池和读写分类
            poolrl = new PooledRedisClientManager(writes, reads, new RedisClientManagerConfig()
            {
                MaxReadPoolSize = 50, //读节点个数
                MaxWritePoolSize = 50,//写节点个数
            });
        }

    }

这样我们想要去写入缓存的时候就调用 GetInstance方法，如果是想要读的话就调用CreatePoolManager方法，通常读节点配置成本地缓存，这样效率快一点。

我们可以测试获取一下一下读节点，上面我们读接口设置了两个看看获取的情况：

我们可以看到找到6380的次数是10次，刚好是我们循环次数的一半，说明负载均衡做得不错哇

ps:当然读写分离其实更好一点的做法是：

1：使用一个项目专门负责读

2：另外一个项目专门复制写   

然后使用消息队列通讯就行了嘛，分离逻辑分离项目，降低耦合度，增强维护性

这样做的好处：处理redis就是一个独立的项目，相关的功能就会高内聚，不会在不同的项目都去重复的写，

这样维护起来就方便多了，就维护那一个地方的，不乱