Python中线程的MQ消息队列实现以及消息队列的优点解析

当前位置:

首页 > Python基础教程 >

Python中线程的MQ消息队列实现以及消息队列的优点解析

消息队列(MQ,Message Queue)在消息数据传输中的保存作用为数据通信提供了保障和实时处理上的便利,这里我们就来看一下Python中线程的MQ消息队列实现以及消息队列的优点解析

“消息队列”是在消息的传输过程中保存消息的容器。消息队列管理器在将消息从它的源中继到它的目标时充当中间人。队列的主要目的是提供路由并保证消息的传递；如果发送消息时接收者不可用，消息队列会保留消息，直到可以成功地传递它。相信对任何架构或应用来说，消息队列都是一个至关重要的组件，下面是十个理由:

Python的消息队列示例：

1.threading+Queue实现线程队列

#!/usr/bin/env python

import Queue

import threading

import time

queue = Queue.Queue()

class ThreadNum(threading.Thread):

 """没打印一个数字等待1秒，并发打印10个数字需要多少秒？"""

 def __init__(self, queue):

  threading.Thread.__init__(self)

  self.queue = queue

 def run(self):

  whileTrue:

   #消费者端，从队列中获取num

   num = self.queue.get()

   print "i'm num %s"%(num)

   time.sleep(1)

   #在完成这项工作之后，使用 queue.task_done() 函数向任务已经完成的队列发送一个信号

   self.queue.task_done()

start = time.time()

def main():

 #产生一个 threads pool, 并把消息传递给thread函数进行处理，这里开启10个并发

 for i in range(10):

  t = ThreadNum(queue)

  t.setDaemon(True)

  t.start()

 #往队列中填错数据 

 for num in range(10):

   queue.put(num)

 #wait on the queue until everything has been processed

 queue.join()

main()

print "Elapsed Time: %s" % (time.time() - start)

栏目列表