[首页]
[文章]
[教程]
首页
Web开发
Windows开发
编程语言
数据库技术
移动平台
系统服务
微信
设计
布布扣
其他
数据分析
首页
>
其他
> 详细
activiti源码解读之心得整编
时间:
2016-02-24 17:09:11
阅读:
331
评论:
0
收藏:
0
[点我收藏+]
TaskService.completeTask()的执行内幕是啥?
activiti采取了command模式,completeTask会被包装成一个CompleteTaskCmd,一个Cmd执行的时候需要一些外围处理,如:log日志。activiti定义了一个拦截器链,链上的每个拦截器都有个next,会一直next执行下去。以CompleteTaskCmd为例,拦截器链为:
logger拦截器-->spring事务拦截器-->CommandContext拦截器-->CommandInvoker拦截器
其中CommandContext拦截器的工作主要是设置Context:
[java]
view plain
copy
print
?
// Push on stack
Context.setCommandContext(context);
Context.setProcessEngineConfiguration(processEngineConfiguration);
return
next.execute(config, command);
这边push,另外有地方pop,CommandInvoker就干的此事:
[java]
view plain
copy
print
?
public
T execute(CommandConfig config, Command command) {
return
command.execute(Context.getCommandContext());
}
一个节点结束了,流程怎么知道往下走?
答案是TaskEntity.completeTask()方法会调用execution.signal()-->activityBehavior.signal()-->activityBehavior.leave()方法,该方法最终会激活AtomicOperationTransitionNotifyListenerStart的eventNotificationsCompleted()方法,该方法会创建当前Transition的destination,代码如下:
[java]
view plain
copy
print
?
protected
void
eventNotificationsCompleted(InterpretableExecution execution) {
TransitionImpl transition = execution.getTransition();
ActivityImpl destination =
null
;
if
(transition ==
null
) {
// this is null after async cont. -> transition is not stored in execution
destination = (ActivityImpl) execution.getActivity();
}
else
{
destination = transition.getDestination();
}
ActivityImpl activity = (ActivityImpl) execution.getActivity();
if
(activity!=destination) {
ActivityImpl nextScope = AtomicOperationTransitionNotifyListenerTake.findNextScope(activity, destination);
execution.setActivity(nextScope);
execution.performOperation(TRANSITION_CREATE_SCOPE);
}
else
{
execution.setTransition(
null
);
execution.setActivity(destination);
execution.performOperation(ACTIVITY_EXECUTE);
}
}
多实例任务怎么知道该loop已结束?
多实例任务会启动多个任务和execution,调用execution.signal()-->activityBehavior.signal()-->activityBehavior.leave(),ParallelMultiInstanceBehavior.leave()其中包含如下代码:
[java]
view plain
copy
print
?
List joinedExecutions = executionEntity.findInactiveConcurrentExecutions(execution.getActivity());
if
(joinedExecutions.size() == nrOfInstances || completionConditionSatisfied(execution)) {
// Removing all active child executions (ie because completionCondition is true)
List executionsToRemove =
new
ArrayList ();
for
(ActivityExecution childExecution : executionEntity.getParent().getExecutions()) {
if
(childExecution.isActive()) {
executionsToRemove.add((ExecutionEntity) childExecution);
}
}
for
(ExecutionEntity executionToRemove : executionsToRemove) {
if
(LOGGER.isDebugEnabled()) {
LOGGER.debug(
"Execution {} still active, but multi-instance is completed. Removing this execution."
, executionToRemove);
}
executionToRemove.inactivate();
executionToRemove.deleteCascade(
"multi-instance completed"
);
}
executionEntity.takeAll(executionEntity.getActivity().getOutgoingTransitions(), joinedExecutions);
completionConditionSatisfied()方法将用来判断是否该结束,takeAll()方法将结束当前子执行,并将主执行设置为active。
是否可以在运行时期新增/修改一个activity
当然可以!但是记住,标注有当前activity的execution在后续执行和结束的时候会用到这个activity!如果发生程序关闭等情况,execution会尝试从ProcessDefinition里重新根据ID加载activity,如下所示:
[java]
view plain
copy
print
?
protected
void
ensureProcessDefinitionInitialized() {
if
((processDefinition ==
null
) && (processDefinitionId !=
null
)) {
ProcessDefinitionEntity deployedProcessDefinition = Context
.getProcessEngineConfiguration()
.getDeploymentManager()
.findDeployedProcessDefinitionById(processDefinitionId);
setProcessDefinition(deployedProcessDefinition);
}
}
protected
void
ensureActivityInitialized() {
if
((activity ==
null
) && (activityId !=
null
)) {
activity = getProcessDefinition().findActivity(activityId);
}
}
再来看看execution的set方法,就能明白它为什么会保留一堆id:
[java]
view plain
copy
print
?
public
void
setActivity(ActivityImpl activity) {
this
.activity = activity;
if
(activity !=
null
) {
this
.activityId = activity.getId();
this
.activityName = (String) activity.getProperty(
"name"
);
}
else
{
this
.activityId =
null
;
this
.activityName =
null
;
}
}
所以,要完全保证程序认识被改造的activity的途径是:自定义ProcessDefinition,重写其findActivity()方法!
为什么bpmn文件是XML格式,但model记录里面却采用的是JSON格式,而deployment里又采用的是XML格式?
不知道!真的不知道activiti为什么这么做!是想支持flex里面的JSON建模么?(如上结论主要是针对于activiti-modeler的实现,经仔细验证,activiti-engine对model的editorsource是没有任何限制的~~~)
进入多实例节点的时候,系统何时创建了新的子执行?
答案是AtomicOperationTransitionCreateScope.execute(),代码摘录如下:
[java]
view plain
copy
print
?
public
void
execute(InterpretableExecution execution) {
InterpretableExecution propagatingExecution =
null
;
ActivityImpl activity = (ActivityImpl) execution.getActivity();
if
(activity.isScope()) {
propagatingExecution = (InterpretableExecution) execution.createExecution();
propagatingExecution.setActivity(activity);
propagatingExecution.setTransition(execution.getTransition());
execution.setTransition(
null
);
execution.setActivity(
null
);
execution.setActive(
false
);
log.debug(
"create scope: parent {} continues as execution {}"
, execution, propagatingExecution);
propagatingExecution.initialize();
}
else
{
propagatingExecution = execution;
}
propagatingExecution.performOperation(AtomicOperation.TRANSITION_NOTIFY_LISTENER_START);
}
其中的activity就是当前的节点。
什么时候保存历史记录信息?如:HistoricActivity
魅力在于activity的executionListeners,代码如下:
[java]
view plain
copy
print
?
public
class
ActivityInstanceEndHandler
implements
ExecutionListener {
public
void
notify(DelegateExecution execution) {
Context.getCommandContext().getHistoryManager()
.recordActivityEnd((ExecutionEntity) execution);
}
}
activiti源码解读之心得整编
原文:http://www.cnblogs.com/haore147/p/5213591.html
踩
(
0
)
赞
(
0
)
举报
评论
一句话评论(
0
)
登录后才能评论!
分享档案
更多>
2021年09月23日 (328)
2021年09月24日 (313)
2021年09月17日 (191)
2021年09月15日 (369)
2021年09月16日 (411)
2021年09月13日 (439)
2021年09月11日 (398)
2021年09月12日 (393)
2021年09月10日 (160)
2021年09月08日 (222)
最新文章
更多>
2021/09/28 scripts
2022-05-27
vue自定义全局指令v-emoji限制input输入表情和特殊字符
2022-05-27
9.26学习总结
2022-05-27
vim操作
2022-05-27
深入理解计算机基础 第三章
2022-05-27
C++ string 作为形参与引用传递(转)
2022-05-27
python 加解密
2022-05-27
JavaScript-对象数组里根据id获取name,对象可能有children属性
2022-05-27
SQL语句——保持现有内容在后面增加内容
2022-05-27
virsh命令文档
2022-05-27
教程昨日排行
更多>
1.
list.reverse()
2.
Django Admin 管理工具
3.
AppML 案例模型
4.
HTML 标签列表(功能排序)
5.
HTML 颜色名
6.
HTML 语言代码
7.
jQuery 事件
8.
jEasyUI 创建分割按钮
9.
jEasyUI 创建复杂布局
10.
jEasyUI 创建简单窗口
友情链接
汇智网
PHP教程
插件网
关于我们
-
联系我们
-
留言反馈
- 联系我们:wmxa8@hotmail.com
© 2014
bubuko.com
版权所有
打开技术之扣,分享程序人生!