应用与数据集成平台 ROMA Connect-附录:如何提高消息处理效率:重视消息生产与消费的确认过程

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

重视消息生产与消费的确认过程

消息生产

生产消息后,生产者需要根据ROMA Connect的返回信息确认消息是否发送成功,如果返回失败需要重新发送。

每次生产消息,生产者都需要等待消息发送API的应答信号,以确认消息是否成功发送。在消息传递过程中,如果发生异常,生产者没有接收到发送成功的信号,生产者自己决策是否需要重复发送消息。如果接收到发送成功的信号,则表明该消息已经被ROMA Connect可靠存储。

消息消费

消息消费时,消费者需要确认消息是否已被成功消费。

生产的消息被依次存储在ROMA Connect的存储介质中。消费时依次获取ROMA Connect中存储的消息。消费者获取消息后,进行消费并记录消费成功或失败的状态,并将消费状态提交到ROMA Connect,由ROMA Connect决定消费下一批消息或回滚重新消费消息。

在消费过程中,如果出现异常,没有提交消费确认,该批消息会在后续的消费请求中再次被获取。

support.huaweicloud.com/devg-roma/roma_04_3018.html