RabbitMQ系列（一）rabbitmq简介

------------恢复内容开始------------

参考：http://www.javashuo.com/article/p-qngymthe-hk.html

 

RabbitMQ简介

在介绍RabbitMQ以前实现要介绍一下MQ，MQ是什么？

　　MQ全称是Message Queue，能够理解为消息队列的意思，简单来讲就是消息以管道的方式进行传递。

　　RabbitMQ是一个实现了AMQP（Advanced Message Queuing Protocol）高级消息队列协议的消息队列服务，用Erlang语言的。

使用场景

　　在咱们秒杀抢购商品的时候，系统会提醒咱们稍等排队中，而不是像几年前同样页面卡死或报错给用户。

　　像这种排队结算就用到了消息队列机制，放入通道里面一个一个结算处理，而不是某个时间断忽然涌入大批量的查询新增把数据库给搞宕机，因此RabbitMQ本质上起到的做用就是削峰填谷，为业务保驾护航。

为何选择RabbitMQ

如今的市面上有不少MQ能够选择，好比ActiveMQ、ZeroMQ、Appche Qpid，那问题来了为何要选择RabbitMQ？

1. 除了Qpid，RabbitMQ是惟一一个实现了AMQP标准的消息服务器；
2. 可靠性，RabbitMQ的持久化支持，保证了消息的稳定性；
3. 高并发，RabbitMQ使用了Erlang开发语言，Erlang是为电话交换机开发的语言，天生自带高并发光环，和高可用特性；
4. 集群部署简单，正是应为Erlang使得RabbitMQ集群部署变的超级简单；
5. 社区活跃度高，根据网上资料来看，RabbitMQ也是首选；

工做机制

生产者、消费者和代理

在了解消息通信以前首先要了解3个概念：生产者、消费者和代理。

　　生产者：消息的建立者，负责建立和推送数据到消息服务器；

　　消费者：消息的接收方，用于处理数据和确认消息；

　　代理：就是RabbitMQ自己，用于扮演“快递”的角色，自己不生产消息，只是扮演“快递”的角色。

消息发送原理

　　首先你必须链接到RabbitMQ才能发布和消费消息，那怎么链接和发送消息的呢？

　　你的应用程序和Rabbit Server之间会建立一个TCP链接，一旦TCP打开，并经过了认证，认证就是你试图链接Rabbit以前发送的Rabbit服务器链接信息和用户名和密码，有点像程序链接数据库，使用Java有两种链接认证的方式，后面代码会详细介绍，一旦认证经过你的应用程序和Rabbit就建立了一条AMQP信道（Channel）。

　　信道是建立在“真实”TCP上的虚拟链接，AMQP命令都是经过信道发送出去的，每一个信道都会有一个惟一的ID，不管是发布消息，订阅队列或者介绍消息都是经过信道完成的。

为何不经过TCP直接发送命令？

　　1. TCP的建立和销毁，开销大，建立须要三次握手，销毁须要四次分手。

　　2. 若是不使用信道，那么引用程序就会使用TCP的方式链接到rabbitmq，高峰时每秒成千上万条链接会形成资源的巨大浪费(一条tcp消耗资源，成千上万的tcp会很是消耗资源)，并且操做系统每秒处理TCP链接数量也是有限的，一定会形成性能瓶颈。

　　3.信道的原理是一条线程一条信道，多条线程多条信道共同使用一条TCP链接。一条TCP链接能够容纳无限的信道，及时每秒形成成千上万的请求也不会形成性能瓶颈。

 

          

你必须知道的Rabbit

想要真正的了解Rabbit有些名词是你必须知道的。

包括：ConnectionFactory（链接管理器）、Channel（信道）、Exchange（交换器）、Queue（队列）、RoutingKey（路由键）、BindingKey（绑定键）。

　　ConnectionFactory（链接管理器）：应用程序与Rabbit之间创建链接的管理器，程序代码中使用；

　　Channel（信道）：消息推送使用的通道；

　　Exchange（交换器）：用于接受、分配消息；

　　Queue（队列）：用于存储生产者的消息；

　　RoutingKey（路由键）：用于把生成者的数据分配到交换器上；

　　BindingKey（绑定键）：用于把交换器的消息绑定到队列上；

看到上面的解释，最难理解的路由键和绑定键了，那么他们具体怎么发挥做用的，请看下图：

 

 

   

 

消息持久化

Rabbit队列和交换器有一个不可告人的秘密，就是默认状况下重启服务器会致使消息丢失，那么怎么保证Rabbit在重启的时候不丢失呢？答案就是消息持久化。

当你把消息发送到Rabbit服务器的时候，你须要选择你是否要进行持久化，但这并不能保证Rabbit能从崩溃中恢复，想要Rabbit消息能恢复必须知足3个条件：

1. 投递消息的时候durable设置为true，消息持久化，代码：channel.queueDeclare(x, true, false, false, null)，参数2设置为true持久化；
2. 设置投递模式deliveryMode设置为2（持久），代码：channel.basicPublish(x, x, MessageProperties.PERSISTENT_TEXT_PLAIN,x)，参数3设置为存储纯文本到磁盘；
3. 消息已经到达持久化交换器上；
4. 消息已经到达持久化的队列；

持久化工做原理

　　Rabbit会将你的持久化消息写入磁盘上的持久化日志文件，等消息被消费以后，Rabbit会把这条消息标识为等待垃圾回收。

持久化的缺点

　　消息持久化的优势显而易见，但缺点也很明显，那就是性能，由于要写入硬盘要比写入内存性能较低不少，从而下降了服务器的吞吐量，尽管使用SSD硬盘可使事情获得缓解，但他仍然吸干了Rabbit的性能，当消息成千上万条要写入磁盘的时候，性能是很低的。

因此使用者要根据本身的状况，选择适合本身的方式。

虚拟主机

　　每一个Rabbit都能建立不少vhost，咱们称之为虚拟主机，每一个虚拟主机其实都是mini版的RabbitMQ，拥有本身的队列，交换器和绑定，拥有本身的权限机制。

vhost特性

1. RabbitMQ默认的vhost是“/”开箱即用；

2. 多个vhost是隔离的，多个vhost没法通信，而且不用担忧命名冲突（队列和交换器和绑定），实现了多层分离；

3. 建立用户的时候必须指定vhost；

vhost操做（具体命令见下一章内容）

　　能够经过rabbitmqctl工具命令建立：

rabbitmqctl add_vhost[vhost_name]

删除vhost：

rabbitmqctl delete_vhost[vhost_name]

查看全部的vhost：

rabbitmqctl list_vhosts