当前位置：首页 > news >正文

Service-stack.redis 使用PooledRedisClientManager 速度慢的原因之一

news 来源：原创 2024/5/2 13:11:53

现在越来越多的开发者使用service-stack.redis 来进行redis的访问，但是获取redisclient的方式有多种方式，其中有一种从缓冲池获取client的方式很是得到大家的认可。

List<string> listWrite = new List<string>() { "6380@192.168.8.245:6380" };
            List<string> readHosts = new List<string>() { "192.168.8.245:6381", "192.168.8.245:6382" };
            PooledRedisClientManager clientManager = PoolManagerFactory.CreateManager(listWrite.ToArray(), readHosts.ToArray());
            ///可以在缓存管理器中加入密码验证  因为没有对应的密码字段显示
          ///通过getClient获取一个client 连接
            using (IRedisClient redisClient = clientManager.GetClient())
            {
                IRedisTypedClient<Phone> phones = redisClient.As<Phone>();
                
                Phone phoneFive = phones.GetValue("5");
                if (phoneFive == null)
                {
                    phoneFive = new Phone()
                    {
                        ID = 5,
                        Manufacturer = "Nokia",
                        Model = "guozhiqi",
                        Owner = new Person()
                        {

                            ID = 1,
                            Name = "袁金州",
                            Surname = "Old"
                        }
                    };
                    phones.SetEntry(phoneFive.ID.ToString(), phoneFive);
                }
                Console.WriteLine("OwnerID" + phones.GetValue("5").Owner.Name);
            }

请注意上面代码的第五行，using (IRedisClient redisClient = clientManager.GetClient()){}

通过clientManager.getClient方法来获取一个连接，我们在ado.net中也是采用这种方式，而且性能很高。我们认为这种方式的工作方式肯定是首先从缓冲池中获取一条连接，然后执行using里面的代码，最后dispose。但是有时候这种方式在稍微访问量大的时候性能很低，什么原因呢？

/// <summary>
        /// Returns a Read/Write client (The default) using the hosts defined in ReadWriteHosts
        /// 返回可以读写的 客户端连接   默认的  使用定义在readWriteHosts中的服务器地址
        /// </summary>
        /// <returns></returns>
        public IRedisClient GetClient()
        {
            lock (writeClients)
            {
                AssertValidReadWritePool();

                RedisClient inActiveClient;
                while ((inActiveClient = GetInActiveWriteClient()) == null)
                {
                    if (PoolTimeout.HasValue)
                    {
                        // wait for a connection, cry out if made to wait too long
                        if (!Monitor.Wait(writeClients, PoolTimeout.Value))
                            throw new TimeoutException(PoolTimeoutError);
                    }
                    else
                        Monitor.Wait(writeClients, RecheckPoolAfterMs);
                }

                WritePoolIndex++;
                inActiveClient.Active = true;

                if (this.ConnectTimeout != null)
                {
                    inActiveClient.ConnectTimeout = this.ConnectTimeout.Value;
                }

                if (this.SocketSendTimeout.HasValue)
                {
                    inActiveClient.SendTimeout = this.SocketSendTimeout.Value;
                }
                if (this.SocketReceiveTimeout.HasValue)
                {
                    inActiveClient.ReceiveTimeout = this.SocketReceiveTimeout.Value;
                }
                if (this.IdleTimeOutSecs.HasValue)
                {
                    inActiveClient.IdleTimeOutSecs = this.IdleTimeOutSecs.Value;
                }

                inActiveClient.NamespacePrefix = NamespacePrefix;

                //Reset database to default if changed
                if (inActiveClient.Db != Db)
                {
                    inActiveClient.ChangeDb(Db);
                }

                return inActiveClient;
            }
        }