MQ消息重复消费
1 分钟阅读
•
185 字
+
42 词
在消费者这边做消息去重
:在消费者端对接收到的消息进行去重操作,可以通过**维护一个消息ID(这个消息ID是一个全局唯一的)的集合(去重表)或者使用唯一标识(查数据库)**来判断是否已经消费过该消息。
如果已经消费过,则不进行处理,避免重复消费。
消息确认机制
:RabbitMQ提供了消息确认机制,可以确保消息被正确地消费。
消费者在消费完消息之后,可以手动向RabbitMQ发送确认消息,告知RabbitMQ该消息已经成功消费,RabbitMQ会将该消息标记为已确认,然后删除消息队列中的该消息。