风火1989

文章

未归档(15)

/ 注册

全部文章 / 文章（共3篇）

RocketMQ源码随笔-注册服务器来自专栏

RocketMQ源码随笔-注册服务器 [TOC] NamesrvStartup 该类用于启动注册服务器。其main方法委托了main0方法，该方法的执行逻辑如下：调用方法NamesrvStartup#createNamesrvController创建一个NamesrvController实例，声...

消息队列 RocketMq

2021-01-25

0 598

RocketMQ源码随笔-过期文件的删除来自专栏

过期文件的删除引言 RocketMQ中文件的存储是分为3个不同的部分： CommitLog，提交日志。所有主题、队列的消息数据都是直接写入这一文件。 ConsumeQueue，消费队列。按照主题和队列的方式进行区分，消费队列中写入定长20字节的消费条目信息，消费条目中指向了该信息对应在提交日志中...

消息队列 RocketMq

2021-01-18

0 982

RocketMQ的三种刷盘实现逻辑来自专栏

RocketMQ的三种刷盘实现逻辑 [TOC] 在rocketmq中有两种刷盘模式：同步刷盘和异步刷盘。从类图上来看，有三个不同的实现思路。那下面逐一来看过。适用情况如下同步刷盘使用GroupCommitService。异步刷盘且未开启TransientStorePool，使用Flush...

消息队列 RocketMq

2020-12-30

0 1333