GitHub - fencyio:为RabbitMQ消费者提供幂等性保证的库包

19-05-28 banq
                   

fency是一个使用SpringBoot和Redis消除RabbitMQ中重复消息的开源项目。

即使发送方应用程序仅发送一次消息,接收方应用程序也可能不止一次地接收消息。

幂等元一词在数学中用于描述一个函数,如果它应用于自身,则产生相同的结果:f(x)= f(f(x))。在消息处理中,这个概念转换为:一条消息无论是一次还是多次接收都会产生相同的效果。这意味着即使接收器接收到相同消息的重复,发送者也可以安全地重新发送消息而不会引起任何问题。

收件人可以通过跟踪已收到的消息来明确地删除消息。唯一的消息标识符ID可以简化此任务,并有助于检测具有相同消息内容的两个合法消息到达的情况。

为了基于消息标识符检测和消除重复消息,消息接收者必须保留已经接收的消息标识符的列表。

技术实施

为了存储已处理的消息元数据,我们必须处于事务上下文中。如果出现问题,则必须回滚事务。

  1. MessageInterceptor创建的MessageContext在一个ThreadLocal,并将其存储
  2. 所述IdempotencyBarrier是围绕一个方面@IdempotentConsumer注释。它检索MessageContext并检查消息是否已存在。唯一消息密钥由messageId和consumerQueueName组成。

如果消息不存在,则调用目标方法,并将消息元数据存储在数据存储中。

如果消息已存在,则会记录一条错误消息,并且不会调用目标方法。

使用@IdempotentConsumer为您的消费者添加注释。

请参阅示例应用程序:fency-spring-boot-sample-app

 

                   

1