内容简介：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消费者提供幂等性屏障。》，希望对大家有所帮助，如果大家有任何疑问请给我留言，小编会及时回复大家的。在此也非常感谢大家对 码农网 的支持！
猜你喜欢:
- 垃圾回收之写屏障
- CyclicBarrier - 同步屏障实现分析
- Java 并发编程（三）：MESI、内存屏障
- Java 并发编程（三）：MESI、内存屏障
- 刘睿民：数据库是保障数据安全的有力屏障
- Kafka消费者的偏移量和高级/简单消费者
本站部分资源来源于网络，本站转载出于传递更多信息之目的，版权归原作者或者来源机构所有，如转载稿涉及版权问题，请联系我们。
