python消息订阅_python rabbitmq消息发布订阅

发送端：import pika

import sys

connection = pika.BlockingConnection(pika.ConnectionParameters(

host='localhost'))

channel = connection.channel()

channel.exchange_declare(exchange='logs',exchange_type='fanout')

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')

result = channel.queue_declare(exclusive=True) # 不指定queue名字,rabbit会随机分配一个名字,exclusive=True会在使用此queue的消费者断开后,自动将queue删除

queue_name = result.method.queue

print(queue_name)

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)

channel.basic_consume(callback,

queue=queue_name,

no_ack=True)

channel.start_consuming()

exchange不会保存数据，如果没客户端接受，就丢弃，也就是说，客户端会丢失启动前发送端发送的数据。

python消息订阅_python rabbitmq消息发布订阅相关推荐

消息队列中点对点与发布订阅区别
背景知识 JMS一个在 Java标准化组织(JCP)内开发的标准(代号JSR 914).2001年6月25日,Java消息服务发布JMS 1.0.2b,2002年3月18日Java消息服务发布 1.1 ...
消息队列中点对点与发布订阅区别（good）
背景知识 JMS一个在 Java标准化组织(JCP)内开发的标准(代号JSR 914).2001年6月25日,Java消息服务发布JMS 1.0.2b,2002年3月18日Java消息服务发布 1.1 ...
redis订阅和发布消息推送php,redis发布订阅什么用
Redis 发布订阅(pub/sub)是一种消息通信模式:发送者(pub)发送消息,订阅者(sub)接收消息. Redis 客户端可以订阅任意数量的频道. (推荐学习:Redis视频教程) Redis ...
python消息队列_python之消息队列
消息持久化 acknowledgment 消息不丢失的方法生效方法:channel.basic_consume(consumer_callback, queue, no_ack=False, exc ...
RabbitMq之发布订阅模式
这里写了一个简单的springboot的demo来处理RabbitMq的发布订阅添加pom依赖 <dependency><groupId>com.rabbitmq</g ...
消息队列模式（点对点发布订阅）
Java消息服务(Java Message Service,JMS)应用程序接口是一个Java平台中关于面向消息中间件(MOM)的API,用于在两个应用程序之间,或分布式系统中发送消息,进行异步通信. ...
RabbitMQ 之发布订阅模式
publish/subscribe 发布订阅模式中,生产者不再直接与队列绑定,而是将数据发送至交换机Exchange 交换机Exchange用于将数据按某种规则送入与之绑定的队列,进而供消费者使用. ...
SpringBoot监听redis订阅监听和发布订阅
前言我们可以在redis中发布一条订阅到通道中,所有监听了这个通道的都可以收到这个发布的内容! redis订阅监听配置类代码如下: RedisListenerConfig.java package ...
redis发布订阅c接口_Redis 发布/订阅机制原理分析
序:使用订阅发布功能的时候想查一下客户端是如何接收消息的(客户端订阅了频道之后也会注册一个回调函数,服务端publish消息之后回调函数会获取到消息.这块没看到太多内容只有C++的源码),无意中查到这 ...

python消息订阅_python rabbitmq消息发布订阅

python消息订阅_python rabbitmq消息发布订阅相关推荐

最新文章

热门文章