RabbitMQ学习笔记【1】

生产者:

# 生产者
import pika

# 链接本地rabbitmq,获取channel对象
connection = pika.BlockingConnection(pika.ConnectionParameters('localhost'))
channel = connection.channel()

# RabbitMQ有两种方式发布消息:
    # 一种是生产者直接通过队列发布
    # 一种是通过交换机的方式发布
# 交换机的方式更灵活,交换机的模式一种有4种:
    # direct = 'direct'  处理路由键。需要将一个队列绑定到交换机上,要求该消息与一个特定的路由键完全匹配。
    # fanout = 'fanout'  不处理路由键。你只需要简单的将队列绑定到交换机上。(广播模式,只要绑定了就发,不区分routing_key)
    # headers = 'headers'
    # topic = 'topic'  将路由键和某模式进行匹配。此时队列需要绑定要一个模式上。
# 符号“#”匹配一个或多个词,符号“*”匹配不多不少一个词。因此“audit.#”能够匹配到“audit.irs.corporate”,
   # 但是“audit.*” 只会匹配到“audit.irs”。 # 性能排序:fanout > direct >> topic。比例大约为11:10:6 # # 申明一个名称为hello的队列 # channel.queue_declare(queue='hello') # 申明一个交换机 channel.exchange_declare(exchange='logs', exchange_type='fanout') # 向队列中插入一个数据"hello world!" # channel.basic_publish(exchange='', # 交换机模式 # routing_key='hello', # 当交换机为空时,routing_key就是要插入的队列名称 # body='Hello World1111!') # 插入的数据 # 向交换机插入数据 channel.basic_publish(exchange='logs', # 交换机模式 routing_key='', # 当交换机模式为fanout模式,为空 body='Hello rasion!') # 插入的数据 print(" [x] Sent 'Hello World!'")

消费者:

# 消费者
import pika
import time

# 链接本地rabbitmq,获取channel对象
connection = pika.BlockingConnection(pika.ConnectionParameters('localhost'))
channel = connection.channel()

# 创建交换机(若消费者先启动,需要有交换机)
channel.exchange_declare(exchange='logs',
                         exchange_type='fanout')

# 申明一个名称为hello的队列
result = channel.queue_declare("", exclusive=True)
queue_name = result.method.queue
print(result.method.queue)  # 随机队列名

# 绑定交换机
channel.queue_bind(exchange='logs',
                   queue=queue_name)

# 回调函数
def callback(ch, method, properties, body):
    time.sleep(1)
    print(" [x] Received body %r" % body)
    print(" [x] Received ch %r" % ch)
    print(" [x] Received method %r" % method)
    print(" [x] Received properties %r" % properties)
    # ch.basic_ack(delivery_tag=method.delivery_tag)  # 应答


# 监听绑定
channel.basic_consume(queue=queue_name,
                      auto_ack=True,
                      on_message_callback=callback)


print(' [*] Waiting for messages. To exit press CTRL+C')
# 启动监听
channel.start_consuming()

 

上一篇:javaswitch能接受哪几种参数,涨姿势了!


下一篇:吴裕雄--天生自然--SPRING BOOT--解决:method(reply-code=406, inequivalent arg 'type