博客
关于我
强烈建议你试试无所不能的chatGPT,快点击我
关于redis连接池
阅读量:6713 次
发布时间:2019-06-25

本文共 1821 字,大约阅读时间需要 6 分钟。

1、redis-py不需要显式使用连接池。

在幕后,redispy使用一个连接池来管理与Redis服务器的连接。默认情况下,每个Redis实例将依次创建自己的连接池。您可以通过将已创建的连接池实例传递给Redis类的connection_pool参数,来重写此行为并使用现有的连接池。您可以选择这样做,以便实现客户端分片或对连接的管理方式有更好的粒度控制。

 

2、一般写 r = Redis('127.0.0.1','6379'),别的模块导入r属性,一直保持使用这一个连接对象就可以了,不需要使用连接池,直接单例就可以。如果想无限制实例化使用同一个连接池对象,使用连接池,用法如下。

pool = redis.ConnectionPool(host='localhost', port=6379, db=0) >>> r1 = redis.Redis(connection_pool=pool)
>>> r2 = redis.Redis(connection_pool=pool) 类似于这样。 控制一下,每个redis服务器只有一个连接池。
# coding=utf8import redisimport unittestclass RedisManager(object):    _pool_dict = {}    def __init__(self, host='127.0.0.1', port=6379, db=0, password='123456'):        if (host, port, db, password) not in self.__class__._pool_dict:            print '创建一个连接池'            self.__class__._pool_dict[(host, port, db, password)] = redis.ConnectionPool(host=host, port=port, db=db, password=password)        self._r = redis.Redis(connection_pool=self._pool_dict[(host, port, db, password)])        self._ping()    def get_redis(self):        """        :rtype :redis.Redis        """        return self._r    def _ping(self):        try:            self._r.ping()        except Exception as e:            raise eclass _Test(unittest.TestCase):    def test_error_conn(self):        """测试错误的连接"""        self.assertRaises(Exception, RedisManager, password='1234567')    def test_get_redis(self):        """正常的连接,测试连接池创建次数"""        RedisManager().get_redis()        RedisManager().get_redis()        RedisManager().get_redis()        RedisManager().get_redis()        r = RedisManager().get_redis()        self.assertIsInstance(r, redis.Redis)    def test_set_key_value(self):        """设置值"""        r = RedisManager().get_redis()        r.set('a', 'c')        self.assertEqual(r.get('a'), 'c', msg='a的值不是c')if __name__ == '__main__':    unittest.main()

 

 
 

转载地址:http://wzelo.baihongyu.com/

你可能感兴趣的文章
clamav杀毒软件部署笔记
查看>>
小测试
查看>>
涨姿势一下:#include<>和#include""的区别
查看>>
quartz spring配置
查看>>
centos备份与还原
查看>>
fixed 兼容ie6
查看>>
To Be an Architect : 架构的一些基本概念
查看>>
数据恢复软件哪个好
查看>>
『火车进出栈问题 卡特兰数』
查看>>
第四天:HTTP&Tomcat
查看>>
python 文件和路径操作函数小结
查看>>
条件+努力=?
查看>>
HBase分布式安装
查看>>
随笔-文件的读写
查看>>
tcp 状态以及三次握手
查看>>
我的友情链接
查看>>
WAITED TOO LONG FOR A ROW CACHE ENQUEUE LOCK!的分析
查看>>
nginx禁止ip直接访问
查看>>
hadoop常用服务管理命令
查看>>
10.28 rsync工具10.29-10.30 rsync选项10.31 rsync通过ssh同步
查看>>