应用与数据集成平台 ROMA CONNECT-附录:如何提高消息处理效率:重视消息生产与消费的确认过程
重视消息生产与消费的确认过程
消息生产
生产消息后,生产者需要根据ROMA Connect的返回信息确认消息是否发送成功,如果返回失败需要重新发送。
每次生产消息,生产者都需要等待消息发送API的应答信号,以确认消息是否成功发送。在消息传递过程中,如果发生异常,生产者没有接收到发送成功的信号,生产者自己决策是否需要重复发送消息。如果接收到发送成功的信号,则表明该消息已经被ROMA Connect可靠存储。
消息消费
消息消费时,消费者需要确认消息是否已被成功消费。
生产的消息被依次存储在ROMA Connect的存储介质中。消费时依次获取ROMA Connect中存储的消息。消费者获取消息后,进行消费并记录消费成功或失败的状态,并将消费状态提交到ROMA Connect,由ROMA Connect决定消费下一批消息或回滚重新消费消息。
在消费过程中,如果出现异常,没有提交消费确认,该批消息会在后续的消费请求中再次被获取。
- 怎么群发消息_短信如何发消息_短信息发送
- 短信怎么发短信_手机消息延迟_如何用短信发消息
- 怎么群发消息_发送短信_短信如何群发消息给很多人
- RabbitMQ如何保证消息的可靠性_分布式消息系统_分布式消息RabbitMQ-华为云
- 消息队列_数据交换问题_处理异步任务-华为云
- 分布式消息服务Kafka版与分布式消息服务RocketMQ版的区别_Kafka与RocketMQ对比_Kafka与RocketMQ差异
- 提高软件交付效率与质量方式_软件发布_制品仓库工具-华为云
- 华为云资料 2021年 7月刊
- 国内RPA厂商_RPA是什么系统_RPA金融
- 分布式消息中间件实战_分布式消息实战_分布式消息-华为云