RabbitMQ队列

标签：rod   基础上   是什么   传递   log   解决   html   blog   get   

RabbitMQ是什么？

RabbitMQ是一个在AMQP基础上完整的，可复用的企业消息系统。他遵循Mozilla Public License开源协议。

MQ全称为Message Queue, 消息队列（MQ）是一种应用程序对应用程序的通信方法。应用程序通过读写出入队列的消息（针对应用程序的数据）来通信，而无需专用连接来链接它们。消 息传递指的是程序之间通过在消息中发送数据进行通信，而不是通过直接调用彼此来通信，直接调用通常是用于诸如远程过程调用的技术。排队指的是应用程序通过 队列来通信。队列的使用除去了接收和发送应用程序同时执行的要求。

RabbitMQ的安装

首先说明，RabbitMQ在win上安装是一件颇为麻烦的事情。试了很长时间都没有成功，后来就转战linux了。在linux的安装中也可能会出现一点问题，下面会贴出一个网址有安装中出现问题的解决办法。

linux上都是直接install rabbitmq-server

当然可能会在安装中和后来的使用上出现这样或者是那样的问题，解决办法参见这篇博客http://www.cnblogs.com/kaituorensheng/p/4985767.html

RabbitMQ的语法以及实例

基于Queue实现生产者消费者模型

 1 import Queue
 2 import threading
 3 
 4 
 5 message = Queue.Queue(10)
 6 
 7 
 8 def producer(i):
 9     while True:
10         message.put(i)
11 
12 
13 def consumer(i):
14     while True:
15         msg = message.get()
16 
17 
18 for i in range(12):
19     t = threading.Thread(target=producer, args=(i,))
20     t.start()
21 
22 for i in range(10):
23     t = threading.Thread(target=consumer, args=(i,))
24     t.start()

View Code

对于RabbitMQ来说，生产和消费不再针对内存里的一个Queue对象，而是某台服务器上的RabbitMQ Server实现的消息队列。

 1 import pika
 2 
 3 connection = pika.BlockingConnection(pika.ConnectionParameters(
 4     host=‘localhost‘))
 5 channel = connection.channel()#开通一个管道
 6 
 7 #声明queue
 8 channel.queue_declare(queue=‘hello‘)
 9 
10 channel.basic_publish(exchange=‘‘,
11                       routing_key=‘hello‘,#queue名字
12                       body=‘Hello World!‘)#消息内容
13 print(" [x] Sent ‘Hello World!‘")
14 connection.close()

RabbitMQ队列

标签：rod   基础上   是什么   传递   log   解决   html   blog   get   

原文地址：http://www.cnblogs.com/lixiaoliuer/p/6846063.html