rabbitmq简介

简介

RabbitMQ的官方站：http://www.rabbitmq.com/

rabbitMQ是一个在AMQP协议标准基础上完整的，可服用的企业消息系统。他遵循Mozilla Public License开源协议。采用 Erlang 实现的工业级的消息队列(MQ)服务器。
       AMQP(高级消息队列协议) 是一个异步消息传递所使用的应用层协议规范，做为线路层协议，而不是API（例如JMS），AMQP 客户端可以无视消息的来源任意发送和接受信息。AMQP的原始用途只是为金融界提供一个能够彼此协做的消息协议，而如今的目标则是为通用消息队列架构提供通用构建工具。所以，面向消息的中间件 （MOM）系统，例如发布/订阅队列，没有做为基本元素实现。反而经过发送简化的AMQ实体，用户被赋予了构建例如这些实体的能力。这些实体也是规范的一 部分，造成了在线路层协议顶端的一个层级：AMQP模型。这个模型统一了消息模式，诸如以前提到的发布/订阅，队列，事务以及流数据，而且添加了额外的特性，例如更易于扩展，基于内容的路由。

AMQP当中有四个概念很是重要

1. virtual host，虚拟主机
2. exchange，交换机
3. queue，队列
4. binding，绑定

一个虚拟主机持有一组交换机、队列和绑定。

为何须要多个虚拟主机呢？由于RabbitMQ当中，用户只能在虚拟主机的粒度进行权限控制。所以，若是须要禁止A组访问B组的交换机/队列/绑定，必须为A和B分别建立一个虚拟主机。每个RabbitMQ服务器都有一个默认的虚拟主机/。

队列（Queues）是你的消息（messages）的终点，能够理解成装消息的容器。消息就一直在里面，直到有客户端（也就是消费者，Consumer）链接到这个队列而且将其取走为止。不过，也能够将一个队列配置成这样的：一旦消息进入这个队列，此消息就被删除。

队列是由消费者（Consumer）经过程序创建的，不是经过配置文件或者命令行工具。这没什么问题，若是一个消费者试图建立一个已经存在的队列，RabbitMQ会直接忽略这个请求。所以咱们能够将消息队列的配置写在应用程序的代码里面。

而要把一个消息放进队列前，须要有一个交换机（Exchange）。

交换机（Exchange）能够理解成具备路由表的路由程序。每一个消息都有一个称为路由键（routing key）的属性，就是一个简单的字符串。交换机当中有一系列的绑定（binding），即路由规则（routes）。（例如，指明具备路由键 “X” 的消息要到名为timbuku的队列当中去。）

消费者程序（Consumer）要负责建立你的交换机。交换机能够存在多个，每一个交换机在本身独立的进程当中执行，所以增长多个交换机就是增长多个进程，能够充分利用服务器上的CPU核以便达到更高的效率。例如，在一个8核的服务器上，能够建立5个交换机来用5个核，另外3个核留下来作消息处理。相似的，在RabbitMQ的集群当中，你能够用相似的思路来扩展交换机一边获取更高的吞吐量。

交换机如何判断要把消息送到哪一个队列？你须要路由规则，即绑定（binding）。一个绑定就是一个相似这样的规则：将交换机“desert（沙漠）”当中具备路由键“阿里巴巴”的消息送到队列“hideout（山洞）”里面去。换句话说，一个绑定就是一个基于路由键将交换机和队列链接起来的路由规则。例如，具备路由键“audit”的消息须要被送到两个队列，“log-forever”和“alert-the-big-dude”。要作到这个，就须要建立两个绑定，每一个都链接一个交换机和一个队列，二者都是由“audit”路由键触发。在这种状况下，交换机会复制一份消息而且把它们分别发送到两个队列当中。交换机不过就是一个由绑定构成的路由表。

交换机有多种类型。他们都是作路由的，可是它们接受不一样类型的绑定。为何不建立一种交换机来处理全部类型的路由规则呢？由于每种规则用来作匹配分子的CPU开销是不一样的。例如，一个“topic”类型的交换机试图将消息的路由键与相似“dogs.*”的模式进行匹配。匹配这种末端的通配符比直接将路由键与“dogs”比较（“direct”类型的交换机）要消耗更多的CPU。若是你不须要“topic”类型的交换机带来的灵活性，你能够经过使用“direct”类型的交换机获取更高的处理效率。那么有哪些类型，他们又是怎么处理的呢？

　　Exchange

1. Exchange Direct

   Exchange Fanout

   Exchange Topic

---

持久化

你花了大量的时间来建立队列、交换机和绑定，而后，服务器程序挂了。你的队列、交换机和绑定怎么样了？还有，放在队列里面可是还没有处理的消息们呢？

若是你是用默认参数构造的这一切的话，那么，他们都灰飞烟灭了。RabbitMQ重启以后会干净的像个新生儿。你必须重作全部的一切，亡羊补牢，如何避免未来再度发生此类杯具？

队列和交换机有一个建立时候指定的标志durable。durable的惟一含义就是具备这个标志的队列和交换机会在重启以后从新创建，它不表示说在队列当中的消息会在重启后恢复。那么如何才能作到不仅是队列和交换机，还有消息都是持久的呢？

可是首先须要考虑的问题是：是否真的须要消息的持久化？若是须要重启后消息能够回复，那么它须要被写入磁盘。但即便是最简单的磁盘操做也是要消耗时间的。因此须要衡量判断。

当你将消息发布到交换机的时候，能够指定一个标志“Delivery Mode”（投递模式）。根据你使用的AMQP的库不一样，指定这个标志的方法可能不太同样。简单的说，就是将Delivery Mode设置成2，也就是持久的（persistent）便可。通常的AMQP库都是将Delivery Mode设置成1，也就是非持久的。因此要持久化消息的步骤以下：

1. 将交换机设成 durable。
2. 将队列设成 durable。
3. 将消息的 Delivery Mode 设置成2 。

绑定（Bindings）怎么办？绑定没法在建立的时候设置成durable。没问题，若是你绑定了一个durable的队列和一个durable的交换机，RabbitMQ会自动保留这个绑定。相似的，若是删除了某个队列或交换机（不管是否是durable），依赖它的绑定都会自动删除。

注意：

• RabbitMQ 不容许你绑定一个非坚固（non-durable）的交换机和一个durable的队列。反之亦然。要想成功必须队列和交换机都是durable的。
• 一旦建立了队列和交换机，就不能修改其标志了。例如，若是建立了一个non-durable的队列，而后想把它改变成durable的，惟一的办法就是删除这个队列而后重现建立。所以，最好仔细检查建立的标志。