RabbitMQ是最广泛部署的开源消息队列。是轻量级的应用，支持分布式和联合配置以满足高扩展、高可用性的需求。

一、特性

异步消息：支持多种消息协议、消息队列、发送确认、弹性路由、多种交换类型。

开发者经验：可与BOSH, Chef, Docker and Puppet进行部署，支持多种开发语言Java, .NET, PHP, Python, JavaScript, Ruby, Go等。

分布式部署：集群部署高可用性及吞吐量，联合（federate）部署可跨区域。

支持企业及云：插件式的身份认证及授权，支持TlS和LDAP

工具及插件：多种工具及插件支持持续整合、操作矩阵和与其他企业应用进行整合。

管理和监控：提供HTTP-api、命令行工具及界面来管理和监控Rabbitmq

二、下载及安装

• 以windows7为例子：

1.RabbitMq是基于Erlang平台，需先安装Erlang。下载64位版http://www.erlang.org/downloads。以管理员身份进行安装

2.下载windows版本：http://www.rabbitmq.com/download.html。
3.进行安装，安装完后rabbitmq已经启动，使用默认的配置以windows服务的形式启动。
命令行工具在Rabbitmq安装目录的Sbin中，有rabbitmqctl：管理消息队列，
如重启节点：rabbitmqctl reset，
查看状态：rabbitmqctl status等；
rabbitmq-plugins：管理消息队列插件；
rabbitmq-server：启动mq服务；
rabbitmq-service：管理windows的rabbitmq服务；
rabbitmq-echopid：返会windows中rabbitmq的进程id

安装完后，进入cmd窗口运行：rabbitmqctl status验证是否安装成功。

image

• 可能出现的问题：please check the Erlang Cookie的问题

解决方法：将cookie从c:/windows/.erlang.cookie复制到c:/user/royal/.erlang.cookie(synchronise Erlang cookies (when running a manually service))。

安装插件：rabbitmq_plugins enable rabbitmq_management，启用管理插件，可通过http://127.0.0.1:15672访问。默认用户、密码guest/guest。

三、开始新手入门

rabbitmq支持多种协议，本次将使用AMQP 0-9-1协议，依赖lib文件(SLF4J APIandSLF4J Simple)，也可使用Logback

术语：

1、producer 消息发送者

2、queue rabbitmq中的邮箱

3、consumer 消息接受者

4、exchange：消息交换器（邮局）（有定义好的交换类型fanout、direction、topic、headers）

5、binding：绑定，将交换器和队列相关联

6、connection 网络链接

7、channel：信道，

8、broker：中间人。表示消息队列服务器实体

image

work queue：避免了立即执行完资源紧张任务和必须等待完成的任务。Round-robin分发，循环轮流发送，可并行执行任务。

• 消息确认，默认是开启的，消费者发送确认给mq，mq收到后可删除已确认的消息。

• 消息持久化，当queue crash时，将队列里的消息持久化到磁盘，需设置queue和message都为持久化。

• 公平分发，使用basic.qos方法设置prefetch_count=1。新消息不会分发给正在处理消息，未确认的节点。

• 发布/订阅：发送一条消息给多个接收者，exchange使用fanout模式，将消息广播给全部队列

• 临时队列：非持久、独占、自动删除、自动生成的队列

• exchange：direct模式，消息中的路由键（routing key）和binding key一致，交换器将消息发送到对应队列。完全匹配，单播模式

• exchange：topic模式，交换器通过模式匹配分发消息的路由键属性。通配符：#代表0个或多个键；*代表一个关键字。

RabbitMq集群部署

单机集群部署遇到问题，节点启动后无法重启，加入集群