RabbitMQ 发布订阅测试
2017-02-14 10:06
519 查看
【测试一】1个producer,1个consumer
分别打开两个命令行窗口进入python执行:
#cmd窗口一
import pika
connection = pika.BlockingConnection(pika.ConnectionParameters(host='localhost'))
channel = connection.channel()
channel.queue_declare(queue='hello') #通道使用队列:hello
channel.basic_publish(exchange='', routing_key='hello',body='Hello World!')#每次更改body信息多次执行
【测试二】1个producer,2个consumer (每个[b]consumer 轮流获取消息)[/b]
分别打开多个命令行窗口进入python执行:
#cmd窗口一
import pika
connection = pika.BlockingConnection(pika.ConnectionParameters(host='localhost'))
channel = connection.channel()
channel.queue_declare(queue='hello') #通道使用队列:hello
channel.basic_publish(exchange='', routing_key='hello',body='Hello World!')#每次更改body信息多次执行
【测试三】1个producer,1个exchange,2个队列,2个consumer (每个队列信息相同)
#cmd窗口一
import pika
connection = pika.BlockingConnection(pika.ConnectionParameters(host='localhost'))
channel = connection.channel()
channel.exchange_declare(exchange='logs',type='fanout')
channel.basic_publish(exchange='logs', routing_key='',body='Hello World!')
参考:http://www.rabbitmq.com/tutorials/tutorial-one-python.html
分别打开两个命令行窗口进入python执行:
#cmd窗口一
import pika
connection = pika.BlockingConnection(pika.ConnectionParameters(host='localhost'))
channel = connection.channel()
channel.queue_declare(queue='hello') #通道使用队列:hello
channel.basic_publish(exchange='', routing_key='hello',body='Hello World!')#每次更改body信息多次执行
#cmd窗口二 import pika connection = pika.BlockingConnection(pika.ConnectionParameters(host='localhost')) channel = connection.channel() channel.queue_declare(queue='hello') #通道使用队列:hello def callback(ch, method, properties, body): print("接收信息:%r" % body) channel.basic_consume(callback,queue='hello',no_ack=True) channel.start_consuming()执行结果:
【测试二】1个producer,2个consumer (每个[b]consumer 轮流获取消息)[/b]
分别打开多个命令行窗口进入python执行:
#cmd窗口一
import pika
connection = pika.BlockingConnection(pika.ConnectionParameters(host='localhost'))
channel = connection.channel()
channel.queue_declare(queue='hello') #通道使用队列:hello
channel.basic_publish(exchange='', routing_key='hello',body='Hello World!')#每次更改body信息多次执行
#cmd窗口二 / cmd窗口三 / cmd窗口四 ………… import pika connection = pika.BlockingConnection(pika.ConnectionParameters(host='localhost')) channel = connection.channel() channel.queue_declare(queue='hello') #通道使用队列:hello def callback(ch, method, properties, body): print("接收信息:%r" % body) channel.basic_qos(prefetch_count=1) #比测试一多此命令 channel.basic_consume(callback,queue='hello',no_ack=True) channel.start_consuming()执行结果:
【测试三】1个producer,1个exchange,2个队列,2个consumer (每个队列信息相同)
#cmd窗口一
import pika
connection = pika.BlockingConnection(pika.ConnectionParameters(host='localhost'))
channel = connection.channel()
channel.exchange_declare(exchange='logs',type='fanout')
channel.basic_publish(exchange='logs', routing_key='',body='Hello World!')
#cmd窗口二 / cmd窗口三 / cmd窗口四 ………… import pika connection = pika.BlockingConnection(pika.ConnectionParameters(host='localhost')) channel = connection.channel() channel.exchange_declare(exchange='logs',type='fanout') result = channel.queue_declare(exclusive=True) queue_name = result.method.queue channel.queue_bind(exchange='logs',queue=queue_name) def callback(ch, method, properties, body): print("接收信息:%r" % body) channel.basic_consume(callback,queue=queue_name,no_ack=True) channel.start_consuming()执行结果:
参考:http://www.rabbitmq.com/tutorials/tutorial-one-python.html
相关文章推荐
- RabbitMQ下的生产消费者模式与订阅发布模式
- RabbitMQ --- Publish-Subscribe(发布-订阅)
- RabbitMQ (三)消息的发布于订阅
- RabbitMQ (三) 发布/订阅
- RabbitMQ下的生产消费者模式与订阅发布模式
- RabbitMQ的订阅和发布步骤详解
- rabbitmq 发布/订阅
- 06-rabbitmq-发布订阅-spring
- RabbitMQ (三) 发布/订阅
- RabbitMQ 发布和订阅
- RabbitMQ (三) 发布/订阅 -摘自网络
- RabbitMQ (三) 发布/订阅
- RabbitMQ发布订阅"Hello World"消息
- 轻松搞定RabbitMQ(四)——发布/订阅
- RabbitMQ (三) 发布/订阅
- MAC下搭建MQTT客户端,测试发布和订阅话题
- RabbitMQ 教程3 发布与订阅
- RabbitMQ下的生产消费者模式与订阅发布模式
- 轻松搞定RabbitMQ(四)——发布/订阅
- (转) RabbitMQ学习之发布/订阅(java)