消息中间件之RabbitMQ消息传递模式及交换机类型

小灰灰 2022-11-18 13:45 240阅读 0赞

# RabbitMQ核心组成部分 #

## RabbitMQ组件图 ##

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L0V4Y2VwdGlvbl9zaXI_size_16_color_FFFFFF_t_70]  
**说明：**

> server: 又称broker，接收客户端的连接，实现AMQP实体服务，安装RabbitMQ服务器。  
> connection: 连接，客户端与broker服务的基于TCP/IP协议的三次握手和四次挥手。  
> channel：网络信道，几乎所有的操作都在信道中完成，主要负责消息的读写，客户端可以建立多个信道，每个channel代表一个会话  
> message: 消息，服务与应用程序之间传送的数据，主要由properties和Body组成，Properties主要是用于修饰消息的，比如消息的优先级、延迟等高级特性，Body则是消息体。  
> VirtureHost: 虚拟地址，用于逻辑隔离，最上层的消息路由，一个交换机可以包含若干个exchange和queue，同一个虚拟主机里面不能有相同的exchange和queue，相当于磁盘分区，主要用于做多个业务之间的隔离区分，防止杂乱无章。  
> exchange：交换机，接收消息，根据一定的routing key将消息发送到绑定的队列中去，不负责存储消息，若没有对应的路由key，则直接发送到的队列中,说白了就是负责接收、发送消息给交换机。  
> Bindings：exchange和queue之间的虚拟绑定，bindings中可以包含多个路由key  
> Routing key：路由key，是一个路由规则，虚拟机可以通过路由绑定一个特定的消息。  
> queue：队列，保存消息并将它们发送给消费者。

## RabbitMQ支持的消息模式 ##

参考官网：[https://www.rabbitmq.com/getstarted.html][https_www.rabbitmq.com_getstarted.html]

### 1.简单模式simple ###

![在这里插入图片描述][20210419100022363.png]  
简单模式组成主要：  
P: 生产者  
queue：队列  
C： 消费者

### 2.工作模式 ###

![在这里插入图片描述][20210419145138420.png]  
其主要和简单模式一样，都是使用默认的交换机，交换机类型路由规则为Direct。

> 轮询模式(Round-Robin)
> 
> > 特点：一个消费者消费一条，按均分配，该模式接收消息时，当有多个消费者接收消息时，是对称均等消费，不会因为服务器或者网络问题少消费，多个消费者之间是对等的。不会造成数据倾斜。

> 公平分发
> 
> > 特点：根据消费者的消费能力进行公平分发，处理快的处理的多，处理慢的处理的少，按劳分配，可能会造成数据倾斜。

### 3.发布订阅模式 ###

![在这里插入图片描述][20210419145432997.png]  
这是一种发布订阅模式，交换机类型为fanout（广播模式）  
组成部分：  
生产者、交换机、队列、多个消费者

### 4.路由模式 ###

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L0V4Y2VwdGlvbl9zaXI_size_16_color_FFFFFF_t_70 1]  
路由模式：就是在发布订阅模式基础上加了一些过滤条件，所以根据对应的过滤机制将对应的消息发送给对应的消费者消费。  
特点：

1.  交换机类型必须为direct，若为广播模式fanout模式，那么luyou就没有过滤的意义。
2.  一个交换机可以绑定多个路由key，一个路由key可以绑定多个队列。

### 5.主题Topic模式 ###

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L0V4Y2VwdGlvbl9zaXI_size_16_color_FFFFFF_t_70 2]  
基于3、4模式的基础衍生出主题模式，类似于模糊匹配一般，使用通配符进行模糊匹配路由规则：  
**.\#** :代表有0个或者多个多级的模糊，例如com.\# 的路由key可以匹配com或者com.xxx.xxx.xxx…这类的，即以com开头的所有绑定队列，\#可有可无

**.**\* :代表只有一级匹配，例如com.\* ,可以匹配com.xxx ，但是至少要匹配一条。

特点：

1.  交换机类型必须为topic模式
2.  模糊匹配

### 6.RPC拉取模式 ###

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L0V4Y2VwdGlvbl9zaXI_size_16_color_FFFFFF_t_70 3]

### 7.发布确认机制 ###

略

## RabbitMQ使用场景 ##

1.  解耦、削峰，异步  
    ![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L0V4Y2VwdGlvbl9zaXI_size_16_color_FFFFFF_t_70 4]
2.  流量削峰
3.  分布式事物的可靠消费和生产
4.  索引缓存、静态化处理数据同步
5.  流量监控
6.  日志监控
7.  下单、订单分发、抢票

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L0V4Y2VwdGlvbl9zaXI_size_16_color_FFFFFF_t_70]: /images/20221022/1bd107c06bd54b3f84da7580a4d4519e.png
[https_www.rabbitmq.com_getstarted.html]: https://www.rabbitmq.com/getstarted.html
[20210419100022363.png]: /images/20221022/0c47f6a34a38417eb3f2ac8d4f5b3a8a.png
[20210419145138420.png]: /images/20221022/6d5cfe2bd04840d68d371713fa054694.png
[20210419145432997.png]: /images/20221022/47a9482f857a4f0ebc672f22d4100590.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L0V4Y2VwdGlvbl9zaXI_size_16_color_FFFFFF_t_70 1]: /images/20221022/57a81d8c67b74054bf6630877a5f5f37.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L0V4Y2VwdGlvbl9zaXI_size_16_color_FFFFFF_t_70 2]: /images/20221022/3d425d046ea241c6a6306848b4aace8e.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L0V4Y2VwdGlvbl9zaXI_size_16_color_FFFFFF_t_70 3]: /images/20221022/aa4bc2f3ec1443919fa5993f19771eaa.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L0V4Y2VwdGlvbl9zaXI_size_16_color_FFFFFF_t_70 4]: /images/20221022/2d94cf8a60d648eb9683fc1693da5b9e.png