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

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

 1  List<string> listWrite = new List<string>() { "[email protected]:6380" };
 2             List<string> readHosts = new List<string>() { "192.168.8.245:6381", "192.168.8.245:6382" };
 3             PooledRedisClientManager clientManager = PoolManagerFactory.CreateManager(listWrite.ToArray(), readHosts.ToArray());
 4             ///可以在缓存管理器中加入密码验证  因为没有对应的密码字段显示
 5           ///通过getClient获取一个client 连接
 6             using (IRedisClient redisClient = clientManager.GetClient())
 7             {
 8                 IRedisTypedClient<Phone> phones = redisClient.As<Phone>();
 9
10                 Phone phoneFive = phones.GetValue("5");
11                 if (phoneFive == null)
12                 {
13                     phoneFive = new Phone()
14                     {
15                         ID = 5,
16                         Manufacturer = "Nokia",
17                         Model = "guozhiqi",
18                         Owner = new Person()
19                         {
20
21                             ID = 1,
22                             Name = "袁金州",
23                             Surname = "Old"
24                         }
25                     };
26                     phones.SetEntry(phoneFive.ID.ToString(), phoneFive);
27                 }
28                 Console.WriteLine("OwnerID" + phones.GetValue("5").Owner.Name);
29             }

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

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

 1  /// <summary>
 2         /// Returns a Read/Write client (The default) using the hosts defined in ReadWriteHosts
 3         /// 返回可以读写的 客户端连接   默认的  使用定义在readWriteHosts中的服务器地址
 4         /// </summary>
 5         /// <returns></returns>
 6         public IRedisClient GetClient()
 7         {
 8             lock (writeClients)
 9             {
10                 AssertValidReadWritePool();
11
12                 RedisClient inActiveClient;
13                 while ((inActiveClient = GetInActiveWriteClient()) == null)
14                 {
15                     if (PoolTimeout.HasValue)
16                     {
17                         // wait for a connection, cry out if made to wait too long
18                         if (!Monitor.Wait(writeClients, PoolTimeout.Value))
19                             throw new TimeoutException(PoolTimeoutError);
20                     }
21                     else
22                         Monitor.Wait(writeClients, RecheckPoolAfterMs);
23                 }
24
25                 WritePoolIndex++;
26                 inActiveClient.Active = true;
27
28                 if (this.ConnectTimeout != null)
29                 {
30                     inActiveClient.ConnectTimeout = this.ConnectTimeout.Value;
31                 }
32
33                 if (this.SocketSendTimeout.HasValue)
34                 {
35                     inActiveClient.SendTimeout = this.SocketSendTimeout.Value;
36                 }
37                 if (this.SocketReceiveTimeout.HasValue)
38                 {
39                     inActiveClient.ReceiveTimeout = this.SocketReceiveTimeout.Value;
40                 }
41                 if (this.IdleTimeOutSecs.HasValue)
42                 {
43                     inActiveClient.IdleTimeOutSecs = this.IdleTimeOutSecs.Value;
44                 }
45
46                 inActiveClient.NamespacePrefix = NamespacePrefix;
47
48                 //Reset database to default if changed
49                 if (inActiveClient.Db != Db)
50                 {
51                     inActiveClient.ChangeDb(Db);
52                 }
53
54                 return inActiveClient;
55             }
56         }

这是service-stack.redis中getClient的实现,但是我们发现了一个问题就是,他只从主 redis中获取连接,不可能返回slave 的readonly 连接。

如果缓存设置为5,那么如果同时500个请求,还是会有性能影响的,因为完全忽略了slave的读的功能。

如果要写,我们可以调用clientManager.GetClient() 来获取writeHosts的redis实例。

如果要读,我们可以调用clientManager.GetReadOnlyClient()来获取仅仅是readonlyHost的redis实例。

如果你嫌麻烦,那么完全可以使用clientManager.GetCacheClient() 来获取一个连接,他会在写的时候调用GetClient获取连接,读的时候调用GetReadOnlyClient获取连接,这样可以做到读写分离,从而利用redis的主从复制功能。

时间: 2024-11-06 02:53:12

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

使用Service.Stack客户端编写redis pub sub的方法

pub相对简单 client.PublishMessage("channel", "msg");   sub有2种方法 方法1 var subscription = client.CreateSubscription(); subscription.OnMessage = (channel, msg) => { Console.WriteLine(String.Format("Received '{0}' from channel '{1}'&quo

Redis进阶实践之十八 使用管道模式提高Redis查询的速度

原文:Redis进阶实践之十八 使用管道模式提高Redis查询的速度 一.引言 学习redis 也有一段时间了,该接触的也差不多了.后来有一天,以为同事问我,如何向redis中批量的增加数据,肯定是大批量的,为了这主题,我从新找起了解决方案.目前的解决方案大都是从官网上查找和翻译的,每个实例也都调试了,正确无误.把结果告诉我同事的时候,我也跟清楚这个主题如何操作了,里面的细节也更清楚了.大然也有人说可以通过脚本来做这个操作,没错,但是我对脚本语言还没有研究很透,就不来班门弄斧了. 二.管道的由来

网站加载速度慢的原因

排查网站打开速度慢的原因: 1 网站服务器速度或租用空间所在服务器速度 服务器空间速度是网站打开速度快的硬件基础,也是先决条件.否则即使你网站页面设计的非常"苗条",网站打开速度也会打折扣.解决办法:要找你的空间商解决或换空间商. 如何检测服务器速度快慢呢? 方法一: ping命令看连接到服务器的时间和丢包情况. 1>单击"开始"键并选择运行:接着在"运行"对话框中输入cmd 注:有的可能是输入command,也有可能有的windows不带

网站打开速度慢的原因,排查方法及优化方法

如果你的网站打开速度过慢,而你又不知道该如何解决,那么这篇文章是非看不可了.手把手的教你如何排查网站打开慢的原因,以及优化方法. 排查网站打开速度慢的原因: 1 网站服务器速度或租用空间所在服务器速度服务器空间速度是网站打开速度快的硬件基础,也是先决条件.否则即使你网站页面设计的非常"苗条",网站打开速度也会打折扣.解决办法:要找你的空间商解决或换空间商. 如何检测服务器速度快慢呢? 方法一: ping命令看连接到服务器的时间和丢包情况. 1>单击"开始"键并

SQL Server查询优化方法(查询速度慢的原因很多,常见如下几种) .

SQL Server查询优化方法(查询速度慢的原因很多,常见如下几种) 标签: sql server优化数据库服务器 2014-12-31 10:13 11988人阅读 评论(0) 收藏 举报 本文章已收录于: 今天看到一位博友的文章,觉得不错,转载一下,希望对大家有帮助,更多文章,请访问:http://blog.haoitsoft.com 1.没有索引或者没有用到索引(这是查询慢最常见的问题,是程序设计的缺陷) 2.I/O吞吐量小,形成了瓶颈效应. 3.没有创建计算列导致查询不优化. 4.内存

SQL Server数据库查询速度慢的原因和解决方法

问 SQL Server数据库查询速度慢的原因有很多,常见的有以下几种: 1.没有索引或者没有用到索引(这是查询慢最常见的问题,是程序设计的缺陷) 2.I/O吞吐量小,形成了瓶颈效应. 3.没有创建计算列导致查询不优化. 4.内存不足 5.网络速度慢 6.查询出的数据量过大(可以采用多次查询,其他的方法降低数据量) 7.锁或者死锁(这也是查询慢最常见的问题,是程序设计的缺陷) 8.sp_lock,sp_who,活动的用户查看,原因是读写竞争资源. 9.返回了不必要的行和列 10.查询语句不好,没

查询速度慢的原因很多,常见如下几种

1.没有索引或者没有用到索引(这是查询慢最常见的问题,是程序设计的缺陷) 2.I/O吞吐量小,形成了瓶颈效应. 3.没有 创建计算列导致查询不优化. 4.内存不足 5.网络速度慢 6.查询出的数据量过大(可以采用多次查询,其他的方法降低数据量) 7. 锁或者死锁(这也是查询慢最常见的问题,是程序设计的缺陷)sp_lock,sp_who,活动的用户查看,原因是读写竞争资源. 9.返回了不必 要的行和列 10.查询语句不好,没有优化 ●可以通过如下方法来优化查询 : 1. 把数据.日志.索引放到不同

参数化查询速度慢的原因及分析

测试环境:sql2005 + .NET2.0 同样的SQL语句,参数化查询和SQL语句直接执行的速度对比.数据库中存放的字段类型是varchar 结论: 1.对参数要设置正确的 DbType(varchar = AnsiString, nvarchar=String,char=AnsiStringFixedLength,nchar=StringFixedLength) 2.尽量使用数据库类型对应的DbType的. 3.尽量给参数的size设置大小 Code: class Program { pr

SQL查询速度慢的原因

1.没有索引或者没有用到索引(这是查询慢最常见的问题,是程序设计的缺陷) 2.I/O吞吐量小,形成了瓶颈效应. 3.没有创建计算列导致查询不优化. 4.内存不足 5.网络速度慢 6.查询出的数据量过大(可以采用多次查询,其他的方法降低数据量) 7.锁或者死锁(这也是查询慢最常见的问题,是程序设计的缺陷) 8.sp_lock,sp_who,活动的用户查看,原因是读写竞争资源. 9.返回了不必要的行和列 10.查询语句不好,没有优化 ●可以通过如下方法来优化查询 : 1)把数据.日志.索引放到不同的