main.py 文件源码

def dispatch_thread(self):
        connection = pika.BlockingConnection(pika.ConnectionParameters(
            Static.RABBITMQ_HOST))
        channel = connection.channel()
        # ??????
        domain_queue = self.get_domain()
        while domain_queue.qsize() > 0:
            while domain_queue.qsize() > 0:
                now_count = channel.queue_declare(queue='domain_queue', durable=True).method.message_count
                #  ???????
                if now_count < QUEUE_LENGTH_MIN:
                    #  ????????????????????
                    while now_count < QUEUE_LENGTH_MAX:
                        if domain_queue.qsize() >= 100:
                            self.domain_push(domain_queue.get(), True)
                        else:
                            domain_queue = self.get_domain()
                        now_count = channel.queue_declare(queue='domain_queue', durable=True).method.message_count
                    #  ?????????????
                    time.sleep(WAIT_INTERVAL)

                # ?????????????????????
                time.sleep(MONITOR_INTERVAL)
                if domain_queue.qsize() < 100:
                    domain_queue = self.get_domain()