发送端：importpika
importsys
connection=pika.BlockingConnection(pika.ConnectionParameters(
host=‘localhost‘))
channel=connection.channel()
channel.exchange_declare(exchange=‘topic_logs‘,
exchange_type=‘topic‘)
routing_key=sys.argv[1]iflen(sys.argv)>1e..
分类：
其他好文 时间：
2017-10-17 20:02:11
阅读次数：
113
发送端：importpika
importsys
connection=pika.BlockingConnection(pika.ConnectionParameters(
host=‘localhost‘))
channel=connection.channel()
channel.exchange_declare(exchange=‘direct_logs‘,
exchange_type=‘direct‘)
severity=sys.argv[1]iflen(sys.argv)>1el..
分类：
其他好文 时间：
2017-10-16 22:07:28
阅读次数：
174
本节内容 一 RabbitMQ介绍 二 RabbitMQ安装配置 三 RabbitMQ的Python实现-pika 1. 生产者消费者 2. 工作队列 3. 持久化和公平分发 4. 发布与订阅 5. RPC 附：概念汇总 1. RabbitMQ使用场景 RabbitMQ是一个消息中间件，消息中间件【 ...
分类：
其他好文 时间：
2017-10-14 21:10:36
阅读次数：
290
发送端：importpika
importsys
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:HelloWorld!"
..
分类：
编程语言 时间：
2017-10-13 22:28:35
阅读次数：
253
给接收端添加：channel.basic_qos(prefetch_count=1)##一次处理一个，处理完再接受新消息发送端：importpika
connection=pika.BlockingConnection(pika.ConnectionParameters(‘localhost‘))
channel=connection.channel()
channel.queue_declare(queue=‘hello‘,durable=True..
分类：
编程语言 时间：
2017-10-12 13:57:06
阅读次数：
185
发送端：importpika
connection=pika.BlockingConnection(pika.ConnectionParameters(‘localhost‘))
channel=connection.channel()
channel.queue_declare(queue=‘hello‘)
#foriinrange(100):
channel.basic_publish(exchange=‘‘,
routing_key=‘hello‘,
body="helloworld")
..
分类：
编程语言 时间：
2017-10-11 00:59:25
阅读次数：
227
发送端：importpika
connection=pika.BlockingConnection(pika.ConnectionParameters(‘localhost‘))
channel=connection.channel()
channel.queue_declare(queue=‘hello‘,durable=True)##队列持久化，队列重启后也存在，不保证数据是否存在
#channel.queue_delete(queue="ta..
分类：
编程语言 时间：
2017-10-11 00:58:46
阅读次数：
217
接着上一章。这一章，我们要将同一个消息发给多个客户端。这就是发布订阅模式。直接看代码： 发送端： import pikaimport sysconnection = pika.BlockingConnection(pika.ConnectionParameters(host='localhost') ...
分类：
编程语言 时间：
2017-10-10 23:17:01
阅读次数：
335
今天，我们要逐步开始讨论rabbitmq稍微高级点的耍法了。了解这一步，对我们设计高并发的系统非常有用。当然，还可以使用kafka。不过还是算了，有几个硬性条件不支持，还是用rabbitmq吧。 循环分发： 启动一个发送端往队列发消息，此时启动多个接收端。发送的消息会对接收端一个一个挨着发送消息。如 ...
分类：
编程语言 时间：
2017-10-10 23:11:51
阅读次数：
1722
发送端:importpika
connection=pika.BlockingConnection(pika.ConnectionParameters(‘localhost‘))
channel=connection.channel()
channel.queue_declare(queue=‘hello‘)
foriinrange(100):
channel.basic_publish(exchange=‘‘,
routing_key=‘hello‘,
body=str(i))
#print("..
分类：
编程语言 时间：
2017-10-10 16:29:15
阅读次数：
159
