Exchange-fanout 广播模式

# -*- coding: UTF-8 -*-

import pika

# 声明一个连接
connection = pika.BlockingConnection(pika.ConnectionParameters(
    host='localhost'))

# 声明一个管道
channel = connection.channel()

# 声明一个exchange,并命名exchange 和定义它的类型
channel.exchange_declare(exchange='test-exchange',
                         exchange_type='fanout')

# 消息内容
message = 'hello,world!'

# 生成一个消息
channel.basic_publish(exchange='test-exchange',
                      routing_key='',  # 设置为空
                      body=message,
                      )
print('[x] Sent %r' % message)

# 关闭连接
connection.close()

# -*- coding: UTF-8 -*-

import pika

# 创建一个连接
connection = pika.BlockingConnection(pika.ConnectionParameters(
    host='localhost'))
# 创建一个管道
channel = connection.channel()

# 声明一个exchange,并命名exchange 和定义它的类型
# 和生产端一致
channel.exchange_declare(exchange='test-exchange',
                         exchange_type='fanout')

# 在这里我们要声明队列
# 虽然在生产端我们没有声明队列，是因为消息是广播的，对所有队列发送
# 在此声明的队列也不用命名，rabbitmq会随机分配名称
# 也是就是说消费端还是要从队列中获取消息内容

result = channel.queue_declare(exclusive=True)
# exclusive=True会在使用此queue的消费者断开后,自动将queue删除

# 队列名
queue_name = result.method.queue

# 绑定exchange
channel.queue_bind(exchange='test-exchange',
                   queue=queue_name)
print(' [*] Waiting for logs. To exit press CTRL+C')


def callback(ch, method, properties, body):
    print(" [x] %r" % body)


channel.basic_consume(callback,
                      queue=queue_name,
                      no_ack=True)

channel.start_consuming()

exclusive=True

# 消费端只有存在的时候，队列名才会存在，并且exchange会向这个队列中
# 发送消息，一旦消费端关闭，队列queue就会被删除