RocketMQ源码详解 | Producer篇 · 其二：消息组成、发送链路
概述 在上一节 RocketMQ源码详解 | Producer篇 · 其一：Start，然后 Send 一条消息 中，我们了解了 Producer 在发送消息的流程。这次我们再来具体下看消息的构成与其发送的链路 Message 在 RocketMQ 的使用中，Message 类是在发送 ...
原文：RocketMQ源码详解 | Producer篇 · 其一：Start，然后 Send 一条消息
概述 Start DefaultMQProducer start 首先进入 start 方法，可以看出主要的功能实现在于 defaultMQProducerImpl.start ，先忽略细枝末节，接着进去看看 DefaultMQProducerImpl start 然后，我们可以看到会根据当前生产者的状态来进行不同的行为 记得在设计模式里，这叫做 状态模式 具体的状态有： CREATE JUST ...
2021-10-17 14:55 1 812 推荐指数：
相关推荐
RocketMq producer 发送一条消息所经过的流程
前言： RocketMq producer 在发送一条消息时候，从 producer --nameSrv -- Broker 中间经过了什么样子的数据交互 开始： 如下是 Producer 发送消息的一个demo例子： 构建发送消息： 从NameSrv ...
RocketMQ源码 — 三、 Producer消息发送过程
Producer 消息发送 producer start producer启动过程如下图 消息发送流程 消息发送过程：先由producer封装通过netty发送到broker，然后由broker进行保存，过程 ...
RocketMQ中Producer消息的发送源码分析
上篇博客介绍过Producer的启动，这里涉及到相关内容就不再累赘了 【RocketMQ中Producer的启动源码分析】 Producer发送消息，首先需要生成Message实例： 其中properties中存放需要配置的属性，由MessageConst规定其key ...
RocketMQ 源码学习笔记 Producer 是怎么将消息发送至 Broker 的？
RocketMQ 源码学习笔记 Producer 是怎么将消息发送至 Broker 的？ 目录 RocketMQ 源码学习笔记 Producer 是怎么将消息发送至 Broker 的？ 前言 项目结构 rocketmq-client 模块 ...
RocketMQ源码详解 | Consumer篇 · 其一：消息的 Pull 和 Push
概述 当消息被存储后，消费者就会将其消费。 这句话简要的概述了一条消息的最总去向，也引出了本文将讨论的问题： 消息什么时候才对被消费者可见？ 是在 page cache 中吗？还是在落盘后？还是像 Kafka 一样维护了一个 ISR 队列，等到副本都将消息也落盘后 ...
探秘RocketMQ源码——Series1：Producer视角看事务消息
简介： 探秘RocketMQ源码——Series1：Producer视角看事务消息 1. 前言 Apache RocketMQ作为广为人知的开源消息中间件，诞生于阿里巴巴，于2016年捐赠给了Apache。从RocketMQ 4.0到如今最新的v4.7.1，不论是 ...
RocketMQ源码详解 | Broker篇 · 其四：事务消息、批量消息、延迟消息
概述 在上文中，我们讨论了消费者对于消息拉取的实现，对于 RocketMQ 这个黑盒的心脏部分，我们顺着消息的发送流程已经将其剖析了大半部分。本章我们不妨乘胜追击，接着讨论各种不同的消息的原理与实现。 事务消息 概念 RocketMQ 中的事务消息功能，实际上是 分布式事务中的本地 ...