zoukankan      html  css  js  c++  java
  • Python操作rabbitmq系列(三):多个接收端消费消息

    接着上一章。这一章,我们要将同一个消息发给多个客户端。这就是发布订阅模式。直接看代码:

    发送端:

    import pika
    import sys

    connection = pika.BlockingConnection(pika.ConnectionParameters(host='localhost'))
    channel = connection.channel()

    # 原则上,消息,只能有交换机传到队列。就像我们家里面的交换机道理一样。
    # 有多个设备连接到交换机,那么,这个交换机把消息发给那个设备呢,就是根据
    # 交换机的类型来定。类型有:direct opicheadersfanout
    # fanout:这个就是,所有的设备都能收到消息,就是广播。
    # 此处定义一个名称为'logs'的'fanout'类型的exchange
    channel.exchange_declare(exchange='logs',
    exchange_type='fanout')

    # 将消息发送到名为log的exchange中
    # 因为是fanout类型的exchange,所以无需指定routing_key
    message = ' '.join(sys.argv[1:]) or "info: Hello World!"
    channel.basic_publish(exchange='logs',
    routing_key='',
    body=message)
    print(" [x] Sent %r" % message)
    connection.close()

    接收端:

    import pika

    connection = pika.BlockingConnection(pika.ConnectionParameters(host='localhost'))
    channel = connection.channel()

    # 这里需要和发送端保持一致(习惯和要求)
    channel.exchange_declare(exchange='logs',
    exchange_type='fanout')

    # 类似的,比如log,我们其实最想看的,当连接上的时刻到消费者退出,这段时间的日志
    # 有些消息,过期了的对我们并没有什么用
    # 并且,一个终端,我们要收到队列的所有消息,比如:这个队列收到两个消息,一个终端收到一个。
    # 我们现在要做的是:两个终端都要收到两个
    # 那么,我们就只需做个临时队列。消费端断开后就自动删除
    result = channel.queue_declare(exclusive=True)
    # 取得队列名称
    queue_name = result.method.queue

    # 将队列和交换机绑定一起
    channel.queue_bind(exchange='logs',
    queue=queue_name)

    print(' [*] Waiting for logs. To exit press CTRL+C')


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


    # no_ack=True:此刻没必要回应了
    channel.basic_consume(callback,
    queue=queue_name,
    no_ack=True)

    channel.start_consuming()

    效果:

  • 相关阅读:
    记周日一次故障意外
    每周一坑-【3月第1周】
    关于计划任务的一个小需求-优化篇
    400篇博客的一个里程碑
    关于计划任务的一个小需求-实现篇
    关于计划任务的一个小需求
    微服务优雅停机研究
    NSUInteger设为负数
    Mac上运行第一个Flutter项目
    Vue filtersfilter、computed、methods、watch对比
  • 原文地址:https://www.cnblogs.com/zijiyanxi/p/7648228.html
Copyright © 2011-2022 走看看