云消息队列 MQ源码的相关内容

文章 2022-11-02 来自：开发者社区

搭建源码调试环境—RocketMQ源码分析（一）

你好，我是程序员Alan,很高兴遇见你。一、RocketMQ目录结构在正式开始搭建调试环境之前，我们先了解一下RockeMQ源码的整体架构。这是因为掌握了整体架构，可以让我们迅速了解各个方面的特性，并且可以方便我们后续快速定位功能模块对应的代码文件。话不多说，我们开始看RocketMQ目录结构。acl: 权限控制。可以给话题指定权限，只有拥有权限的消费者才可以进行消费。broker: Rocke....

文章 2022-09-07 来自：开发者社区

读完 RocketMQ 源码，我学会了如何优雅的创建线程

RocketMQ 是一款开源的分布式消息系统，基于高可用分布式集群技术，提供低延时、高可靠的消息发布与订阅服务。这篇文章，笔者整理了 RocketMQ 源码中创建线程的几点技巧，希望大家读完之后，能够有所收获。1 创建单线程首先我们先温习下常用的创建单线程的两种方式：实现 Runnable 接口继承 Thread 类▍一、实现 Runnable 接口图中，MyRunnable 类实现了 Runn....

文章 2022-08-24 来自：开发者社区

云原生中间件RocketMQ源码包结构和集群架构模型

源码包结构进入rocket的github官方地址：https://github.com/apache/rocketmq可以看到当前最新的 releases 版本是4.9.4，下载最新的源码包到本地。执行以下命令解压源码包，并通过maven打包构建。unzip rocketmq-all-4.9.4-source-release.zip cd rocketmq-all-4.9.4-source-re....

文章 2022-08-18 来自：开发者社区

RocketMQ 顺序消息解析——图解、源码级解析

# 顺序消息说到顺序，我们经常会将它和现实里的时间关联起来，即按照时间顺序表示事件的先后关系。比如发生在10:00的消息A就要早于发生在11:00的消息B。上面例子之所以成立的原因是他们有相同的参考系，倘若A的时间是北京时间，而B的时间是纽约时间，这个先后顺序就不一定成立了。 当然除了时间以....

文章 2022-08-18 来自：开发者社区

RocketMQ 延迟消息解析——图解、源码级解析

定义**延迟消息：** 生产者发送消息之后，不能立刻被消费者消费，而是应该等到一定时间之后才可以被消费。**例如：** 在淘宝购物时，当用户提交一个订单之后，如果30min还没有支付的话，就给用户发送一条提示消息Broker提供延迟消息功能的核心思路是一致的：将延迟消息先存放在一个临时的空间里，等到期后才发送给To....

文章 2022-05-23 来自：开发者社区

深入源码聊聊RocketMQ刷盘机制

本章概括同步刷盘整个同步刷盘策略由 FlushCommitLogService 与 GroupCommitService 实现。FlushCommitLogService 是 GroupCommitService 刷盘服务的父类，它是一个抽象类，本身没有实现，只是一个标记类，刷盘策略由子类负责完成。同步刷盘时，只有消息被真正持久化到磁盘才会响应 ACK，可靠性非常高，但是性能会受到较大影响，适用....

文章 2022-05-02 来自：开发者社区

RocketMQ高性能通信实现机制源码精读

异步通信机制源码精读生产者发送消息异步监听消息发送结果创建一个线程池用其中的一个线程去执行发送消息的动作监听发送结果如果有回调函数则调用回调函数这里的onSuccess回调就是图1中的回调函数1、一个请求对应一个请求编号每次请求的发送都要先获取一个信号量锁在服务器资源有限的情况下防止调用太快导致服务不可用 2、一个请求编号对应一个响应结果将对应关系保存在内存中 3、进行netty通....

文章 2022-04-19 来自：开发者社区

RocketMQ入门到入土（四）producer生产消息源码剖析

一、Demoimport org.apache.rocketmq.client.producer.DefaultMQProducer; import org.apache.rocketmq.client.producer.SendResult; import org.apache.rocketmq.common.message.Message; /** * Description: * *...

文章 2022-02-18 来自：开发者社区

RocketMQ入门到入土（五）消息持久化存储源码解析（下）

5、submitFlushRequest再次回到【2、commitLog.asyncPutMessage】的submitFlushRequest方法，因为之前的方法是将数据已经写到ByteBuffer缓冲区里了，下一步也就是我们现在这一步就要刷盘了。public CompletableFuture<PutMessageStatus> submitFlushRequest(Append....

文章 2022-02-18 来自：开发者社区

RocketMQ入门到入土（五）消息持久化存储源码解析（上）

一、原理1、消息存在哪了？消息持久化的地方其实是磁盘上，在如下目录里的commitlog文件夹里。/root/store/commitlog源码如下：// {@link org.apache.rocketmq.store.config.MessageStoreConfig} // 数据存储根目录 private String storePathRootDir = System.getProper....