問(wèn)題描述

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

根據(jù)文檔寫(xiě)了一個(gè)帶連接池的redis client,然后生成一個(gè)實(shí)例全局使用。將一個(gè)實(shí)例，在多線程中共用測(cè)試過(guò)正常。但是多進(jìn)程情況，測(cè)試失敗

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

這樣寫(xiě)，在執(zhí)行start時(shí)，會(huì)報(bào)錯(cuò)，無(wú)法序列化之類(lèi)。改為：

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

這樣倒是能運(yùn)行起來(lái)，不過(guò)這種連接方式正確嗎？是否有更好的辦法實(shí)現(xiàn)？

在主線程中 直接process1 = ProcessRdeisTest(’p1’) process1.start() 這種方式調(diào)用

問(wèn)題解答

樓主，python redis有自己的連接池:

import redisimport threadingclass 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**31return redis_obj