RabbitMQ 提供了一些机制来避免消息重复投递或重复消费：
1. 消息确认机制：
- 当消费者从队列中获取到消息后，必须发送确认（ACK）给 RabbitMQ。
- RabbitMQ 在收到确认后，才将消息标记为已传递（delivered），并将消息从队列中删除。
- 通过使用消息确认机制，可以确保消费者成功处理消息后再将其删除，防止重复消费。
2. 消费者限流（Consumer Prefetch）：
- 可以使用消费者限流来控制消费者一次从队列中获取的消息数量。
- 通过限制每个消费者处理的消息数量，可以避免同时将大量消息发送给消费者，导致消息的重复消费。
3. 消息去重机制：
- 在某些场景下，可能需要根据消息内容来进行去重，以避免相同的消息被重复处理。
- 可以在消费者端维护一个去重的缓存或数据结构，记录已经处理过的消息的唯一标识，比如消息的 ID。
- 在处理新消息时，可以先查询去重缓存，判断消息是否已经被处理过，从而避免重复处理。
4. 幂等性处理：
- 对于一些幂等性操作，可以将消息处理逻辑设计成幂等的，即多次执行操作所产生的结果与单次执行是相同的。
- 这样即使消息被重复消费，也不会造成影响或结果异常。
- 通过在消息处理逻辑中实现幂等性，可以有效避免重复消费或重复操作产生的问题。
以上是一些常用的方法来避免消息重复投递或重复消费。根据不同的业务需求，可以选择适合的机制或策略来保证消息的唯一性和正确处理。
向大家推荐《Activiti工作流实战教程》:https://xiaozhuanlan.com/activiti