首页 > 代码库 > python-RabbitMQ
python-RabbitMQ
简单队列方式
#!/usr/bin/env python # -*- coding:utf-8 -*- import Queue import threading #建立队列长度为10 message = Queue.Queue(10) #生产者 def producer(i): #往队列中扔消息 message.put(i) print(‘queue_size=%s‘%message.queue) #消费者 def consumer(i): #取队列消息,先进先出 msg = message.get() #生产线程 for i in range(10): t = threading.Thread(target=producer, args=(i,)) t.start() #消费线程 for i in range(5): t = threading.Thread(target=consumer, args=(i,)) t.start() #打印剩余的数据 print(‘queue_size=%s‘%message.queue)
结果:
生产队列增长过程过程
producer_queue=deque([0])
producer_queue=deque([0, 1])
producer_queue=deque([0, 1, 2])
producer_queue=deque([0, 1, 2, 3])
producer_queue=deque([0, 1, 2, 3, 4])
producer_queue=deque([0, 1, 2, 3, 4, 5])
producer_queue=deque([0, 1, 2, 3, 4, 5, 6])
producer_queue=deque([0, 1, 2, 3, 4, 5, 6, 7])
producer_queue=deque([0, 1, 2, 3, 4, 5, 6, 7, 8])
producer_queue=deque([0, 1, 2, 3, 4, 5, 6, 7, 8, 9])
剩余数据
queue=deque([4, 5, 6, 7, 8, 9])
以下是RabbitMQ 主要模式
1简单队列
2exchange{
1、fanout
2、direct
3 、topic
}
安装组件
pip install pika
对于RabbitMQ来说,生产和消费不再针对内存里的一个Queue对象,而是某台服务器上的RabbitMQ Server实现的消息队列。
python-RabbitMQ
声明:以上内容来自用户投稿及互联网公开渠道收集整理发布,本网站不拥有所有权,未作人工编辑处理,也不承担相关法律责任,若内容有误或涉及侵权可进行投诉: 投诉/举报 工作人员会在5个工作日内联系你,一经查实,本站将立刻删除涉嫌侵权内容。