fency是一个使用SpringBoot和Redis消除RabbitMQ中重复消息的开源项目。
即使发送方应用程序仅发送一次消息，接收方应用程序也可能不止一次地接收消息。
幂等元一词在数学中用于描述一个函数，如果它应用于自身，则产生相同的结果：f（x）= f（f（x））。在消息处理中，这个概念转换为：一条消息无论是一次还是多次接收都会产生相同的效果。这意味着即使接收器接收到相同消息的重复，发送者也可以安全地重新发送消息而不会引起任何问题。
收件人可以通过跟踪已收到的消息来明确地删除消息。唯一的消息标识符ID可以简化此任务，并有助于检测具有相同消息内容的两个合法消息到达的情况。
为了基于消息标识符检测和消除重复消息，消息接收者必须保留已经接收的消息标识符的列表。
技术实施
为了存储已处理的消息元数据，我们必须处于事务上下文中。如果出现问题，则必须回滚事务。
- MessageInterceptor创建的MessageContext在一个ThreadLocal，并将其存储
- 所述IdempotencyBarrier是围绕一个方面@IdempotentConsumer注释。它检索MessageContext并检查消息是否已存在。唯一消息密钥由messageId和consumerQueueName组成。
如果消息不存在，则调用目标方法，并将消息元数据存储在数据存储中。
如果消息已存在，则会记录一条错误消息，并且不会调用目标方法。
使用@IdempotentConsumer为您的消费者添加注释。
请参阅示例应用程序：fency-spring-boot-sample-app