2021年RabbitMQ面试题全解析：延时处理与持久化策略

本文档是一份针对2021年RabbitMQ技术面试题的汇总，包含了两个主要讨论点：消息队列的延时与过期失效处理，以及在消息积压和队列满时的应对策略。 首先，关于消息队列的延时和过期失效问题，面试者可能会询问如何确保消息的可靠持久化。RabbitMQ中的消息持久化是指消息即使在服务器断电或重启后也能被正确存储并传递。要实现可靠持久化，消息需要同时存储在磁盘（确保数据持久）和确认机制（确保消息被消费者接收）。对于消息队列满了的情况，面试者可能期待解答以下几点： 1. 当消息积压严重时，首先应修复消费者端的问题，提高消费速度，然后暂时停止原有消费者，创建一个新的topic队列，并扩展到原来的10倍容量。接着编写一个临时的程序，将积压数据快速均匀地分配到这些临时队列中，同时启动额外的机器来处理。 2. 消费过程中，由于RabbitMQ的TTL（Time To Live）特性，积压的消息超过设定时间会被自动删除。为避免数据丢失，面试者应了解如何在高峰期过后通过批量重导的方式找回丢失的数据，这可能涉及程序性操作，如查找丢失消息并重新注入队列。 3. 如果队列接近满载，快速消费积压消息是关键，即使这意味着部分消息可能被丢弃。这通常作为临时应急措施，直到晚上或者低峰时段再进行数据补救。 第二个讨论点是关于保证message被可靠持久化的条件，面试者可能问及queue（队列）和exchange（交换机）的角色。queue和exchange是RabbitMQ的核心组件： - queue负责存储消息，当消息到达exchange后，根据exchange的规则路由到不同的queue。 - exchange负责消息的路由，根据配置策略将消息发送到相应的queue。 - 要保证可靠持久化，queue需要设置为持久化的（persistent），并且exchange的持久化模式（persistent or durable）也需要设置得当。只有当exchange和至少一个持久化queue连接在一起时，消息才能在服务器重启后仍能到达queue。 总结，面试者可能关注RabbitMQ的运维实践，包括如何处理高负载下的消息处理问题、数据丢失恢复策略，以及理解queue和exchange在可靠消息传递中的角色。这份文档提供了实用的解决方案和理论背景，有助于求职者准备相关的技术面试。