应用与数据集成平台 ROMA Connect-附录:如何提高消息处理效率:消息生产与消费的幂等传递

时间:2023-11-01 16:16:24

消息生产与消费的幂等传递

ROMA Connect设计了一系列可靠性保障措施,确保消息不丢失。例如使用消息同步存储机制防止系统与服务器层面的异常重启或者掉电,使用消息确认(ACK)机制解决消息传输过程中遇到的异常。

考虑到网络异常等极端情况,用户除了做好消息生产与消费的确认,还需要配合ROMA Connect完成消息发送与消费的重复传输设计。

  • 当无法确认消息是否已发送成功,生产者需要将消息重复发送给ROMA Connect。
  • 当重复收到已处理过的消息,消费者需要告诉ROMA Connect消费成功且保证不重复处理。
support.huaweicloud.com/devg-roma/roma_04_3018.html