rabbitMQ的详细介绍

系统管理员 2023-10-02 18:49 10阅读 0赞

## 1.概述 ##

RabbitMQ是一个消息中间件:它接受并转发消息。你可以把它当做一个快递站点，当你要发送一个包裹时，你把你的包裹放到快递站，快递员最终会把你的快递送到收件人那里，按照这种逻辑RabbitMQ是一个快递站，一个快递员帮你传递快件。RabbitMQ与快递站的主要区别在于，它不处理快件而是接收，存储和转发消息数据。

## 2.下载 ##

rabbitMQ下载详情可见  
[如何下载安装RabbitMQ\_雨会停rain的博客-CSDN博客如何下载安装RabbitMQ![favicon32.ico][]https://blog.csdn.net/wang20010104/article/details/123986230][RabbitMQ_rain_-CSDN_RabbitMQ_favicon32.ico_https_blog.csdn.net_wang20010104_article_details_123986230]

## 3.工作原理 ##

![watermark_type_d3F5LXplbmhlaQ_shadow_50_text_Q1NETiBA6Zuo5Lya5YGccmFpbg_size_20_color_FFFFFF_t_70_g_se_x_16][]

## 4.名词介绍 ##

**Broker**:接收和分发消息的应用，RabbitMQ Server就是Message Broker

**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)

**Routing Key:**生产者将消息发送到交换机时会携带一个key,来指定路由规则

**binding Key**:在绑定Exchange和Queue时，会指定一个BindingKey,生产者发送消息携带的RoutingKey会和bindingKey对比，若一致就将消息分发至这个队列

**vHost 虚拟主机**：每一个RabbitMQ服务器可以开设多个虚拟主机每一个vhost本质上是一个mini版的RabbitMQ服务器，拥有自己的 "交换机exchange、绑定Binding、队列Queue"，更重要的是每一个vhost拥有独立的权限机制，这样就能安全地使用一个RabbitMQ服务器来服务多个应用程序，其中每个vhost服务一个应用程序。

## 5.交换机类型 ##

1.direct Exchange(直接交换机)

匹配路由键，只有完全匹配消息才会被转发

2.Fanout Excange（扇出交换机）

将消息发送至所有的队列

3.Topic Exchange(主题交换机)

将路由按模式匹配，此时队列需要绑定要一个模式上。符号“\#”匹配一个或多个词，符号“匹配不多不少一个词。因此“abc.\#”能够匹配到“abc.def.ghi”，但是“abc.” 只会匹配到“abc.def”。

4.Header Exchange

在绑定Exchange和Queue的时候指定一组键值对，header为键，根据请求消息中携带的header进行路由

## 6.工作模式 ##

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

![watermark_type_d3F5LXplbmhlaQ_shadow_50_text_Q1NETiBA6Zuo5Lya5YGccmFpbg_size_12_color_FFFFFF_t_70_g_se_x_16][]

一个消费者消费一个生产者生产的信息

#### 2[.Work queues][](工作模式) ####

![watermark_type_d3F5LXplbmhlaQ_shadow_50_text_Q1NETiBA6Zuo5Lya5YGccmFpbg_size_13_color_FFFFFF_t_70_g_se_x_16][]

一个生产者生产信息，多个消费者进行消费，但是一条消息只能消费一次

#### 3.[Publish/Subscribe][Publish_Subscribe]（发布订阅模式） ####

![watermark_type_d3F5LXplbmhlaQ_shadow_50_text_Q1NETiBA6Zuo5Lya5YGccmFpbg_size_13_color_FFFFFF_t_70_g_se_x_16 1][]

生产者首先投递消息到交换机，订阅了这个交换机的队列就会收到生产者投递的消息

#### 4.[Routing][]（路由模式） ####

![watermark_type_d3F5LXplbmhlaQ_shadow_50_text_Q1NETiBA6Zuo5Lya5YGccmFpbg_size_16_color_FFFFFF_t_70_g_se_x_16][]

生产者生产消息投递到direct交换机中，扇出交换机会根据消息携带的routing Key匹配相应的队列

#### 5.[Topics][]（主题模式） ####

![watermark_type_d3F5LXplbmhlaQ_shadow_50_text_Q1NETiBA6Zuo5Lya5YGccmFpbg_size_18_color_FFFFFF_t_70_g_se_x_16][]

生产者生产消息投递到topic交换机中，上面是完全匹配路由键，而主题模式是模糊匹配，只要有合适规则的路由就会投递给消费者

## 7.保证消息的稳定性 ##

#### 1.消息持久化 ####

RabbitMQ的消息默认存在内存中的，一旦服务器意外挂掉，消息就会丢失

消息持久化需做到三点

*  Exchange设置持久化
 *  Queue设置持久化
 *  Message持久化发送：发送消息设置发送模式deliveryMode=2，代表持久化消息

#### 2.ACK确认机制 ####

多个消费者同时收取消息，收取消息到一半，突然某个消费者挂掉，要保证此条消息不丢失，就需要acknowledgement机制，就是消费者消费完要通知服务端，服务端才将数据删除

这样就解决了，及时一个消费者出了问题，没有同步消息给服务端，还有其他的消费端去消费，保证了消息不丢的case。

#### 3.设置集群镜像模式 ####

我们先来介绍下RabbitMQ三种部署模式：

1）单节点模式：最简单的情况，非集群模式，节点挂了，消息就不能用了。业务可能瘫痪，只能等待。

2）普通模式：默认的集群模式，某个节点挂了，该节点上的消息不能用，有影响的业务瘫痪，只能等待节点恢复重启可用（必须持久化消息情况下）。

3）镜像模式：把需要的队列做成镜像队列，存在于多个节点，属于RabbitMQ的HA方案

为什么设置镜像模式集群，因为队列的内容仅仅存在某一个节点上面，不会存在所有节点上面，所有节点仅仅存放消息结构和元数据。下面自己画了一张图介绍普通集群丢失消息情况

#### 4.消息补偿机制 ####

持久化的消息，保存到硬盘过程中，当前队列节点挂了，存储节点硬盘又坏了，消息丢了，怎么办？

产线网络环境太复杂，所以不知数太多，消息补偿机制需要建立在消息要写入DB日志，发送日志，接受日志，两者的状态必须记录。

然后根据DB日志记录check 消息发送消费是否成功，不成功，进行消息补偿措施，重新发送消息处理。

## 8.如何实现延迟队列 ##

RabbitMQ本身没有延迟队列，需要靠TTL和DLX模拟出延迟的效果

#### TTL（Time To Live） ####

RabbitMQ可以针对Queue和Message设置 x-message-tt，来控制消息的生存时间，如果超时，则消息变为dead letter

RabbitMQ针对队列中的消息过期时间有两种方法可以设置。

A: 通过队列属性设置，队列中所有消息都有相同的过期时间。

B: 对消息进行单独设置，每条消息TTL可以不同。

如果同时使用，则消息的过期时间以两者之间TTL较小的那个数值为准。消息在队列的生存时间一旦超过设置的TTL值，就成为dead letter

#### DLX (Dead-Letter-Exchange) ####

RabbitMQ的Queue可以配置x-dead-letter-exchange 和x-dead-letter-routing-key（可选）两个参数，如果队列内出现了dead letter，则按照这两个参数重新路由。

x-dead-letter-exchange：出现dead letter之后将dead letter重新发送到指定exchange

x-dead-letter-routing-key：指定routing-key发送

队列出现dead letter的情况有：

消息或者队列的TTL过期

队列达到最大长度

消息被消费端拒绝（basic.reject or basic.nack）并且requeue=false

利用DLX，当消息在一个队列中变成死信后，它能被重新publish到另一个Exchange。这时候消息就可以重新被消费。

[favicon32.ico]: https://g.csdnimg.cn/static/logo/favicon32.ico
[RabbitMQ_rain_-CSDN_RabbitMQ_favicon32.ico_https_blog.csdn.net_wang20010104_article_details_123986230]: https://blog.csdn.net/wang20010104/article/details/123986230
[watermark_type_d3F5LXplbmhlaQ_shadow_50_text_Q1NETiBA6Zuo5Lya5YGccmFpbg_size_20_color_FFFFFF_t_70_g_se_x_16]: https://img-blog.csdnimg.cn/343e622b91334ec398d054e111142e68.png?x-oss-process=image/watermark,type_d3F5LXplbmhlaQ,shadow_50,text_Q1NETiBA6Zuo5Lya5YGccmFpbg==,size_20,color_FFFFFF,t_70,g_se,x_16
[watermark_type_d3F5LXplbmhlaQ_shadow_50_text_Q1NETiBA6Zuo5Lya5YGccmFpbg_size_12_color_FFFFFF_t_70_g_se_x_16]: https://img-blog.csdnimg.cn/4073e0bba8934e7d95123fe2f1d75406.png?x-oss-process=image/watermark,type_d3F5LXplbmhlaQ,shadow_50,text_Q1NETiBA6Zuo5Lya5YGccmFpbg==,size_12,color_FFFFFF,t_70,g_se,x_16
[.Work queues]: https://rabbitmq.com/tutorials/tutorial-two-python.html
[watermark_type_d3F5LXplbmhlaQ_shadow_50_text_Q1NETiBA6Zuo5Lya5YGccmFpbg_size_13_color_FFFFFF_t_70_g_se_x_16]: https://img-blog.csdnimg.cn/398d942aeb7748fca9fcc523331b3858.png?x-oss-process=image/watermark,type_d3F5LXplbmhlaQ,shadow_50,text_Q1NETiBA6Zuo5Lya5YGccmFpbg==,size_13,color_FFFFFF,t_70,g_se,x_16
[Publish_Subscribe]: https://rabbitmq.com/tutorials/tutorial-three-python.html
[watermark_type_d3F5LXplbmhlaQ_shadow_50_text_Q1NETiBA6Zuo5Lya5YGccmFpbg_size_13_color_FFFFFF_t_70_g_se_x_16 1]: https://img-blog.csdnimg.cn/0c0a258d86984d5ea653838c93c56e8a.png?x-oss-process=image/watermark,type_d3F5LXplbmhlaQ,shadow_50,text_Q1NETiBA6Zuo5Lya5YGccmFpbg==,size_13,color_FFFFFF,t_70,g_se,x_16
[Routing]: https://rabbitmq.com/tutorials/tutorial-four-python.html
[watermark_type_d3F5LXplbmhlaQ_shadow_50_text_Q1NETiBA6Zuo5Lya5YGccmFpbg_size_16_color_FFFFFF_t_70_g_se_x_16]: https://img-blog.csdnimg.cn/e2e01fa6c02546ce93dd6fd2fdba8b06.png?x-oss-process=image/watermark,type_d3F5LXplbmhlaQ,shadow_50,text_Q1NETiBA6Zuo5Lya5YGccmFpbg==,size_16,color_FFFFFF,t_70,g_se,x_16
[Topics]: https://rabbitmq.com/tutorials/tutorial-five-python.html
[watermark_type_d3F5LXplbmhlaQ_shadow_50_text_Q1NETiBA6Zuo5Lya5YGccmFpbg_size_18_color_FFFFFF_t_70_g_se_x_16]: https://img-blog.csdnimg.cn/785bb9af6a58463990e941211c7abf27.png?x-oss-process=image/watermark,type_d3F5LXplbmhlaQ,shadow_50,text_Q1NETiBA6Zuo5Lya5YGccmFpbg==,size_18,color_FFFFFF,t_70,g_se,x_16