EMQ（Erlang MQTT Broker）通过以下机制来保证消息不重复消费：
- MQTT 协议中的 QoS 等级：MQTT 协议定义了三种消息质量等级（Quality of Service，QoS），包括 QoS 0、QoS 1 和 QoS 2。其中，QoS 1 和 QoS 2 提供了消息传递的可靠性保证。
- QoS 0（最多一次）：消息被发送后，不做任何确认或重传处理，可能会导致消息丢失或重复消费。
- QoS 1（至少一次）：消息发送者会收到一个 PUBACK 确认消息，如果没有收到确认，则会进行重传，确保消息至少被消费一次。消费者收到重复消息时，可以通过去重处理避免重复消费。
- QoS 2（恰好一次）：消息发送者会收到一个 PUBREC 确认消息，并在收到 PUBREC 后再发送一个 PUBREL 消息，最后收到 PUBCOMP 确认消息。通过这一系列的确认消息，确保消息仅被消费一次。
- 消费者端的消息去重：在应用程序的消费者端，可以使用去重的机制来避免重复消费。比如，可以维护一个已消费消息的记录表，每次接收到消息时，先检查记录表，如果消息已经存在，则视为重复消息而不进行处理。
- 消费者组：EMQ 支持消费者组的概念，多个消费者可以组成一个消费者组，并共同订阅相同的主题。在消费者组中，每个消费者会接收到主题的不同分区的消息。通过合理设置分区和消费者组的关系，可以保证消息的负载均衡和避免重复消费。
需要注意的是，EMQ 本身并不提供幂等性保证，即确保相同的消息被处理一次。因此，在处理重复消息时，需要在应用程序的消费逻辑中保证幂等性，即多次处理相同消息结果应该是一致的，不会出现副作用。这可以通过设计消息的唯一标识符或利用业务逻辑来实现。
综上所述，EMQ 通过 MQTT 协议的 QoS 等级和消费者端的去重机制以及消费者组的设置来保证消息不重复消费。但是，对于消息的幂等性保证，需要根据具体的应用场景和业务需求在消费端进行合理设计。
