RocketMQ 如何保证消息不丢失，如何保证消息不被重复消费？

RocketMQ 通过消息确认机制和消费者组管理机制来保证消息不丢失和不被重复消费。

1. 消息确认机制：RocketMQ 通过消息确认机制来保证消息不丢失。当消息发送到 Broker 后，Broker 会向生产者发送 ACK 确认消息已经成功接收。如果 Broker 没有收到 ACK 确认，就会向生产者发送 NACK 消息，让生产者进行重试。当消息被成功消费后，消费者会向 Broker 发送 ACK 消息，告诉 Broker 消息已经被成功消费。如果 Broker 在一定时间内没有收到 ACK 消息，就会认为该消息未被正常消费，将会重新发送该消息。

2. 消费者组管理机制：RocketMQ 通过消费者组管理机制来保证消息不被重复消费。RocketMQ 允许多个消费者以同一个消费者组的身份订阅同一个主题。在这种情况下，每个消息只会被消费者组中的一个消费者消费，从而避免了消息被重复消费的问题。同时，如果某个消费者出现故障，RocketMQ 会自动将该消费者的消息分配给其他消费者来消费，确保消息能够被及时处理。

综上所述，RocketMQ 通过消息确认机制和消费者组管理机制，保证了消息不丢失和不被重复消费。