jbpm5 持久化及流转流程剖析

1、.：.；Jbpm5 耐久化及流转流程分析Jbpm5 耐久化构造图Jbpm5实例流程图下面的文档讲解了基于该流程的步骤流程第一步启动义务流程时序图：启动TaskServer运用线程启动TaskServer，初始化耐久化OrganizationEntity,将流程中需求运用到的 groupId,actorId.全部初始化到表中。启动流程1根据途径解析*.bpmn2或*.bpmn 文件,放入到内存中。 在该类注册了相关的对象org.jbpm.bpmn2.xml.BPMNSemanticModule .开启事务Ksession开场执行义务在org.drools.persistence.SingleSe

2、ssionCommandService 中 execute执行,流程实例为org.jbpm.ruleflow.instance.RuleFlowProcessInstance 的对象进入 cess.StartProcessCommand 中执行 excute执行StartNode执行StartNode,结点义务义务流转中心方法流程执行HumanTaskNode流程执行到HumanTask义务结点，引擎会执行org.jbpm.workflow.instance.node.WorkItemNodeInstance 这个实例类的internalTr

3、igger方法，并耐久化WorkItemInfo初始化Handler官方默许提供了WorkItemHandler的实现，com.carefx.workflow.handlermandBasedWSHumanTaskHandler。这个handler 就类似人工义务的范本，假设业务系统要做其他事情，可以适当的修正这个类就可以，例如：与外部组织机构交互等。初始化Client初始化TaskClient. 用于Client 与 效力端Server 交互建立Mina通讯衔接 Jbpm5 默许以 Mina 作为通讯耐久化通讯桥梁注册事件Complete注册事件Fail注册事件Skip初始化CommandB

4、asedWSHumanTaskHandler方法时，由客户端发起，向效力端中注册义务事件(TaskCompletedEvent, TaskFailedEvent, TaskSkippedEvent, TaskClaimedEvent等)。客户端(经过mina发起)：效力端(经过mina接纳)：调用excuteWorkItem 方法调用excuteWorkItem 方法，目的初始化义务信息(义务称号、义务优先级、处置义务人员分配等)，将得到的义务信息 一并发送到效力端进展耐久化初始化Task义务信息调用Client添加义务信息AddTaskRequest由客户端(TaskClient) 向效力端

5、(TaskServer)转发耐久化 Task 恳求该方法最后一行 经过发送 AddTaskRequest 恳求，发送到效力端 ，由效力端耐久化Task和 Content 信息耐久化Task效力端org.jbpm.task.service.TaskServerHandler接纳到客户端发送来的音讯AddTaskRequest, 1耐久化Task信息，插入相关的表PeopleAssignments_PotOwners，PeopleAssignments_ExclOwners，PeopleAssignments_Stakeholders，PeopleAssignments_Bas，PeopleAss

6、ignments_Recipients,Task, I18NTEXTAddTaskResponse经过AddTaskResponse，由效力端(TaskServer) 发起恳求通知客户端(TaskClient),通知客户端(org.jbpm.task.service.TaskClientHandler)添加义务终了,耐久化ProcessInstanceInfo, WorkItemInfo 数据此时路程曾经执行到了HumanTask义务结点上，同时分配了义务给详细的人。进展了耐久化操作。接着等待人员触发该义务前往义务终了前往sessionId,procesInstanceId给用户,外部系统坚持

7、以便获取耐久化信息。封锁事务(提交事务)耐久化processInfo,workItem 等，并对 sessionInfo 解锁执行流程的后续操作执行HumanTaskAfterNode拦截器执行StartAfterNode拦截器执行HumanTaskAfterNode拦截器Ksession.disponse()释放ksession第二步人工义务流程时序图:启动TaskServerTaskServer 坚持启动形状，或者重新启动一个线程亦可。调用人工义务执行接口外部系统经过该接口实现人工义务的交互解析bpmn2读取原来流程的bpmn2 文件并解析到jbpm5 框架中经过kessionId 获取k

8、session经过第一步前往的sessionId.获取到耐久化的sessionInfo 信息，以及 processInstance信息。同时processInstance流程实体采用数据锁，保证并发平安性初始化Client建立Mina 通讯衔接初始化TaskClient, 建立起Mina衔接 注册事件Complete注册事件Fail注册事件Skip同时由客户端(TaskClient)发起，须向效力端TaskServer中注册义务事件(TaskCompletedEvent, TaskFailedEvent, TaskSkippedEvent, TaskClaimedEvent)。注册几个事件，就

9、需求发起几个Mina 恳求客户端(经过mina发起)：效力端(经过mina接纳)：前往registerWorkItemHandler容器注册人工义务Handler经过handler注册后,jbpm5 会自动实现与业务系统的交互发起查询人工义务恳求转发恳求查询人工义务恳求到 TaskClientQueryTasksAssignedAsPotentialOwner客户端(TaskClient)向效力端(TaskServer)发送恳求。发起QueryTasksAssignedAsPotentialOwner 查询恳求：查询分配的用户义务列表效力端(TaskServer) 接纳QueryTasksAs

10、signedAsPotentialOwner 恳求QueryTaskSummaryResponse客户端(TaskClient)接纳前往QueryTaskSummaryResponse 恳求自此，一个来回后，客户端总算获取到了义务信息，接下来再往下走吧前往人工义务信息人工义务前往 包含在 responseHandler 中 经过该接口的getResults 既可获取发起开场执行义务恳求(Start)查看能否需求分配义务，查看能否有groupId，假设groupId不为空那么可以让该组下的某个用户先领取义务。此处不引见分配义务情况开场执行义务OperationRequest客户端(TaskCli

11、ent)发起开场执行义务恳求效力端(TaskServer)接纳开场执行义务恳求OperationResponse客户端(TaskClient)接纳恳求自此，processInfo义务形状保管为InProcess.前往发起胜利完成人工义务恳求(Complete)完成义务，该流程极为繁琐。OpertationRequest客户端(TaskClient)向效力端(TaskServer)发送完成义务恳求OperationRequestEventTriggerResponse由效力端(TaskServer)向效力端(TaskClient)发送EventTriggerResponse恳求，目的需求客户端调

12、用义务信息,促发getContentRequest,让Content做耐久化OperataionResponse效力端(TaskServer)向效力端(TaskClient)发送OperationResponse恳求。GetTaskRequest客户端(TaskClient)向效力端(TaskServer)发送GetTaskRequest恳求，查询用户义务信息。GetTaskResponse效力端(TaskServer)向效力端(TaskClient)发送GetTaskResponse恳求，前往义务信息,并执行GetCompletedTaskResponseHandler 中的execute方

13、法GetContentRequest客户端(TaskClient)向效力端(TaskServer)发送GetContentRequest恳求，查询Content信息GetContentResponse效力端(TaskServer)向效力端(TaskClient)发送GetContentResponse恳求，调用WorkItem管理器 completeWorkItem接口Ksession开启事务Kession 执行CompleteWorkItemCommand结点开场流转调用HumanHandler初始化初始化下个结点的 workItem 信息初始化client注册CompleteEvent注册

14、FailEvent注册SkipEventexcuteWorkItem初始化下个结点的Task在CommandBasedWSHumanTaskHandler 中执行初始化下个结点的Task发送创建义务耐久化恳求AddTaskRequestAddTaskResponse前往前往提交事务前往相关表操作步骤TaskClientTaskServer操作类型涉及的表2.1AOrganizationalEntity2.2.3ASessionInfo2.3.2AProcessInstanceInfo2.3.1AWorkItemInfo2.3.1AVariableInstanceLog, ProcessInst

15、anceLog,NodeInstanceLog2.3.1AVariableInstanceLog,NodeInstanceLog2.4.4ATask,I18NText, PeopleAssignments_Bas,PeopleAssignments_PotOwners,PEOPLEASSIGNMENTS_EXCLOWNERS,PEOPLEASSIGNMENTS_RECIPIENTS,PEOPLEASSIGNMENTS_STAKEHOLDERS,Content,3.7UProcessInstanceInfo3.9.10AWorkItemInfo新增下个结点3.9.11AVariableInstanceLog, NodeInstanceLog3.9.1