RabbitMQ 实现实现基本通信及订单处理，,　　一.基本使用 》

RabbitMQ 实现实现基本通信及订单处理，,　　一.基本使用 》

　　一.基本使用 》》》 依据官方文档

　　（1）生产端

# python 操作我们rabbitMq 需要的模块 pika# pip install pikaimport pika# 建立和RabbitMQ的链接connection = pika.BlockingConnection(pika.ConnectionParameters(‘localhost‘))# 通过句柄channel = connection.channel()# 声明消息队列channel.queue_declare(queue = ‘hello‘)# body 一个内容体 往队列中进行发消息channel.basic_publish(exchange=‘‘,                      routing_key=‘hello‘,                      body=‘Hello World!‘)print("[x]发送‘Hello World！‘")# 关闭connection.close()

　　（2）消费端

# 取消息import pika# 建立和RabbitMQ的链接connection = pika.BlockingConnection(pika.ConnectionParameters(‘localhost‘))# 通过句柄channel = connection.channel()# 确认我们的queue的是存在的channel.queue_declare(queue=‘hello‘)# 申明回调函数def callback(ch, method, properties, body):    print(" [x] Received %r" % body)# 从Q 中取消息channel.basic_consume(queue=‘hello‘,                      auto_ack=True,                      on_message_callback=callback)print(‘ [*] Waiting for messages. To exit press CTRL+C‘)channel.start_consuming()  # 开始消费

　　（3）执行

　　窗口一 放信息

　　窗口二 收消息

RabbitMQ 实现实现基本通信及订单处理