rocketmq 基于 5.1.4 版本

在 rocketmq 中，消息分为多个类型，比如普通消息、批量消息、延迟消息、事务消息等，这一节主要介绍普通消息的逻辑，后面的章节会继续介绍其他消息。

rocketmq 基于 5.1.4 版本

broker 发起注册请求

源码位置: org.apache.rocketmq.broker.BrokerController#start

activiti 基于 8.0.0 版本

在这一节，详细介绍 BoundaryEvent, 这是工作流框架中很重要的节点，同时涉及到定时任务。

先来看看 BoundaryEvent 的 xml 定义

 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13

<userTask id="firstTask" name="First Task" />

<!-- 在到达 firstTask 节点时，会启动一个定时器 -->
<boundaryEvent id="escalationTimer1" cancelActivity="true" attachedToRef="firstTask">
  <timerEventDefinition>
    <timeDuration>PT2H</timeDuration>
  </timerEventDefinition>
</boundaryEvent>

<!-- 在定时器过期之后，会流转到 secondTask 节点 -->
<sequenceFlow id="flow3" sourceRef="escalationTimer1" targetRef="secondTask" />

<userTask id="secondTask" name="Second Task" />

执行 BoundaryEvent

源码位置: org.activiti.engine.impl.agenda.ContinueProcessOperation#executeSynchronous

activiti 基于 8.0.0 版本

工作流操作数据库，并不是直接执行 SQL 语句来完成的，而是通过操作缓存对象来实现的。

Entity 类

源码位置: org.activiti.engine.impl.persistence.entity.Entity

activiti 基于 8.0.0 版本

从之前的分析可以发现，工作流的每个操作都是一个 Command, 所以有必要看看内部的实现机制。

Command 类

源码位置: org.activiti.engine.impl.interceptor.Command

rocketmq 基于 5.1.4 版本

启动 namesrv

在 org.apache.rocketmq.namesrv.NamesrvStartup 中，配置环境变量 ROCKETMQ_HOME，如下图。