第三章：Bean 工厂与对象创建  本章将深入探讨 Jfire 的 Bean 工厂体系，理解不同工厂的设计思想和使用场景，掌握 @Bean 方法的处理机制，以及如何自定义工厂来扩展 Bean 的创建方式。  3.1 为什么需要 Bean 工厂 在第二章中，我们知道 BeanDefinition 负责管理 Bean 的生命周期，但具体的对象创建逻辑是由 Bean 工厂（BeanFactory） 来完成的。 3.1.1 对象创建的多样性 在实际开发中，创建对象的方式多种多样： // 方式1：反射调用无参构造器 UserService service = UserService.class.getD...

第二章：Bean 定义体系——容器的基石  本章将深入剖析 Jfire 的 Bean 定义体系，理解 BeanDefinition 和 BeanRegisterInfo 的设计思想，掌握单例与原型作用域的实现原理，以及循环依赖的检测与解决机制。  2.1 为什么需要 Bean 定义 在第一章中，我们知道 IOC 容器负责管理 Bean 的创建和依赖注入。但容器如何知道：  这个 Bean 的类型是什么？ 应该如何创建这个 Bean？ 这个 Bean 是单例还是原型？ 创建后需要执行哪些初始化操作？ 需要注入哪些依赖？  这些信息都需要通过 Bean 定义（BeanDefinition） 来描述...

第一章：走进 IOC 容器——设计思想与整体架构  本章将带你理解 IOC 容器的核心思想，建立对 Jfire 框架的整体认知，并通过源码分析揭示一个轻量级 IOC 容器的设计精髓。本专栏的项目地址在：https://github.com/linbin-eric/jfire  1.1 什么是 IOC 与 DI 在传统的 Java 开发中，当一个对象需要依赖另一个对象时，我们通常会这样写： public class UserService { private UserDao userDao = new UserDaoImpl(); // 主动创建依赖 public void saveUser(U...

RocketMQ源码随笔-注册服务器 [TOC] NamesrvStartup 该类用于启动注册服务器。其main方法委托了main0方法，该方法的执行逻辑如下：  调用方法NamesrvStartup#createNamesrvController创建一个NamesrvController实例，声明为controller。 调用方法NamesrvStartup#start将这个controller启动。  那么下面就分别来看下两个方法的具体内容。 欢迎加入技术交流群186233599讨论交流，也欢迎关注技术公众号：风火说。 createNamesrvController 这个方法最重要的就是...

过期文件的删除 引言 RocketMQ中文件的存储是分为3个不同的部分：  CommitLog，提交日志。所有主题、队列的消息数据都是直接写入这一文件。 ConsumeQueue，消费队列。按照主题和队列的方式进行区分，消费队列中写入定长20字节的消费条目信息，消费条目中指向了该信息对应在提交日志中的偏移量。 IndexFile，索引文件。索引文件中写入定长20字节的索引信息，索引信息中指向了消息在提交日志中的偏移量。  RocketMQ不会无限制的将消息存储下去，而是采取一定的策略清除过期文件或者在磁盘不足的时候触发文件的删除，或者是手动的方式触发文件的删除。 在启动一个Broker的时候，...

RocketMq源码随笔-Broker的初始化 [TOC] BrokerStartup Broker的启动是依靠BrokerStartup方法。 首先是通过BrokerStartup#createBrokerController来创建一个BrokerController对象。 createBrokerController方法首先是一大串配置确认，转化、打印等。接下来是三个真正的创建步骤：  创建BrokerController实例，并且加载读取到的外部配置信息。 调用方法BrokerController#initialize执行初始化。 添加 hook，在收到外部关闭指令的时候关闭 contr...

RocketMq源码随笔-索引文件与消费队列的创建 引言 Broker在将消息写入到提交日志后，写入线程的动作就结束了。而Broker后台会运行一个ReputMessageService线程。该线程会不断的检查提交日志的内容，如果发现了新增的消息数据，则读取消息的数据内容，组装为DispatchRequest对象，通过接口方法CommitLogDispatcher#dispatch实现该消息的分发处理。 消息的分发处理，通过对该接口的不同实现来进行。不同的实现对应创建不同的内容。 欢迎加入技术交流群186233599讨论交流，也欢迎关注技术公众号：风火说。 ReputMessageServic...

RocketMq源码随笔-刷盘 引言 在rocketmq中有两种刷盘模式：同步刷盘和异步刷盘。  从类图上来看，有三个不同的实现思路。那下面逐一来看过。 适用情况如下  同步刷盘使用GroupCommitService。 异步刷盘且未开启TransientStorePool，使用FlushRealTimeService。 异步刷盘且开启TransientStorePool，使用CommitRealService。  欢迎加入技术交流群186233599讨论交流，也欢迎关注技术公众号：风火说。 GroupCommitService GroupCommitService是在同步刷盘的时候会使用到的...

RocketMq 高可用实现逻辑 [TOC] HAService putRequest 委托给方法HAService.GroupTransferService#putRequest去实现。 notifyTransferSome 该方法主要是为了对GroupTransferService中的等待线程执行唤醒。通过CAS操作，将入参的offset的值尝试写入push2SlaveMaxOffset，前提是入参的值大于当前值。 一旦CAS成功，则执行方法HAService.GroupTransferService#notifyTransferSome唤醒在GroupTransferService上等待...

RocketMq三种刷盘模式实现逻辑 [TOC] 在rocketmq中有两种刷盘模式：同步刷盘和异步刷盘。  从类图上来看，有三个不同的实现思路。那下面逐一来看过。 适用情况如下  同步刷盘使用GroupCommitService。 异步刷盘且未开启TransientStorePool，使用FlushRealTimeService。 异步刷盘且开启TransientStorePool，使用CommitRealService。  GroupCommitService GroupCommitService是在同步刷盘的时候会使用到的。 该类有两个属性：requestsWrite和requestsR...

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

ConcurrentHashMap源码走读 [TOC] 简介 在从JDK8开始，为了提高并发度，ConcurrentHashMap的源码进行了很大的调整。在JDK7中，采用的是分段锁的思路。简单的说，就是ConcurrentHashMap是由多个HashMap构成。当需要进行写入操作的时候，会寻找到对应的HashMap，使用synchronized对对应的hashmap加锁，然后执行写入操作。显然，并发程度就取决于HashMap个数的多少。而在JDK8中换了一种完全不同的思路。 首先，仍然是使用Entry[]作为数据的基本存储。但是锁的粒度被缩小到了数组中的每一个槽位上，数据读取的可见性依靠v...

Activiti架构分析及源码详解 [TOC] 引言 工作流引擎，应用于解决流程审批和流程编排方面等问题，有效的提供了扩展性的支撑。而目前来说，工作流领域也有了相对通行化的标准规范，也就是BPMN2.0。支持这个规范的开源引擎主要有：Activiti，flowable，Jbpm4等。本文着重对Activiti的架构设计进行分析和梳理，同时对流程启动和原子操作的相关代码进行完整走读。 本文的阅读对象需要对Activiti有一定的理解并且已经能够初步的使用Activiti进行流程流转方面开发。 欢迎加入技术交流群186233599讨论交流，也欢迎关注技术公众号：风火说。 一、Activiti设计解...

AQS源码详细解读 [TOC] 基础 在讲解AQS之前，有几个额外的知识需要了解。知道了这些，才能明白AQS框架中很多代码的道理。  CAS相关知识 通过标识位进行线程挂起的并发编程范式 MPSC队列的实现技巧  欢迎加入技术交流群186233599讨论交流，也欢迎关注笔者公众号：风火说。 CAS相关知识 CAS相关知识具体不表，请百度相关概念 通过标识位进行线程挂起的并发编程范式 一个线程通过一个标识位来表明自己进入挂起状态，那么在该线程将挂起标识位设置为真时，需要再次检查所有的资源条件，而后才能真正的将自己挂起。也就是所谓的二次检查。因为别的线程需要通过挂起标识位来判断是否唤醒挂起线程。而...