发布/订阅系统

send.py

import pika

import time

s_conn = pika.BlockingConnection(pika.ConnectionParameters('127.0.0.1'))  # 创建连接

chan = s_conn.channel()  # 在连接上创建一个频道

chan.queue_declare(queue='hello')  # 声明一个队列，生产者和消费者都要声明一个相同的队列，用来防止万一某一方挂了，另一方能正常运行

while 1:

    time.sleep(1)

    chan.basic_publish(exchange='',  # 交换机

                       routing_key='hello',  # 路由键，写明将消息发往哪个队列，本例是将消息发往队列hello

                       body='Ye:当前时间%s ' % time.strftime('%m-%d %H:%M:%S'))  # 生产者要发送的消息

    print("[生产者] send 'hello world")

s_conn.close()  # 当生产者发送完消息后，可选择关闭

recv.py

import pika

s_conn = pika.BlockingConnection(pika.ConnectionParameters('127.0.0.1'))  # 创建连接

chan = s_conn.channel()  # 在连接上创建一个频道

chan.queue_declare(queue='hello')  # 声明一个队列，生产者和消费者都要声明一个相同的队列，用来防止万一某一方挂了，另一方能正常运行

def callback(ch, method, properties, body):  # 定义一个回调函数，用来接收生产者发送的消息

    print(ch, method, properties, )

    print(body.decode('utf8'))

chan.basic_consume('hello',  # 指定取消息的队列名,

                   callback,  # 调用回调函数，从队列里取消息

                   auto_ack=True)  # 取完一条消息后，给生产者发送确认消息，默认是False的，即  默认不给rabbitmq发送一个收到消息的确认

# 如果auto_ack=True则消失接收之后就会删除也就是只能取一次

print('[消费者] waiting for msg .')

chan.start_consuming()  # 开始循环取消息

巴特西

RabbitMQ之pika模块

发布/订阅系统

最新文章

热门文章

巴特西

RabbitMQ之pika模块

发布/订阅 系统

最新文章

热门文章

发布/订阅系统