liteflow学习二
前面我们看到了执行的具体逻辑，但是在哪里构建EL表达式的、获取的、执行的呢？
一、EL表达式的设置
在LiteFlowChainELBuilder可以看到EL表达式的逻辑是基于阿里开源的QLExpress实现的, 在初始化QLExpress的Runner中，作者扩展了很多操作Operator。在setEL(String elStr)这个方法中，我们可以会将FlowBus中的chainMap和NodeMap放入到Context中，也即DefaultContext，同时放入当前的chainId。接着会解析el表达式，解析成最外部一个condition, 内部可以嵌套很多层。
可以看到构建EL表达式的过程中会涉及到chainMap和NodeMap放入到DefaultContext中：
DefaultContext<String, Object> context = new DefaultContext<>();
// 这里一定要先放chain，再放node，因为node优先于chain，所以当重名时，node会覆盖掉chain
FlowBus.getChainMap().values().forEach(chain -> context.put(chain.getChainId(), chain));
// 往上下文里放入所有的node，使得el表达式可以直接引用到nodeId
FlowBus.getNodeMap().keySet().forEach(nodeId -> context.put(nodeId, FlowBus.getNode(nodeId)));
// 放入当前主chain的ID
context.put(ChainConstant.CURR_CHAIN_ID, this.chain.getChainId());
// 解析el成为一个Condition
// 为什么这里只是一个Condition，而不是一个List<Condition>呢
// 这里无论多复杂的，外面必定有一个最外层的Condition，所以这里只有一个，内部可以嵌套很多层，这点和以前的不太一样
Condition condition = (Condition) EXPRESS_RUNNER.execute(elStr, context, errorList, true, true);
// 把主要的condition加入
this.conditionList.add(condition);
可以看到我们的WHEN表达式会进行WHEN的EL表达式的解析，此时经过BaseOperator会对对应的Operator进行依次构建。所有的Operator都会经过com.yomahub.liteflow.builder.el.operator.base.BaseOperator#executeInner进行build。
因此我们来看看WhenOperator是如何构建的。
public WhenCondition build(Object[] objects) throws Exception {
OperatorHelper.checkObjectSizeGtZero(objects);
WhenCondition whenCondition = new WhenCondition();
for (Object obj : objects) {
whenCondition.addExecutable(OperatorHelper.convert(obj, Executable.class));
}
return whenCondition;
}
此时会将可执行的执行器放入到executableGroup中，方便执行condition的时候获取执行。
public void addExecutable(String groupKey, Executable executable) {
System.out.println("添加执行的operator");
if (ObjectUtil.isNull(executable)) {
return;
}
List<Executable> executableList = this.executableGroup.get(groupKey);
if (CollUtil.isEmpty(executableList)) {
this.executableGroup.put(groupKey, ListUtil.toList(executable));
}
else {
this.executableGroup.get(groupKey).add(executable);
}
}
前面我们已经知道，liteflow的执行逻辑是先获取chain，然后执行chain，然后执行condition，最终执行业务逻辑中的nodeComponent。因此我们来看看并行器是如何实现的。
二、并行器是如何实现
前面说到THEN打头的是串行器，而WHEN打头的是并行器，因此我们可以看到Condition中的并行器对应的WhenCondition。
可以看到执行的execution是executeAsyncCondition(slotIndex)。
前面看到初始化LiteflowConfig的时候，没有配置信息。可以看到线程池的配置信息就是配置在LiteflowConfig中的。并行编排的实现借助了封装CompletableFuture对象。
前面我们知道执行condition的方法是executeCondition(Integer slotIndex)。执行condition的核心方法是com.yomahub.liteflow.flow.element.condition.WhenCondition#executeAsyncCondition。
那么此时我们似乎在Future的代码中找不到调用的逻辑，如果看过我上一篇文章的话，那应该知道调用condition之后，会调用具体的node执行业务逻辑编排代码。因此此时我们可以根据之前的线索知道会调用node中的execute方法。因此我们可以查询引用的地方，从而找到对应的地方。
根据前的ThenCondition的调用，我们知道调用的过程是condition到node的过程，因此这个过程必然会涉及到node的调用过程。因此我们可以知道对应的node的执行是在ParallelSupplier中。
public WhenFutureObj get() {
try {
executableItem.setCurrChainId(currChainId);
executableItem.execute(slotIndex);
return WhenFutureObj.success(executableItem.getId());
}
catch (Exception e) {
return WhenFutureObj.fail(executableItem.getId(), e);
}
}
从而调用node执行具体的业务逻辑方法com.yomahub.liteflow.flow.element.Node#execute。
从而进一步调用我们自己写的业务逻辑。
总结下来即：组装数据chain、node ，构建EL表达式，然后根据通过槽拿到chain，从而进一步拿到condition，从而拿到node，调用业务系统继承NodeComponent重写的process方法。
三、UML图
这里我们了解了并行编排的相关执行流程后，当然这些都是基于正常情况下实现的编排。如果是异常情况下，或者说重试失败的情况下，又做怎样的处理呢？下一篇，我们来学习，因为在业务处理中，我们会用到，同时这也是框架留给我们继承重写的方法。因此需要了解。
参考：https://gitee.com/dromara/LiteFlow LiteFlow的官网地址：https://liteflow.cc/