Python 中使用 RabbitMQ 实现多线程

import threading
import pika

class ConsumerThread(threading.Thread):
    def __init__(self, queue_name):
        super(ConsumerThread, self).__init__()
        self.queue_name = queue_name

    def run(self):
        connection = pika.BlockingConnection(pika.ConnectionParameters('localhost'))
        channel = connection.channel()
        channel.queue_declare(queue=self.queue_name)
        channel.basic_consume(queue=self.queue_name, on_message_callback=self.callback, auto_ack=True)
        channel.start_consuming()

    def callback(self, ch, method, properties, body):
        print("Received message: %r" % body)

def main():
    threads = []
    for i in range(5):
        thread = ConsumerThread('my_queue')
        thread.start()
        threads.append(thread)

    for thread in threads:
        thread.join()

if __name__ == '__main__':
    main()