python rabbitmq no_

• 2020 年 1 月 14 日
• 筆記

发送端：

import pika    connection = pika.BlockingConnection(pika.ConnectionParameters('localhost'))  channel = connection.channel()    channel.queue_declare(queue='hello')    # for i in range(100):  channel.basic_publish(exchange='',                        routing_key='hello',                        body="hello world")  # print("Sent 'hello world!'")  connection.close()

接收端：

#!/usr/bin/env python  import pika  import time  connection = pika.BlockingConnection(pika.ConnectionParameters(host='localhost'))  channel = connection.channel()    channel.queue_declare(queue='hello')  # channel.queue_bind(queue='hello',exchange='',routing_key='hello')  def callback(ch, method, properties, body):      print("aaa")      time.sleep(8)      print(" [x] Received %r" % body)        channel.basic_consume(callback,                        queue='hello',                        no_ack=False)    print(' [*] Waiting for messages. To exit press CTRL+C')  channel.start_consuming()