python redis 多进程使用-PHP中文网问答

文章专题 AI工具学习下载问答源码最近更新

PHP

会员中心讲师中心微信公众号

python redis 多进程使用

巴扎黑 2017-06-08 11:02:09

[Redis讨论组]

1475

class RedisClient(object):
    def __init__(self):
        pool = redis.ConnectionPool(host='127.0.0.1', port=6379)
        self.client = redis.StrictRedis(connection_pool=pool)

根据文档写了一个带连接池的redis client,然后生成一个实例全局使用。
将一个实例，在多线程中共用测试过正常。
但是多进程情况，测试失败

class ProcessRdeisTest(Process):
    def __init__(self,client):
        self._client = client

这样写，在执行start时，会报错，无法序列化之类。
改为：

class ProcessRdeisTest(Process):
    def __init__(self):
        pass
    def run(self):
        self._client = RedisClient()
        while Ture:
            dosomething()

这样倒是能运行起来，不过这种连接方式正确吗？是否有更好的办法实现？

在主线程中直接
process1 = ProcessRdeisTest('p1')
process1.start()
这种方式调用

巴扎黑

全部回复(1)

typecho2017-06-08 11:04:09 1楼

楼主，python redis有自己的连接池:

import redis
import threading

class RedisPool(object):
    __mutex = threading.Lock()
    __remote = {}

    def __new__(cls, host, passwd, port, db):
        with RedisPool.__mutex:
            redis_key = "%s:%s:%s" % (host, port, db)
            redis_obj = RedisPool.__remote.get(redis_key)
            if redis_obj is None:
                redis_obj = RedisPool.__remote[redis_key] = RedisPool.new_redis_pool(host, passwd, port, db)
        return redis.Redis(connection_pool=redis_obj)

    def __init__(self, host, passwd, port, db):
        pass

    @staticmethod
    def new_redis_pool(host, passwd, port, db):
        redis_obj = redis.ConnectionPool(host=host, password=passwd,
                                         port=port, db=db, socket_timeout=3, max_connections=10) # max_connection default 2**31
        return redis_obj

赞 +0

添加回复

专题推荐

更多>

热门话题

热门教程

更多>