RabbitMQ 简介

RabbitMQ 简介

首先我们先看一下常见的MQ产品

在上图我们可以知道RabbitMQ和ActiveMQ都支持AMQP协议，那么什么时AMQP呢？

AMQP，即 Advanced Message Queuing Protocol（高级消息队列协议），是一个网络协议，是应用层协议
的一个开放标准，为面向消息的中间件设计。基于此协议的客户端与消息中间件可传递消息，并不受客户端/中
间件不同产品，不同的开发语言等条件的限制。2006年，AMQP 规范发布。类比HT

在AMQP中规定了如下的几个角色：

执行流程：由Publisher（生产者）发布消息到Exchange(交换机)，交换机通过路由到队列（Queue)中存储，Consumer(消费者)从对应的消息进行消费；

RabbitMQ出现：

2007年，Rabbit 技术公司基于 AMQP 标准开发的 RabbitMQ 1.0 发布。RabbitMQ 采用 Erlang 语言开发。
Erlang 语言由 Ericson 设计，专门为开发高并发和分布式系统的一种语言，在电信领域使用广泛。

RabbitMQ 中的相关概念：

⚫ Broker：接收和分发消息的应用，RabbitMQ Server就是 Message Broker
⚫ Virtual host：出于多租户和安全因素设计的，把 AMQP 的基本组件划分到一个虚拟的分组中，类似于网
络中的 namespace 概念。当多个不同的用户使用同一个 RabbitMQ server 提供的服务时，可以划分出多
个vhost，每个用户在自己的 vhost 创建 exchange／queue 等
⚫ Connection：publisher／consumer 和 broker 之间的 TCP 连接
⚫ Channel：如果每一次访问 RabbitMQ 都建立一个 Connection，在消息量大的时候建立 TCP Connection
的开销将是巨大的，效率也较低。Channel 是在 connection 内部建立的逻辑连接，如果应用程序支持多线
程，通常每个thread创建单独的 channel 进行通讯，AMQP method 包含了channel id 帮助客户端和
message broker 识别 channel，所以 channel 之间是完全隔离的。Channel 作为轻量级的 Connection
极大减少了操作系统建立 TCP connection 的开销

⚫ Exchange：message 到达 broker 的第一站，根据分发规则，匹配查询表中的 routing key，分发消息到
queue 中去。常用的类型有：direct (point-to-point), topic (publish-subscribe) and fanout (multicast)
⚫ Queue：消息最终被送到这里等待 consumer 取走
⚫ Binding：exchange 和 queue 之间的虚拟连接，binding 中可以包含 routing key。Binding 信息被保存
到 exchange 中的查询表中，用于 message 的分发依据

RabbitMQ的工作模式：

RabbitMQ 提供了 6 种工作模式：简单模式、work queues、Publish/Subscribe 发布与订阅模式、Routing
路由模式、Topics 主题模式、RPC 远程调用模式

JMS

⚫JMS 即 Java 消息服务（JavaMessage Service）应用程序接口，是一个 Java 平台中关于面向消息中间件
的API
⚫JMS 是 JavaEE 规范中的一种，类比JDBC
⚫很多消息中间件都实现了JMS规范，例如：ActiveMQ。RabbitMQ 官方没有提供 JMS 的实现包，但是开
源社区有