风火1989

分类

文章(41) 未归档(15)

/ 注册

TA的专栏 54篇文章 24人订阅

Java岗高薪必备：Netty从入门到实战30讲

32篇文章 2052人学习

Sentinel 深度解读：从源码到算法

2篇文章 780人学习

高并发、源码研究

14篇文章 1122人学习

RocketMq源码随笔

6篇文章 855人学习

全部文章（共6篇）

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

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

消息队列 RocketMq

2021-01-25

0 478

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

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

消息队列 RocketMq

2021-01-18

0 855

RocketMq源码随笔-Broker的初始化来自专栏

RocketMq源码随笔-Broker的初始化 [TOC] BrokerStartup Broker的启动是依靠BrokerStartup方法。首先是通过BrokerStartup#createBrokerController来创建一个BrokerController对象。 createBroke...

RocketMq

2021-01-13

0 448

RocketMq源码随笔-刷盘来自专栏

RocketMq源码随笔-刷盘引言在rocketmq中有两种刷盘模式：同步刷盘和异步刷盘。从类图上来看，有三个不同的实现思路。那下面逐一来看过。适用情况如下同步刷盘使用GroupCommitService。异步刷盘且未开启TransientStorePool，使用FlushRealT...

RocketMq

2021-01-10

0 457

RocketMq 高可用实现逻辑来自专栏

RocketMq 高可用实现逻辑 [TOC] HAService putRequest 委托给方法HAService.GroupTransferService#putRequest去实现。 notifyTransferSome 该方法主要是为了对GroupTransferService中的等待线程执...

RocketMq

2021-01-04

0 711

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

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

消息队列 RocketMq

2020-12-30

0 1122