MQ消息丢失问题

由于网络问题，我们很难保证生产者发送的消息能100%到达消息队列服务器，也就是说有消息丢失的可能性，因此，生产者就必须具有消息丢失检测和重发机制，也就是我们常说的消息队列的事务机制。不能把可靠性的保证全部交给TCP，TCP只保证了传输层的可靠传输，但是无法保证与应用层的交互是否出错TCP无法给应用层任何反馈，因此必须在应用层处理差错。

同步的事务一停止等待

所谓停止等待协议就是没发送完一组数据后，等待对方确认并且收到确认后，再发送下一组数据。

同步的事务一连续ARQ

类似于TCP的滑动窗口模型

异步的事务—回调机制

生产者在发送消息的时候，注册一个回调函数，这样生产者便不用停下来等待确认了，而是可以一直持续发送消息，当消息到达消息队列服务器的时候，服务器便会调用生产者注册的回调函数，告知生产者消息发送成功了还是失败了，进而做进一步的处理，从而提高了并发量。

本文小结

本文介绍了MQ防止消息丢失的几种解决方案。

MQ如何防止消息丢失相关推荐

active mq topic消费后删除_RabbitMQ重复消费，顺序消费，消息丢失如何解决
MQ的优势异步解耦削峰不同MQ的优缺点特性 RabbitMQ ActiveMQ RocketMQ Kafka 单机吞吐量万级万级十万级十万级 topic数量对吞吐量影响 topic达 ...
MQ 消息丢失、重复、积压问题，如何解决？
面试官在面试候选人时,如果发现候选人的简历中写了在项目中使用了 MQ 技术(如 Kafka.RabbitMQ.RocketMQ),基本都会抛出一个问题:在使用 MQ 的时候,怎么确保消息 100% 不 ...
Mq消息丢失解决方案
1.生产者存放消息的过程中丢失消息解决办法: 1)事务机制:(同步方式,不推荐) 对于RabbitMQ来说,生产者发送数据之前开启RabbitMQ的事务机制 channel.txselect,如果消 ...
MQ - 如何保证消息不丢失？处理重复消息？消息堆积处理？
什么是消息队列在百度百科中,消息队列是这么解释的:"消息队列"是在消息的传输过程中保存消息的容器. 消息队列全称为英文 Message Queue 简称(MQ)是一种应用程序对应 ...
RocketMQ 消息丢失场景分析及如何解决！
本文来源:https://blog.csdn.net/LO_YUN/article/details/103949317 既然在项目中使用了MQ,那么就不可避免的需要考虑消息丢失问题.在一些涉及到了金钱 ...
RocketMQ消息丢失场景及解决办法
作者:霁云HYY 来源:https://blog.csdn.net/LO_YUN/article/details/103949317 既然在项目中使用了MQ,那么就不可避免的需要考虑消息丢失问题.在一 ...
RocketMQ 消息丢失场景及解决办法
点击上方蓝色"程序猿DD",选择"设为星标" 回复"资源"获取独家整理的学习资料! 来源 | blog.csdn.net/LO_YUN/ar ...
Java性能优化推荐书！RocketMQ消息丢失场景及解决办法
毫不夸张的说,这份SpringBoot学习指南能解决你遇到的98%的问题给跪了!这套万人期待的 SQL 成神之路PDF,终于开源了既然使用在项目中使用了MQ,那么就不可避免的需要考虑消息丢失问题. ...
一文理清RocketMQ顺序消费、重复消费、消息丢失问题
前言在使用消息队列时不可避免的会遇到顺序消费.重复消费.消息丢失三个问题.在一次面试字节的时候,面试官问到如何保证顺序消费,当时回答不太准确,特意此文回顾如何解决顺序消费.重复消费.消息丢失三个问题 ...

MQ如何防止消息丢失

文章目录

MQ消息丢失问题

同步的事务一停止等待

同步的事务一连续ARQ

异步的事务—回调机制

本文小结

MQ如何防止消息丢失相关推荐

最新文章

热门文章