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

RocketMQ 是一个来自阿里巴巴的分布式消息中间件，于 2012 年开源，并在 2017 年正式成为 Apache 顶级项目。据了解，包括阿里云上的消息产品以及收购的子公司在内，阿里集团的消息产品全线都运行在 RocketMQ 之上，并且最近几年的双十一大促中，RocketMQ 都有抢眼表现 ...

　　消息中间件是分布式系统常用的组件，无论是异步化、解耦、削峰等都有广泛的应用价值。我们通常会认为，消息中间件是一个可靠的组件——这里所谓的可靠是指，只要我把消息成功投递到了消息中间件，消息就不会丢失，即消息肯定会至少保证消息能被消费者成功消费一次，这是消息中间件最基本的特性之一，也就 ...

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

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

用户U1从A银行系统转账给B银行系统的用户U2的处理过程如下：第一步：A银行系统生成一条转账消息，以事务消息的方式写入RocketMQ，此时B银行系统不可见这条消息(Prepare阶段) 第二步：写入MQ成功后，回调A银行系统，对T1，T2表进行操作（很显然需要是一个事务）我们重点关注下T2 ...

一、可靠消息最终一致性事务概述 可靠消息最终一致性方案是指当事务发起方执行完成本地事务后并发出一条消息，事务参与方(消息消费者)一定能够接收消息并处理事务成功，此方案强调的是只要消息发给事务参与方最终事务要达到一致。 此方案是利用消息中间件完成，如下图：​ 事务发起方（消息生产方）将消息 ...

从“消息”到“消息、事件、流”的大融合 消息队列作为当代应用的通信基础设施，微服务架构应用的核心依赖，通过异步解耦能力让用户更高效地构建分布式、高性能、弹性健壮的应用程序。 从数据价值和业务价值角度来看，消息队列的价值不断深化。消息队列中流动的业务核心数据涉及集成传输、分析计算和处理 ...