rabbitmq系列（一）初识rabbitmq

客官°小女子只卖身不卖艺 2021-09-18 05:08 401阅读 0赞

## 为什么要使用消息中间件 ##

案例：假如我们开发了一个商品抢购网站。这个网站的目的就是在某一时间点进行抢购商品，同时要求用户注册，在注册的时候会同时给用户电话和邮箱中发送验证码，以便完成信息注册。传统做法应该是这样的。两种方式，并行即启用两个线程，当用户提交信息后，分别去发送邮件和发送短信。这种方式很明显比串行的方式更快。当我们加入消息队列后，处理方式如下图：

![串行并行.jpg][.jpg]

加入消息中间件后，我们只需要注册信息存库后，给消息队列中添加一条消息就完事了。然后邮件服务和短信服务分别去消费消息即可。

![消息队列.png][.png]

当用户注册完成后，到了抢购商品的时间，大家都去抢购某个商品的时候这个量很大。消息队列可以设置队列长度来保证系统的稳定性。当队列满了的时候，则不再处理这些用户请求。

因此我们可以总结一下消息队列的特点：

1.  异步处理 -- 用户注册信息提交后，直接返回响应。然后邮件服务和短信服务监听到队列有消息后去主动处理
2.  应用解耦 -- 用户注册流程分成了三个服务，注册服务、邮件服务、短信服务互不干扰。
3.  流量削峰 -- 控制用户请求，以防系统奔溃。

## 常见消息中间件介绍 ##

**ActiveMQ**：apache出品，能力强劲的开源消息总线，完全支持jms规范的消息中间件。api丰富，在传统行业的中小型企业中应用广泛。缺点：服务性能和数据存储性能不好。

**Kafka**：apache顶级项目，追求高吞吐量。一开始的目的是用于日志收集和传输。不支持事务，对消息重复，丢失，错误没有严格的请求。适合产生大量数据的互联网服务的数据收集业务。

**RocketMQ**：阿里开源中间件，目前已孵化成apache顶级项目，纯java开发，思路起源于kafka，对消息的可靠性传输和事务性做了优化。特点：高吞吐量、高可用。适合大规模分布式系统应用。目前在阿里集团被广泛使用，用于交易、充值，流计算，日志处理，消息推送等。现在推出了商业版，有些功能对外不开发。

**RabbitMQ**：是一个开源的消息代理和队列服务器，用来通过普通协议在完全不同的应用之间共享数据，RabbitMQ是使用ErLang语言来编写的，并且基于AMQP协议。erlang语言开发，性能较好，高并发。社区活跃度高，网上资料比较多。

## 什么是AMQP协议 ##

AMQP（Advanced Message Queuing Protocol，高级消息队列协议）是一个进程间传递**异步消息**的**网络协议**。

涉及到的具体概念：

*  server - 又称broker，接收客户端的链接，实现amqp实体服务。
 *  Connection - 链接，应用程序跟broker的网络链接。
 *  channel - 网络信道，几乎所有的操作都是在channel中进行，数据的流转都要在channel上进行。channel是进行消息读写的通道。客户端可以建立多个channel，每个channel代表一个会话任务。
 *  message - 消息，服务器与应用程序之间传送的数据。由properties和body组成。properties可以对消息进行修饰，比如消息的升级，延迟等高级特性。body就是消息体的内容。
 *  virtual host - 虚拟主机，用于进行逻辑隔离，最上层的消息路由，一个虚拟地址里面可以有多个交换机。exchange和消息队列message quene。
 *  exchange - 交换机，接收消息，根据路由器转发消息到绑定的队列。
 *  binding - 绑定，交换机和队列之间的虚拟链接，绑定中可以包含routing key。
 *  routing key - 一个路由规则，虚拟机可以用它来确定如何路由一个特定消息。
 *  quene - 消息队列，保存消息并将它们转发给消费者。

详细了解AMQP协议可参考这篇文章--------[详解AMQP协议][AMQP]

## 交换机简单介绍 ##

exchange：接收消息，并根据路由键转发消息所绑定的队列。

交换机的属性：

name：交换机的名称

type：交换机的类型direct，topic，fanout，headers

durability：是否需要持久化，true为持久化。

auto delete：当最后一个绑定到exchange上的队列删除后，自动删除该exchange。

internal：当前exchange是否用于rabbitMQ内部使用，默认为false。

arguments：可扩展参数。用户自自定义的交换机时，用到的参数。

交换机常用的类型为direct，topic，fanout。headers不常用。

**direct（直连交换机）:**

1.  所有发送到directExchange的消息被转发到RouteKey中指定的Queue
2.  rabbitmq有一个自带的exchange叫default exchange，这个交换机是direct类型的。rabbitmq会让路由键跟队列名相等进行绑定。

**topic（主题交换机）:**

1.  所有发送到topic exchange的消息被转发到所有关心RouteKey的Queue上
2.  Exchange将RouteKey和某些队列进行模糊匹配，此时队列需要绑定一个Topic

模糊匹配可以使用通配符：

\#可以匹配一个或多个词

\*只能匹配一个词

比如："log.\#"可以匹配到“log.info.oa”。“log.\*”只会匹配到“log.error”

**Fanout（扇型交换机）：**

1.  不处理路由键，只需要简单的将队列绑定到交换机上。
2.  发送到交换机的消息都会被转发到与该交换机绑定的所有队列上
3.  fanout交换机转发消息是最快的。

> 如果文章对您有帮助，请记得点赞关注哟~
> 
> 欢迎大家关注我的公众号：字节传说，每日推送技术文章供大家学习参考。

[.jpg]: /images/20210918/2a22a491f039424dbdbf5d0c0677a3c1.png
[.png]: /images/20210918/f8ec7d1bfe4d4d368636ffa5dac4dea4.png
[AMQP]: https://blog.csdn.net/m0_37968982/article/details/103864888