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

Posted 2021-03-20 mofujin

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

　　（1）生产端

 

 

# python 操作我们rabbitMq 需要的模块 pika
# pip install pika
import 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）执行

 　　窗口一 放信息

 

　　 窗口二  收消息