RabbitMQ（一）简介
1 简介
-
大多应用中，可通过消息服务中间件来提升系统异步通信、扩展解耦能力
-
消息中间件有两个重要概念：
-
消息代理
-
目的地
消息发送者发送消息之后，将由消息代理接管，消息代理保证消息传递到指定目的地
-
-
消息队列有两种形式的目的地
队列（queue）：点对点消息通信，消息发送者发送消息给消息队列后，消息代理将其放入一个队列中，消息接受者从消息中获取消息内容，消息读取之后被移除队列；消息只有唯一的发送者和接受者，但可以有多个接收者主题（topic）：发布（publish）、订阅（subscribe）消息通信。发送者（发布者）发送消息到主题，多个接收者（订阅者）监听（订阅）这个主题，那么就会在消息到达的同时收到消息
-
JMS（Java Message Service）Java消息服务
- JMS是基于JVM消息代理的规范，
ActiveMQ、HornetMQ是JMS的实现
- JMS是基于JVM消息代理的规范，
-
AMQP（Advanced Message Queuing Protocol）高级消息队列协议
- 高级消息队列协议也是一个消息代理的规范，兼容JMS
RabbitMQ是AMQP的实现
-
应用场景：
-
异步处理
-
应用解耦
-
流量控制
-
2 RabbitMQ概念
-
RabbitMQ是一个由erlang开发的AMQP的开源实现
-
核心概念包括：
-
消息Message：消息是不具名的，它由消息头和消息体组成，消息体是不透明的；而消息头则由一系列的可选属性组成，这些属性包括：routing-key路由键、priority（相对于其他消息的优先权）、delivery-mode（该消息是否需要持久性存储） -
消息生产者Publisher：向交换机发布消息的客户端应用程序 -
交换机Exchange：用来接收生产者发送的消息并将这些消息路由给服务器中的队列。交换机共有四种类型：direct、fanout、topic、headers，不同类型的Exchange转发的策略有所不同 -
队列Queue：消息队列，用来保存消息直到发送给消费者，是消息的容器，也是消息的终点，一个消息可以投入一个或者多个队列。消息一直存在队列里面，等待消费者连接到这个队列将其取走 -
绑定Binding：用于关联消息队列和交换机，一个绑定就是基于路由键将交换机和消息队列连接起来的规则交换机和队列的绑定可以是多对多的关系
-
连接Connection：比如一个TCP连接 -
信道Channel：多路复用连接的一条双向数据流通道，信道是建立在TCP连接中的虚拟连接，AMQP命令都是通过信道发出去的，不管是发布消息、订阅消息还是接收消息，都是通过信道完成的。因为对于操作系统来说建立和摧毁TCP连接都是非常昂贵的操作，所以引入了通道的概念，复用一条TCP连接
-
消费者Consumer：消息的消费者，表示一个从消息队列中获取消息的客户端应用程序 -
虚拟主机Visual Host：表示一批交换器、消息队列和相关对象，是具有相同身份认证和加密环境的独立服务器域，每个vhost本质上就是一个mini版的RabbitMQ服务器，拥有自己独立的交换器、消息队列、绑定和权限机制，vhost是AMQP概念的基础，必须在连接的时候指定对应的虚拟主机，RabbitMQ的默认vhost是/虚拟主机之间的配置互相隔离不受影响
-
Broker：表示消息队列服务器实体
-
-
工作流程：
生产者和消费者想要收发消息必须和RabbitMQ建立一条连接，所有的数据都在连接中开辟信道进行收发，收发的数据被封装成消息，消息头包含对消息的参数、设置以及命令，消息体为收发的真正内容，消息到达消息队列后先到执行的虚拟主机中，由该虚拟主机指定的交换机根据消息头中的路由键，并根据交换机和消息队列之间的绑定关系将消息发送给消息队列；消费者同时会监听消息队列的内容，发生变化便会实时拿到
建立长连接的好处就在于，当消费者宕机后，消息队列就会将消息存储起来，不造成大面积的消息丢失
3 RabbitMQ的安装
下载并启动容器
docker run -d --name rabbitmq -p 5671:5671 -p 5672:5672 -p 4369:4369 -p 25672:25672 -p 15671:15671 -p 15672:15672 rabbitmq:management