mq.py 文件源码

def __init__(self, host, port, queue='queue'):
        self._conn = redis.Redis(connection_pool=redis.BlockingConnectionPool(max_connections=15, host=host, port=port))
        self.set_queue(queue)