rabbitmq开始使用rabbitmq


备注

本节概述了rabbitmq是什么,以及开发人员为什么要使用它。

它还应该提到rabbitmq中的任何大型主题,并链接到相关主题。由于rabbitmq的文档是新的,您可能需要创建这些相关主题的初始版本。

版本

发行说明发布日期
3.6.5 发行说明 2016年8月5日
3.6.4 发行说明 2016年7月29日
3.6.3 发行说明 2016年7月6日
3.6.2 发行说明 2016年5月19日
3.6.1 发行说明 2016年3月1日
3.6.0 发行说明 2015年12月22日
3.5.7 发行说明 2015年12月15日
3.5.6 发行说明 2015年10月7日
3.5.5 发行说明 2015年9月24日
3.5.4 发行说明 2015年7月22日
3.5.3 发行说明 2015年5月22日
3.5.2 发行说明 2015年5月12日
3.5.1 发行说明 2015年4月3日
3.5.0 发行说明 2015-03-11
3.4.4 发行说明 2015年2月11日
3.4.3 发行说明 2015年1月7日
3.4.2 发行说明 情节中字
3.4.1 发行说明 2014年10月29日
3.4.0 发行说明 2014年10月21日
3.3.5 发行说明 2014年8月11日
3.3.4 发行说明 2014年6月24日
3.3.3 发行说明 2014年6月17日
3.3.2 发行说明 2014年6月9日
3.3.1 发行说明 2014年4月29日
3.3.0 发行说明 2014年4月2日
3.2.4 发行说明 2014年3月4日
3.2.3 发行说明 2014年1月23日
3.2.2 发行说明 2013年12月11日
3.2.1 发行说明 2013年11月7日
3.2.0 发行说明 2013年10月23日
3.1.5 发行说明 2013-08-15
3.1.4 发行说明 2013年8月7日
3.1.3 发行说明 2013年6月26日
3.1.2 发行说明 2013年6月24日
3.1.1 发行说明 2013年5月21日
3.1.0 发行说明 2013年5月1日

在Ubuntu Server上安装RabbitMQ

实际安装RabbitMQ之前的快速说明:如果你在RabbitMQ中使用SSL,Ubuntu 14.04的Erlang软件包会出现问题,所以你需要安装比Ubuntu软件包维护者提供的版本更新的版本,所以请使用https:/中的二进制文件/www.erlang-solutions.com/resources/download.html ,适用于Erlang 17.0或更高版本。

将RabbitMQ添加到包存储库列表:

echo 'deb http://www.rabbitmq.com/debian/ testing main' |
    sudo tee /etc/apt/sources.list.d/rabbitmq.list
 

然后添加签名密钥:

wget -O- https://www.rabbitmq.com/rabbitmq-release-signing-key.asc |
    sudo apt-key add -
 

然后更新并安装:

sudo apt-get update && sudo apt-get install rabbitmq-server
 

RabbitMQ'Hello World'

此代码创建一个生产者,它将两个消息发送到一个队列,一个消费者接收来自该队列的所有消息。

producer.py的代码(使用pika 0.10.0 Python客户端):

import pika

connection = pika.BlockingConnection(pika.ConnectionParameters(
        host='localhost'))
channel = connection.channel()

channel.queue_declare(queue='queueName')

channel.basic_publish(exchange='',
                      routing_key='queueName',
                      body='Hello')
channel.basic_publish(exchange='',
                      routing_key='queueName',
                      body='World!')
print("Message sent")
connection.close()
 

consumer.py的代码:

import pika

connection = pika.BlockingConnection(pika.ConnectionParameters(
        host='localhost'))
channel = connection.channel()

channel.queue_declare(queue='queueName')

def callback(ch, method, properties, body):
    print("Received message: %r" % body)

channel.basic_consume(callback,
                      queue='queueName',
                      no_ack=True)

print('Waiting for messages...')
channel.start_consuming()
 

输出是:

$ python receive.py
Waiting for messages...
Received message: 'Hello'
Received message: 'World!'
 

其他语言的RabbitMQ教程页面中提供了其他示例。