1 模式介绍
生产者-消费者模式是最简单的使用模式。
一个生产者P，给队列发送消息，一个消费者C来取队列的消息。
这里的队列长度不限，生产者和消费者都不用考虑队列的长度。
队列的模型图：
2 示例代码
生产者
#!/usr/bin/env python
import pika parameters = pika.ConnectionParameters('localhost')
connection = pika.BlockingConnection(parameters)
channel = connection.channel() channel.queue_declare(queue='hello')
number = 0
while number < 5:
channel.basic_publish(exchange='', routing_key='hello', body="hello world: {}".format(number))
print(" [x] Sent {}".format(number))
number += 1 connection.close()
消费者
#!/usr/bin/env python
import pika
import datetime parameters = pika.ConnectionParameters('localhost')
connection = pika.BlockingConnection(parameters)
channel = connection.channel() channel.queue_declare(queue='hello') def callback(ch, method, properties, body): # 定义一个回调函数，用来接收生产者发送的消息
print("{} [消费者] recv {}".format(datetime.datetime.now(), body)) channel.basic_consume(callback, queue='hello', no_ack=True)
print('{} [消费者] waiting for msg .'.format(datetime.datetime.now()))
channel.start_consuming() # 开始循环取消息
执行输出
生产者输出：
[x] Sent 0
[x] Sent 1
[x] Sent 2
[x] Sent 3
[x] Sent 4
消费者输出：
2018-07-06 16:10:05.308371 [消费者] waiting for msg .
2018-07-06 16:10:10.028588 [消费者] recv b'hello world: 0'
2018-07-06 16:10:10.028588 [消费者] recv b'hello world: 1'
2018-07-06 16:10:10.028588 [消费者] recv b'hello world: 2'
2018-07-06 16:10:10.028588 [消费者] recv b'hello world: 3'
2018-07-06 16:10:10.028588 [消费者] recv b'hello world: 4'
3 队列信息
在web管理页面上查看，点击queues，可以看到：hello队列