# RabbitMQ 簡單使用 - python **依賴:** ``` pip3 install pika==0.12 ``` **生產者(發送):** ```python import pika # producer connection = pika.BlockingConnection(pika.ConnectionParameters(host='localhost')) channel = connection.channel() channel.queue_declare('hello') channel.basic_publish(exchange='', routing_key='hello',body='Hello World!') print('[x] sent "Hello World!"') connection.close() # 我們可以在命令行模式運行 rabbitmqctl list_queues 來查看隊列 ``` **消費者(接收):** ```python import pika connection = pika.BlockingConnection(pika.ConnectionParameters(host='localhost')) channel = connection.channel() # 如果不聲明隊列標識的話,如果接收程序先啟動,將會報錯 channel.queue_declare(queue = 'hello') # 定義callback函數,處理在隊列中獲取的數據 def callback(ch, method, properties, body): print("[x] Received %r" % body.decode()) # ch.basic_ack(delivery_tag=method.delivery_tag) 告訴隊列, 處理完成 channel.basic_consume(callback, queue= 'hello', no_ack = True) # no_ack 不用隊列系統發送確認, 默認false. 處理完后沒有發送確認或系統崩潰自動分發給其他消費者處理 print('[*] Waiting for messages. To exit press CTRL+C') channel.start_consuming() ``` **參考資料:** - [Python操作rabbitmq 實踐筆記](https://www.cnblogs.com/wt11/p/5970297.html) - [報錯: basic_consume() got multiple values for keyword argument 'queue'](https://blog.csdn.net/xc_zhou/article/details/91483096)