消息入库，对消息状态进行打标记
image.png
1.业务操作入库，然后生成消息保存到数据库，状态为0
2.发送端将消息发送到MQ
3.MQ返回一个应答(发送端有一个监听程序)
4.将指定消息更新状态为1
5.定时取出状态为0的消息
6.调用发送端重新发送消息
7.限制重试次数，大于3次，将消息状态设置为2既重试失败
消息延迟投递，进行二次确认，回调检查
第一种方式不适合在高并发场景下
image.png
1.业务入库，然后发送消息到MQ
2.发送延迟检查消息
3.消费端监听指定消息并消费
4.消费端处理完消息，返回一条消息进行响应
5.Callback Service监听消费端的响应，收到后将消息持久化到数据库
6.Callback Service同时监听延迟检查消息。收到延迟检查消息后将数据库中对应的消息进行状态变更
7.Callback Service定时检查数据库中状态没有变更的消息。之后发送ReSend Command给发送端。
消息的可靠性投递 消息入库，对消息状态进行打标记image.png1.业务操作入库，然后生成消息保存到数据库，状态...
1、消息可靠性投递分析 由RabbitMQ消息发送的过程，我们可以知道如果要保证消息的可靠性投递，必须要下保证如下...
如何确保rabbitMQ消息的可靠性 要确保rabbitMQ消息的可靠性要做到三点： publisher conf...
提到消息队列，相信大家都不陌生，本文主要在于抛砖引玉，简要介绍一下消息队列的几个问题 1.可靠性 消息队列的可靠性...
可靠性投递 关于消息的可靠性投递，从以下几个方面来着手： 保障消息成功发出； 保障MQ成功接收； 发送方接收到MQ...
数据可靠性 Producer往Broker发送消息 为了让用户设置数据可靠性，kafka在Producer里面体用...
数据可靠性 Kafka 作为一个商业级消息中间件，消息可靠性的重要性可想而知。本文从 Producter 往 Br...
数据可靠性 Kafka 作为一个商业级消息中间件，消息可靠性的重要性可想而知。本文从 Producter 往 Br...
1. 数据可靠性 Kafka作为一个商业级消息中间件，消息可靠性的重要性可想而知。本文从Producter 往Br...
在 Kafka 工作机制 一文提及了 Kafka 消息的不可靠性。本文就 Kafka 消息的三种不可靠性（重复、丢...
本文标题：消息可靠性
本文链接：https://www.haomeiwen.com/subject/fymdcctx.html
网友评论