rabbitmq简介

绝地灬酷狼 2022-05-10 11:26 274阅读 0赞

[开发十年，就只剩下这套Java开发体系了 >>> ][Java_ _]  ![hot3.png][]

# 1、**AMQP** #

**    **AMQP协议是一个高级抽象层消息通信协议，RabbitMQ是AMQP协议的实现。它主要包括以下组件：

## 1.1 Server(broker) ##

接受客户端连接，实现AMQP消息队列和路由功能的进程。

## 1.2 Virtual Host ##

其实是一个虚拟概念，类似于权限控制组，一个Virtual Host里面可以有若干个Exchange和Queue，但是权限控制的最小粒度是Virtual Host。

## 1.3 Exchange ##

接受生产者发送的消息，并根据Binding规则将消息路由给服务器中的队列。ExchangeType决定了Exchange路由消息的行为，例如，在RabbitMQ中，ExchangeType有direct、Fanout和Topic三种，不同类型的Exchange路由的行为是不一样的。

### 1.3.1 direct ###

如果 routing key 匹配, 那么Message就会被传递到相应的queue中。其实在queue创建时，它会自动的以queue的名字作为routing key来绑定那个exchange。

### 1.3.2 fanout ###

会向响应的queue广播。

### 1.3.3 topic ###

对key进行模式匹配，比如ab\*可以传递到所有ab\*的queue。

## 1.4 Message Queue ##

消息队列，用于存储还未被消费者消费的消息。

## 1.5 Message ##

由Header和Body组成，Header是由生产者添加的各种属性的集合，包括Message是否被持久化、由哪个Message Queue接受、优先级是多少等。而Body是真正需要传输的APP数据。

## 1.6 Binding ##

Binding联系了Exchange与Message Queue。Exchange在与多个Message Queue发生Binding后会生成一张路由表，路由表中存储着Message Queue所需消息的限制条件即Binding Key。当Exchange收到Message时会解析其Header得到Routing Key，Exchange根据Routing Key与Exchange Type将Message路由到Message Queue。Binding Key由Consumer在Binding Exchange与Message Queue时指定，而Routing Key由Producer发送Message时指定，两者的匹配方式由Exchange Type决定。

## 1.7 Connection ##

连接，对于RabbitMQ而言，其实就是一个位于客户端和Broker之间的TCP连接。

## 1.8 Channel ##

信道，仅仅创建了客户端到Broker之间的连接后，客户端还是不能发送消息的。需要为每一个Connection创建Channel，AMQP协议规定只有通过Channel才能执行AMQP的命令。一个Connection可以包含多个Channel。之所以需要Channel，是因为TCP连接的建立和释放都是十分昂贵的，如果一个客户端每一个线程都需要与Broker交互，如果每一个线程都建立一个TCP连接，暂且不考虑TCP连接是否浪费，就算操作系统也无法承受每秒建立如此多的TCP连接。RabbitMQ建议客户端线程之间不要共用Channel，至少要保证共用Channel的线程发送消息必须是串行的，但是建议尽量共用Connection。

为什么使用Channel，而不是直接使用Connection（TCP连接）？

对于OS来说，建立和关闭TCP连接是有代价的，频繁的建立关闭TCP连接对于系统的性能有很大的影响，而且TCP的连接数也有限制，这也限制了系统处理高并发的能力。但是，在TCP连接中建立Channel是没有上述代价的。对于Producer或者Consumer来说，可以并发的使用多个Channel进行Publish或者Receive。

## 1.9 Command ##

AMQP的命令，客户端通过Command完成与AMQP服务器的交互来实现自身的逻辑。例如在RabbitMQ中，客户端可以通过publish命令发送消息，txSelect开启一个事务，txCommit提交一个事务。

# 2、系统架构 #

*   生产者将message发送到exchange。
 *  exchange接受message之后，负责将其路由到具体的队列中。
 *  Bindings负责连接exchange和队列(queue)。
 *  message到达队列(queue)，然后等待被message接收端处理。
 *  消费者处理message。

# 3、广播模式 #

## 3.1 fanout ##

所有bind到此exchange的queue都可以接收消息（纯广播，绑定到RabbitMQ的接受者都能收到消息）。

## 3.2 direct ##

通过routingKey和exchange决定的那个唯一的queue可以接收消息。

## 3.3 topic ##

所有符合routingKey(此时可以是一个表达式)的routingKey所bind的queue可以接收消息。

[Java_ _]: https://my.oschina.net/u/3779583/blog/1862418
[hot3.png]: /images/20220510/d1ba5649a34b435a9aec76ecfd1769d5.png