内容简介：fency是一个使用SpringBoot和Redis消除RabbitMQ中重复消息的开源项目。即使发送方应用程序仅发送一次消息，接收方应用程序也可能不止一次地接收消息。幂等元一词在数学中用于描述一个函数，如果它应用于自身，则产生相同的结果：f（x）= f（f（x））。在消息处理中，这个概念转换为：一条消息无论是一次还是多次接收都会产生相同的效果。这意味着即使接收器接收到相同消息的重复，发送者也可以安全地重新发送消息而不会引起任何问题。
fency是一个使用SpringBoot和 Redis 消除RabbitMQ中重复消息的开源项目。
即使发送方应用程序仅发送一次消息，接收方应用程序也可能不止一次地接收消息。
幂等元一词在数学中用于描述一个函数，如果它应用于自身，则产生相同的结果：f（x）= f（f（x））。在消息处理中，这个概念转换为：一条消息无论是一次还是多次接收都会产生相同的效果。这意味着即使接收器接收到相同消息的重复，发送者也可以安全地重新发送消息而不会引起任何问题。
收件人可以通过跟踪已收到的消息来明确地删除消息。唯一的消息标识符ID可以简化此任务，并有助于检测具有相同消息内容的两个合法消息到达的情况。
为了基于消息标识符检测和消除重复消息，消息接收者必须保留已经接收的消息标识符的列表。
技术实施
为了存储已处理的消息元数据，我们必须处于事务上下文中。如果出现问题，则必须回滚事务。
- MessageInterceptor创建的MessageContext在一个ThreadLocal，并将其存储
- 所述IdempotencyBarrier是围绕一个方面@IdempotentConsumer注释。它检索MessageContext并检查消息是否已存在。唯一消息密钥由messageId和consumerQueueName组成。
如果消息不存在，则调用目标方法，并将消息元数据存储在数据存储中。
如果消息已存在，则会记录一条错误消息，并且不会调用目标方法。
使用@IdempotentConsumer为您的消费者添加注释。
请参阅示例应用程序： fency-spring-boot-sample-app
以上所述就是小编给大家介绍的《GitHub - fencyio：为RabbitMQ消费者提供幂等性屏障。》，希望对大家有所帮助，如果大家有任何疑问请给我留言，小编会及时回复大家的。在此也非常感谢大家对 码农网 的支持！
本站部分资源来源于网络，本站转载出于传递更多信息之目的，版权归原作者或者来源机构所有，如转载稿涉及版权问题，请联系我们。
High Performance Python
Micha Gorelick、Ian Ozsvald / O'Reilly Media / 2014-9-10 / USD 39.99
If you're an experienced Python programmer, High Performance Python will guide you through the various routes of code optimization. You'll learn how to use smarter algorithms and leverage peripheral t......一起来看看 《High Performance Python》 这本书的介绍吧!
