python redis 多進程使用

Question

{程式碼...} 根據文件寫了一個帶有連接池的redis client,然後產生一個實例全域使用。將一個實例，在多執行緒中共用測試過正常。但是多進程情況，測試失敗 {程式碼...} 這樣寫，執行start時，會報錯，無法序列化之類。改...

typecho · Answer

樓主，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