RocketMQ源码详解 | Producer篇 · 其一：Start，然后 Send 一条消息
概述 Start DefaultMQProducer#start 首先进入 start 方法，可以看出主要的功能实现在于 defaultMQProducerIm ...
原文：RocketMQ源码详解 | Producer篇 · 其二：消息组成、发送链路
概述 在上一节 RocketMQ源码详解 Producer篇 其一：Start，然后 Send 一条消息 中，我们了解了 Producer 在发送消息的流程。这次我们再来具体下看消息的构成与其发送的链路 Message 在 RocketMQ 的使用中，Message 类是在发送消息时必须用到的，其中 body 即是消息的存放位置，还有的就是消息的 标识 flag 和 属性 properties 消 ...
2021-10-28 17:08 0 869 推荐指数：
相关推荐
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源码详解 | Broker篇 · 其一：线程模型与接收链路
概述 在上一节 RocketMQ源码详解 | Producer篇 · 其二：消息组成、发送链路 中，我们终于将消息发送出了 Producer，在短暂的 tcp 握手后，很快它就会进入目的 Broker。这次我们来自底向上的看下 Broker 端是如何接收然后分发处理消息，同时了解 ...
RocketMq producer 发送一条消息所经过的流程
前言： RocketMq producer 在发送一条消息时候，从 producer --nameSrv -- Broker 中间经过了什么样子的数据交互 开始： 如下是 Producer 发送消息的一个demo例子： 构建发送消息： 从NameSrv ...
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，不论是 ...