发送丢失 　　我们发送消息时，broker写入到cache后就返回成功了，而producer只要获取到ACK就说明消息发送成功了，反之肯定会收到一个异常，比如网络错误、请求超时之内的。而当我们发送失败后一直重试发送，能保证消息一定到达MQ吗？比如这样： 　　 　　本地事务执行完之后、数据库 ...

一、消息发送过程 我们将消息流程分为如下三大部分，每一部分都有可能会丢失数据。 生产阶段：Producer通过网络将消息发送给Broker，这个发送可能会发生丢失，比如网络延迟不可达等。 存储阶段：Broker肯定是先把消息放到内存的，然后根据刷盘策略持久化到硬盘中，刚收到 ...

前言 上篇文章，王子通过一个小案例和小伙伴们一起分析了一下消息是如何丢失的，但没有提出具体的解决方案。 我们已经知道发生消息丢失的原因大体上分为三个部分： 1.生产者发送消息到MQ这一过程导致消息丢失 2.MQ自己发生故障导致消息丢失 3.消费者拿到消息后，由于操作不当导致消息丢失 ...

https://blog.csdn.net/leeasony/article/details/104857576 ...

前言 通过之前文章的阅读，有关RocketMQ的底层原理相信小伙伴们已经有了一个比较清晰的认识。 那么接下来王子想跟大家讨论一个话题，如果我们的项目中引入了MQ，势必要面对的一个问题，就是消息丢失问题，今天我们就来聊聊消息是怎么丢失的。 现在假设我们的业务是这样的，用户通过订单系统下了 ...

1、消息整体处理过程 这里我们将消息的整体处理阶段分为3个阶段进行分析： Producer发送消息阶段。 Broker处理消息阶段 ...

不知道大家对于这个问题遇到过没有，或者大家听到这个问题的第一反应是什么，应该如何做，如何避免消息丢失，一起来看看 首先我们知道rocketmq的一个消息从生产到最终的消费过程需要经历总共三个阶段，或者说会经过三个地方，分别是producer的发送端、broker的持久化机制 ...

RocketMQ如何保证消息零丢失呢？ Producer消息零丢失的解决方案： 1、事务消息机制：使用事务消息能保证生产者一定会将消息写入MQ，但是会降低吞吐量。 2、同步消息重试机制：发送同步消息，如果发生异常，则重试，如果重试超过一定次数仍然失败，则可以先入库，后续再补 ...