面试题：消息队列RocketMQ在高并发场景下如何保障消息可靠性投递

工作原理：
- 同步刷盘：生产者发送消息到Broker后，Broker会将消息写入到磁盘的CommitLog文件中，只有当写入磁盘操作完成并返回成功响应后，才会向生产者返回成功。这种方式保证了消息不会因为Broker宕机而丢失，因为消息已经持久化到磁盘。
- 异步刷盘：生产者发送消息到Broker后，Broker会将消息先写入内存的PageCache中，然后由后台线程异步地将PageCache中的数据刷入磁盘。这种方式提高了消息写入的性能，但存在一定风险，如果在消息刷入磁盘前Broker宕机，内存中的消息可能会丢失。
配置方式：在broker.conf配置文件中，通过flushDiskType参数来配置刷盘策略，ASYNC_FLUSH表示异步刷盘，SYNC_FLUSH表示同步刷盘。例如：flushDiskType = SYNC_FLUSH。

工作原理：
- RocketMQ采用Master - Slave模式实现HA。一个Master可以对应多个Slave，Master负责处理读写请求，Slave从Master同步数据。
- 数据同步方式有两种：同步复制和异步复制。
  - 同步复制：Master在向生产者返回成功响应前，会等待所有Slave将消息同步完成。这种方式保证了数据的强一致性和高可靠性，但会降低系统的写入性能，因为需要等待所有Slave的响应。
  - 异步复制：Master在向生产者返回成功响应后，会异步地将消息同步给Slave。这种方式提高了写入性能，但如果Master宕机，可能会有少量未同步到Slave的消息丢失。
配置方式：
- 在broker.conf配置文件中，通过brokerRole参数配置Broker角色，ASYNC_MASTER表示异步复制的Master，SYNC_MASTER表示同步复制的Master，SLAVE表示Slave。例如：brokerRole = ASYNC_MASTER。
- 同时，还需要配置namesrvAddr参数指定NameServer地址，以及brokerId参数，Master的brokerId为0，Slave的brokerId为大于0的整数。

工作原理：
- RocketMQ的存储采用CommitLog + ConsumeQueue的结构。CommitLog是所有消息的物理存储文件，ConsumeQueue是消息消费队列的逻辑存储文件，记录了消息在CommitLog中的物理偏移量等信息。
- 当消息堆积时，RocketMQ可以通过增加Consumer的消费能力来处理堆积消息。Consumer可以采用多线程消费模式，提高消费速度。同时，RocketMQ支持按照消息的Topic、Queue等维度进行并行消费，进一步提升消费效率。
- Broker端也会对堆积消息进行管理，例如根据配置的存储大小限制等，当达到一定阈值时可能会采取相应措施（如限制新消息写入等）。
配置方式：
- 在Consumer端，可以通过setConsumeThreadMin和setConsumeThreadMax来设置消费线程的最小和最大数量，调整消费能力。例如：

DefaultMQPushConsumer consumer = new DefaultMQPushConsumer("ConsumerGroup");
consumer.setConsumeThreadMin(10);
consumer.setConsumeThreadMax(20);

在Broker端，通过maxPhysicalPosInLogicQueue等参数可以控制单个ConsumeQueue最大的物理偏移量，间接控制消息堆积情况，配置在broker.conf文件中。

工作原理：
- RocketMQ的客户端和服务端都有重试机制。当发生网络抖动导致请求失败时，客户端（生产者或消费者）会根据配置的重试次数进行重试。
- 同时，RocketMQ的心跳机制可以检测网络连接状态。Broker和NameServer之间、Broker和Producer/Consumer之间都会定期发送心跳包，以保持连接的有效性。如果检测到连接异常，会进行相应的处理，如重新建立连接等。
配置方式：
- 在生产者端，通过setRetryTimesWhenSendFailed参数设置发送消息失败时的重试次数。例如：

DefaultMQProducer producer = new DefaultMQProducer("ProducerGroup");
producer.setRetryTimesWhenSendFailed(3);

DefaultMQPushConsumer consumer = new DefaultMQPushConsumer("ConsumerGroup");
consumer.setMaxReconsumeTimes(5);

心跳机制的相关配置一般在客户端和服务端的默认配置中已经设置好，通常不需要额外配置，但在一些特殊场景下，可能需要调整心跳间隔等参数，可通过修改相关的配置文件（如broker.conf等）来实现。

星途面试题库