flowable中命令模式的应用

flowable中大量使用了设计模式中的 命令模式,咱来看看源码.

首先出场的执行器接口:CommandExecutor 只有一个实现类CommandExecutorImpl 

负责执行所有的命令.执行器有个最重要的方法

    /**
     * Execute a command with the default {@link CommandConfig}.
     */
    <T> T execute(Command<T> command);

这个执行器在创建流程引擎的时候执行器相关的配置被初始化,对象会被实例化.AbstractEngineConfiguration

public void initCommandExecutors() {
    initDefaultCommandConfig();
    initSchemaCommandConfig();
    initCommandInvoker();
    initCommandInterceptors();
    initCommandExecutor();
}

    public void initCommandExecutor() {
        if (commandExecutor == null) {
            CommandInterceptor first = initInterceptorChain(commandInterceptors);
            commandExecutor = new CommandExecutorImpl(getDefaultCommandConfig(), first);
        }
    }

执行器需要传入命令对象,以启动流程为例:

我们启动流程通常是按key启动,如runtimeService.startProcessInstanceByKey(procDefKey, businessTable + ":" + businessId, vars);

我们看源码是创建了一个StartProcessInstanceCmd的命令给执行器执行.

    @Override
    public ProcessInstance startProcessInstanceByKey(String processDefinitionKey, String businessKey, Map<String, Object> variables) {
        return commandExecutor.execute(new StartProcessInstanceCmd<ProcessInstance>(processDefinitionKey, null, businessKey, variables));
    }

StartProcessInstanceCmd<T> 实现了接口Command<ProcessInstance>,并且实现了命令的 execute方法

T execute(CommandContext commandContext);

这个StartProcessInstanceCmd的execute方法是真正的创建流程实例的逻辑.我们看到创建实例有两个逻辑,

1.获取ProcessDefinition

2.调用

processInstanceHelper.createProcessInstance()的方法创建实例并启动.

上面我们已经知道初始化了CommandExecutor,在此之前还初始化了默认的CommandInvoker对象.CommandInvoker 继承了AbstractCommandInterceptor

public void initCommandInvoker() {
    if (commandInvoker == null) {
        commandInvoker = new DefaultCommandInvoker();
    }
}

这个CommandInvoker就是执行command的真正执行者.CommandInvoker还用了责任链模式来处理日志和事务等通用任务.

LogInterceptor extends AbstractCommandInterceptor
SpringTransactionInterceptor extends AbstractCommandInterceptor
CommandContextInterceptor extends AbstractCommandInterceptor
CommandInvoker extends AbstractCommandInterceptor

CommandInvoker也是继承了AbstractCommandInterceptor的一个拦截器.抽象类

AbstractCommandInterceptor 实现了CommandInterceptor接口

拦截器在execute方法中执行了真正需要执行的Command的execute方法.

            // Execute the command.
            // This will produce operations that will be put on the agenda.
            agenda.planOperation(new Runnable() {
    
                @Override
                public void run() {
                    commandContext.setResult(command.execute(commandContext));
                }
            });
    
            // Run loop for agenda
            executeOperations(commandContext);

在这里flowable用了Agenda去轮询得到处理结果.

总结:

命令模式的三大件

CommandExecutor

Command

CommandInvoker

创建Command,交给执行器CommandExecutor,执行器的CommandInvoker最终去执行Command的execute方法的真正逻辑.

缺点:Command类可能会很多.