RabbitMQ的一些理解和笔记

秒速五厘米 2024-02-19 18:45 22阅读 0赞

在这篇博客中，简单记录一下 rabbitmq 服务器中一些基本的概念。

**Connection:**connection 为 TCP连接，是我们的应用程序和RabbitMQ服务器真正发送和接收数据的地方。

**Channel:** channel为connection创建的**“信道”**，具体的AMQP命令都是通过信道发送出去的。每一条信道都有一个唯一的id,channel是线程不安全的。

**bindingKey和routingKey的区分：**

**bindingkey:** 在使用绑定的时候，需要用到的路由键是 bindingkey。涉及到的客户端方法： channel.exchangeBind 和 channel.queueBind等

**routingkey**: 在发送消息的时候，需要用到的路由键是 routingkey。涉及到的客户端方法： channel.basicPublish

**exchange：交换器，存在四种类型**

1.  **fanout：**fanout类型的Exchange路由规则非常简单，它会把所有发送到该Exchage的消息路由到所有与它绑定的Queue中。  
    ![format_png][]  
    
2.  **direct：**direct类型的Exchange路由规则也是非常简单，它会把消息路由到哪些 binding key 与 routing key 完全匹配的Queue中。  
    ![format_png 1][]  
    **每个队列在新建时，默认会绑定到 默认交换器（名字为空字符串），绑定的路由键名称和路由键名称一致。**
3.  **topic：** 根据 routingKey 和 bindingKey 进行匹配。**bindingKey** ![format_png 2][]  
    
4.  **headers：**此种交换器不常用，它是使用headers来匹配的，不依赖routingKey和bindingKey**中****可以存在两种****特殊字符****“****\*”** **与** **“****\#”** ，用于做模糊匹配，其中 **“\*”** 用于匹配一个单词，**“\#”**用于匹配多个参数（可以是零个）。**注意：****“\*” 以 . 作为分隔符 、 “\#” 以任何字符作为匹配关键字的部分。**

**vhost:虚拟主机**

每一个 vhost 本质上就是一个 mini 版的 RabbitMQ 服务器，它拥有自己的队列、交换器、绑定等，同时它也有自己的权限控制。它提供了逻辑上的隔离，保证了数据的安全性。

**Connection和Channel有什么关系？**

我们知道操作系统创建和销毁一条tcp连接是非常消耗性能的，如果系统高峰期时，大量的创建和销毁TCP连接，这会造成大量的性能损耗，并且系统很有可能达到瓶颈，如果我们所有的线程都使用一条TCP连接，并且保证每个线程的私密性，那么就可以大大提高系统的性能，因此 Channel 就应运而生了。

**即：**我们可以简单的理解，channel 就是一个虚拟的 connection,channel是通过connection创建得来的，channel是线程不安全的。

**设置消息的过期时间：**

**1、设置队列中消息的过期时间**

通过队列设置的过期时间，那么队列中的每条消息的过期时间都是一致的。

在**channel.queueDeclare** 时，设置**x-message-ttl** 参数，这个参数的单位是**毫秒**

\*\* 不进行设置，表示此消息永不过期

\*\* 设置为0表示，除非此时可以将消息投递给消费者，否则该消息会被立即丢弃

**2、为单条消息设置过期时间**

在**channel.basicPublish** 方法中加入**expiretion** 的属性参数，单位是**毫秒**

**注意：**

**1、如果同时设置了队列的过期时间和消息的过期时间，那么以过期时间小的为准**

**2、对于第一种方法设置的过期时间，在消息过期时就会从队列中进行移除，对于第二种方法，即使消息过期也不会马上从队列中移除，因为每条消息的过期时间是在即将投递给消费者之前进行判断的。**

**消费者消费消息时与rabbitmq断开连接：**

如果消费者就收到一条消息，然后确认之前与RabbitMQ断开连接或从队列上取消订阅，RabbitMQ会认为这条消息没有进行分发，会重新分发给下一个消费者进行处理。

**消费者忘记确认消息时RabbitMQ服务器的处理：**

如果应用程序有bug导致没有确认消息，那么RabbitMQ将不会给该消费者发送更多的消息了。这是因为RabbitMQ服务器认为该消费者没有准备好接受下一条消息。

**如果消息要想从RabbitMQ崩溃中恢复，必须满足一下几点：**

1.  将消息的投递模式**(delivery mode)**设置成 2（**持久**）
2.  发送到持久化的交换器中
3.  到达持久化的队列中

**生产者如果知道消息到达了RabbitMQ服务器上**

1、使用事务模式。（**不推荐，严重影响性能**）

2、使用 confirm 一步确认。（**推荐**）

**向多个节点中广播消息**

假设我们一个 web 服务，同时部署在了节点A,B,C上，如果此时向队列中发送一条消息，需要这3个节点都可以收到。

我们可以使用**fanout**类型的交换机，**队列的名字**在程序启动时**动态改变**，这样就可以实现了。

[format_png]: https://image.dandelioncloud.cn/pgy_files/images/2024/01/29/59d226c00ff9421f9dfe8b19462656f0.png
[format_png 1]: https://image.dandelioncloud.cn/pgy_files/images/2024/01/29/563588e2a549495fa776b7934e7e958c.png
[format_png 2]: https://image.dandelioncloud.cn/pgy_files/images/2024/01/29/c3d37113e1674ba99528e01c2f260a17.png