PikaClient.py 文件源码

def __init__(self, host, port=5672, username='guest', password='guest', prefetch_count=1):
        """
        ???rmq?
        :param host:
        :param port:
        :param username:
        :param password:
        :param prefetch_count:
        :return:
        """
        self.queue_host = host
        self.queue_port = port
        self.credentials = pika.credentials.PlainCredentials(username=username, password=password)
        self.connection = pika.BlockingConnection(pika.ConnectionParameters(host=self.queue_host,
                                                                            port=self.queue_port,
                                                                            credentials=self.credentials))
        self.channel = self.connection.channel()
        self.channel.basic_qos(prefetch_count=prefetch_count)