面试题：微服务架构中Spring Cloud RocketMQ消息驱动应用的高可用设计

多 Master 模式：采用多 Master 无 Slave 的部署方式，每个 Master 节点都可以读写消息，提高整体的吞吐量和可用性。在网络抖动或单个节点故障时，其他 Master 节点仍能正常提供服务。
Master - Slave 模式：如果对数据可靠性要求更高，可采用 Master - Slave 模式。Slave 节点实时从 Master 节点同步数据，当 Master 节点出现故障时，Slave 节点可切换为 Master 节点继续提供服务，保证服务的连续性。
负载均衡：使用负载均衡器（如 Nginx、HAProxy 等）将客户端请求均匀分配到各个 Master 节点，避免单个节点压力过大。同时，负载均衡器可以实时监测节点状态，当某个节点出现故障时，自动将请求转发到其他正常节点。

消息发送模式：
- 同步发送：可靠性高，适用于对消息发送结果要求较高的场景，如重要业务通知。生产者发送消息后，等待 Broker 返回确认响应，确保消息发送成功。
- 异步发送：提高发送性能，适用于对响应时间敏感但对消息可靠性要求稍低的场景。生产者发送消息后，无需等待 Broker 响应，通过回调函数处理发送结果。
- 单向发送：只负责发送消息，不等待任何响应，适用于对消息可靠性要求不高且追求极致性能的场景，如日志记录。
重试机制：配置合适的重试次数，当消息发送失败时，生产者自动重试。Spring Cloud RocketMQ 提供了 ProducerConfig 中的 retryTimesWhenSendFailed 参数来设置重试次数，默认是 2 次。可根据业务需求适当增加重试次数，以应对网络抖动等临时故障。
消息持久化：确保 Broker 对消息进行持久化存储，生产者发送消息时设置 Message 的 Property，如 DELAY_TIME_LEVEL 等，控制消息的存储和投递策略。

消费模式：
- 集群消费：多个消费者实例组成一个集群共同消费一组消息，每个消息只会被集群中的一个消费者实例消费，适用于高并发处理场景。
- 广播消费：每个消费者实例都会收到全量的消息，适用于需要所有消费者都处理相同消息的场景，如配置更新通知。
消息确认机制：采用手动确认模式，消费者在成功处理消息后，向 Broker 发送确认消息。Spring Cloud RocketMQ 提供了 @RocketMQMessageListener 注解中的 ackMode 参数来设置确认模式，AckMode.MANUAL 表示手动确认。这样可以避免在消费者处理消息过程中出现故障导致消息重复消费。
重试机制：当消费者消费消息失败时，Spring Cloud RocketMQ 会自动进行重试。可通过 ConsumerConfig 中的 maxReconsumeTimes 参数设置最大重试次数，默认是 16 次。对于重试多次仍失败的消息，可将其发送到死信队列，后续进行人工处理。

网络抖动：
- 生产者：通过重试机制，在网络恢复后重新发送消息。同时，合理设置发送超时时间，避免长时间等待导致资源浪费。
- 消费者：消费端设置合理的心跳机制，保持与 Broker 的连接。当网络抖动导致连接中断时，能够快速重连并继续消费消息。
节点故障：
- 生产者：负载均衡器会自动将请求转发到其他正常的 Master 节点，生产者无需感知节点故障，继续正常发送消息。
- 消费者：对于 Master - Slave 模式，当 Master 节点故障时，Slave 节点切换为 Master 节点，消费者通过负载均衡器自动连接到新的 Master 节点继续消费消息。同时，消费者的手动确认机制保证消息不会丢失和重复消费。

消息顺序性：在某些场景下，需要保证消息的顺序性，如订单处理流程。RocketMQ 通过分区（Queue）来保证消息的局部顺序性，即同一个 Queue 中的消息按照发送顺序依次消费。生产者可通过设置 MessageQueueSelector 来指定消息发送到特定的 Queue。
事务消息：对于一些需要保证分布式事务一致性的场景，RocketMQ 提供了事务消息机制。生产者发送半消息（Half Message），Broker 接收后返回确认响应，生产者执行本地事务，根据本地事务执行结果向 Broker 发送提交或回滚消息。Spring Cloud RocketMQ 对事务消息提供了支持，通过 RocketMQTemplate 发送事务消息，并实现 RocketMQLocalTransactionListener 接口来处理本地事务。

自动配置：Spring Cloud RocketMQ 提供了自动配置功能，通过简单的配置文件即可快速搭建生产者和消费者。例如，在 application.properties 中配置 RocketMQ 的地址、生产者和消费者的相关参数等。
注解支持：使用 @RocketMQMessageListener 注解来定义消费者监听的 Topic 和 Queue，以及设置消费模式、确认模式等参数，简化了消费者的开发。同时，@RocketMQTransactionListener 注解用于定义事务消息的本地事务处理逻辑。
集成 Spring Boot：与 Spring Boot 无缝集成，充分利用 Spring Boot 的特性，如依赖管理、配置管理等，提高开发效率。

星途面试题库