RocketMQ总结之 消息发送和存储流程
基本概念 参考官方： https://github.com/apache/rocketmq/tree/master/docs/cn 整体架构 Producer：生产者 Consumer：消费者 Broker：负责消息存储、投递、查询 ...
原文：rocketmq消息及流程
为什么用mq 优势 主要有 个： 应用解耦 降低微服务之间的关联 异步提速 微服务拿到mq消息后同时工作 削峰填谷 可以消息堆积 劣势 系统可用性降低 MQ一旦宕机整个系统不可用 复杂度提高 需要解决系统消息一致性 重复消费... 一致性问题 不同系统拿到mq中的消息后，部分系统处理失败怎么办 rocketmq集群工作流程 由上图可以看出，rocketMQ集群 消息服务器集群 命名服务器集群，其 ...
2021-12-10 00:07 0 162 推荐指数：
相关推荐
RocketMq producer 发送一条消息所经过的流程
前言： RocketMq producer 在发送一条消息时候，从 producer --nameSrv -- Broker 中间经过了什么样子的数据交互 开始： 如下是 Producer 发送消息的一个demo例子： 构建发送消息： 从NameSrv ...
RocketMq的事务消息发送方法,消息零丢失的实现方式,代码流程讲解,干货分享
1.消息发送mq不丢失实现方式 上面是发送RocketMq的事务消息发送方法 下面是RocketMq的事务消息发送方法的回调函数的实现类 以上就是RocketMq的事务消息发送方法,可以实现发送消息的零丢失,以事务的方式确保消息一定可以发送到 ...
RocketMQ （三）RocketMQ 怎么保证的消息不丢失？
一、消息发送过程 我们将消息流程分为如下三大部分，每一部分都有可能会丢失数据。 生产阶段：Producer通过网络将消息发送给Broker，这个发送可能会发生丢失，比如网络延迟不可达等。 存储阶段：Broker肯定是先把消息放到内存的，然后根据刷盘策略持久化到硬盘中，刚收到 ...
rocketMQ(七) rocketMQ 消息端配置
一.消息队列RocketMQ4.X消费者核心配置讲解 consumeFromWhere配置(某些情况失效：参考 https://blog.csdn.net/a417930422/article/details/83585397 ...
RocketMQ源码 — 九、 RocketMQ延时消息
通过设置消息被投递的时间来实现的，但是Apache RocketMQ在版本4.2.0中尚不支持指定时间 ...
RocketMQ源码 — 八、 RocketMQ消息重试
RocketMQ的消息重试包含了producer发送消息的重试和consumer消息消费的重试。 producer发送消息重试 producer在发送消息的时候如果发送失败了，RocketMQ会自动重试。 重试几次？ 由上面可以看出发送消息的重试次数区分不同的情况： 同步发送 ...
RocketMQ（二）事务消息&顺序消息
一、事务消息的由来 1、案例 引用官方的购物案例： 小明购买一个100元的东西，账户扣款100元的同时需要保证在下游的积分系统给小明这个账号增加100积分。账号系统和积分系统是两个独立是系统，一个要减少100元，一个要增加100积分。如下图： 2、问题 账号服务扣款成功 ...