多进程兔子消费者答案

【问题标题】：multiprocess rabbit consumer多进程兔子消费者
【发布时间】：2017-02-15 11:11:17
【问题描述】：

提前致谢。我是多处理的新手。我创建了一个进程，我想通过它同时使用 Rabbit MQueue 中的数据，但它一次运行一个进程。

def start_consum(queue_name):
    channel.basic_consume(func, queue=queue_name)
    channel.start_consuming()

def process_start(number):
    from multiprocessing import Process
    events = ["ev1","ev2","ev3"]
    for process in range(number):
        for event in events:
            proc = Process(target= start_consum(event))
            proc.daemon = True
            proc.start()


process_start(10)

在上面的代码中，它开始使用第一个事件，然后开始第二个事件。

【问题讨论】：

标签： multithreading python-2.7 rabbitmq python-multiprocessing pika

【解决方案1】：

您可以为此启动一个线程。

class Threaded_worker(threading.Thread):
    def __init__(self):
        threading.Thread.__init__(self)
        self.credentials = pika.PlainCredentials('', '')
        self.connection = pika.BlockingConnection(pika.ConnectionParameters(credentials=self.credentials,host=))
        self.channel = self.connection.channel()
        self.channel.basic_qos(prefetch_count=1)
        events = ["ev1","ev2","ev3"]
        for event in events:
            self.channel.basic_consume(func, queue=event)             

    def run(self):
        print 'start consuming'
        self.channel.start_consuming()

    def thread_start(numberofthreads):                
        for _ in range(numberofthreads):
            td = Threaded_worker()
            td.setDaemon(True)
            td.start()

【讨论】：