风火1989

文章

未归档(15)

/ 注册

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

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源码随笔-Broker的初始化来自专栏

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

RocketMq

2021-01-13

0 596

RocketMq源码随笔-索引文件与消费队列的创建来自专栏

RocketMq源码随笔-索引文件与消费队列的创建引言 Broker在将消息写入到提交日志后，写入线程的动作就结束了。而Broker后台会运行一个ReputMessageService线程。该线程会不断的检查提交日志的内容，如果发现了新增的消息数据，则读取消息的数据内容，组装为DispatchRe...

2021-01-10

0 525

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

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

RocketMq

2021-01-10

0 575

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

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

RocketMq

2021-01-04

0 839

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

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

消息队列 RocketMq

2020-12-30

0 1333

ConcurrentHashMap源码走读来自专栏

ConcurrentHashMap源码走读 [TOC] 简介在从JDK8开始，为了提高并发度，ConcurrentHashMap的源码进行了很大的调整。在JDK7中，采用的是分段锁的思路。简单的说，就是ConcurrentHashMap是由多个HashMap构成。当需要进行写入操作的时候，会寻找到...

JVM 源码

2020-12-24

0 444

Activiti架构分析及源码详解来自专栏

Activiti架构分析及源码详解 [TOC] 引言工作流引擎，应用于解决流程审批和流程编排方面等问题，有效的提供了扩展性的支撑。而目前来说，工作流领域也有了相对通行化的标准规范，也就是BPMN2.0。支持这个规范的开源引擎主要有：Activiti，flowable，Jbpm4等。本文着重对Act...

工作流 Activiti

2020-12-24

0 1296

AQS源码详细解读来自专栏

AQS源码详细解读 [TOC] 基础在讲解AQS之前，有几个额外的知识需要了解。知道了这些，才能明白AQS框架中很多代码的道理。 CAS相关知识通过标识位进行线程挂起的并发编程范式 MPSC队列的实现技巧欢迎加入技术交流群186233599讨论交流，也欢迎关注笔者公众号：风火说。 CA...

并发

2020-12-24

0 642