JBPM工作流引擎原理

￡神魔★判官ぃ 2022-03-02 02:47 240阅读 0赞

1.      JBPM[工作流引擎][Link 1]是用来做什么的

首先要说明的一点是工作流引擎指的并不只是JBPM，JBPM只是工作流引擎的一种。JBPM利用JPDL流程定义语言将现实生活中处理事务的业务流程进行抽象，形成一套业务流程规则，只要处理该项业务就必须按照这个流程规则进行。举一个很简单的例子，就拿[看医生][Link 2]来讲，看医生的整个流程必须是先挂号，再看病，再抓药，只要你进行看医生这个业务就必须按照这套流程进行。说白了，工作流引擎只是将我们人工的处理过程进行了信息化而已，也并不是多么高深的思想。但是JBPM也并不是想我所说的这样简单，毕竟是一套相对来讲比较成熟的技术，它的功能还是十分强大的，它可以用来定义顺序流程结构，选择流程结构（也就是根据条件判断来决定下一步执行哪项任务），以及多任务必须全部完成才能进行到下一步的流程结构。总之，JBPM是将生活中的各种业务处理情况进行抽象所制定出的一套业务处理规则。

2.      JBPM如何应用

使用JBPM工作流引擎一般来讲分为五部分，他们分别是部署流程，创建流程实例，获取当前活动，获取特定用户的任务，以及完成任务。其中，每一部分都是通过一项JBPM服务完成的。下面通过上面的看医生这个流程来讲解如何使用JBPM。

首先来看我们的jpdl文件：

<?xml version="1.0" encoding="UTF-8"?>  
        <process key="test" name="test" xmlns="http://jbpm.org/4.4/jpdl">  
           <start g="275,16,48,48" name="start1">  
              <transition g="-60,-15" name="挂号" to="进行挂号"/>  
           </start>  
           <task assignee="nurse" g="255,101,92,52" name="进行挂号">  
              <transition g="-69,-20" name="提交到医师" to="医师看病"/>  
           </task>  
           <task assignee="doctor" g="259,186,92,52" name="医师看病">  
              <transition g="-50,-20" name="抓药" to="end1"/>  
           </task>  
           <end g="283,283,48,48" name="end1"/>     
        </process>

上面的jpdl文件定义好了整个看医生的流程，它由四个节点组成，开始节点，进行挂号节点，医师看病节点以及结束节点组成。下面我们来看上面提到的具体的五部分都是怎样进行的：

public class seeDoctor extends TestCase {  
          
            /** 
             * 部署流程 
             */  
            public void deploy(){  
                //创建流程引擎  
                ProcessEngine processEngine = Configuration.getProcessEngine();  
                  
                //创建服务  
                RepositoryService repositoryService = processEngine.getRepositoryService();  
                  
                //部署流程  
                repositoryService.createDeployment().addResourceFromClasspath("seeDoctor.jpdl.xml").deploy();  
                  
                  
            }  
              
            /** 
             * 创建流程实例 
             */  
            public void createInstance(){  
                //创建流程引擎  
                ProcessEngine processEngine = Configuration.getProcessEngine();  
                  
                ExecutionService executionService = processEngine.getExecutionService();  
                  
                ProcessInstance processInstance = executionService.startProcessInstanceByKey("seeDoctor");  
                  
                System.out.println("流程实例ID===============" + processInstance.getId());  
            }  
              
            //查询流程实例当前所在节点  
                public void getCurrentActivity(){  
                    ProcessEngine processEngine = Configuration.getProcessEngine();  
                    ExecutionService executionService = processEngine.getExecutionService();  
                    String activityName = executionService.createProcessInstanceQuery().processInstanceId("seeDoctor.10001").uniqueResult().findActiveActivityNames().toString();  
                    System.out.println("当前任务所在节点======" + activityName);  
                }  
              
            /** 
             * 获取对应人员的任务 
             */  
            public void getTask(){  
                ProcessEngine processEngine = Configuration.getProcessEngine();  
                TaskService taskService = processEngine.getTaskService();  
                List<Task> tasks = taskService.findPersonalTasks("nurse");  
                Task task = tasks.get(0);  
                System.out.println("任务数量===" + tasks.size() );  
                System.out.println("任务名词===" + task.getActivityName());  
                System.out.println("任务人员===" + task.getAssignee() + "任务ID===" + task.getId());  
            }  
              
              
              
            //完成任务  
            public void completeTask(){  
                ProcessEngine processEngine = Configuration.getProcessEngine();  
                TaskService taskService = processEngine.getTaskService();  
                taskService.completeTask("20001");  
            }  
        }

下面我们来一次讲解每个部分所完成的主要功能。

Deploy()部署流程的作用[顾名思义][Link 3]，就是部署一个已经制定好的jpdl文件，它的作用类似一个具有版本号的类，流程实例就是这个流程的实例化。在jpdl文件中我们通常通过指定key值来区分所部署的各个流程，如果key相同则规定创建流程实例时按最高版本进行实例化。

createInstance()创建流程实例就是根据key值来确定实例化哪个流程，如果有多个流程的key相同则取最高版本。

getCurrentActivity()查询流程实例当前所在节点。该函数的作用在于根据流程实例ID，来获取该流程实例当前执行到了哪个节点，如本例中的流程实例有进行挂号和医师看病两个节点，该函数就是用来确定当前流程实例执行到了进行挂号还是医师看病环节。

getTask()函数中，之所以用Task task = tasks.get(0)语句来取得第一个任务是因为可能有多个完全不同的流程实例中都有一个为nurse的角色名字，假如恰好出现了这种情况则该函数会取出所有流程实例中角色名称为nurse的任务。

completeTask()完成任务，该函数的作用比较清晰就是根据任务ID，将该任务结束，然后进入到下一节点中，比如当前所在任务节点是进行挂号，该任务ID是10001，则完成该任务后，则会自动进入到医师看病这个节点，当完成医师看病这个任务后则会自动进入到end节点，也就是完成了整个流程。

3.      JBPM中每个服务所对应的[数据库][Link 4]表。

在上面的代码中我们可以很明显的看出在每一部分中都对应着一个Service，也就是一个服务，而所有的服务都是由JBPM引擎来创建的。

在部署流程环节，它所对应的是RepositoryService服务，当部署完流程后，在jbpm4\_deployment中会插入一条部署流程记录，同时在jbpm4\_deployprop表中会记录该流程的详细信息。

在创建流程实例环节，所对应的的是ExecutionService服务，该服务可以根据流程的key值用来启动一个具体的流程实例。启动一个具体的流程实例后会在jbpm4\_execution表中插入一条流程实例记录。

getCurrentActivity()获取当前流程实例环节对应的也是ExecutionService，它操作的表同样是jbpm4\_execution，但是该服务对该表进行的查询操作而并非插入操作，根据流程实例ID来查询出该流程实例当前所在的节点。

getTask()获取对应人员的任务环节对应的是TaskService服务，该服务的作用是获取特定角色名的人员的所有任务，它所操作的表示jbpm4\_task表，该表所存储的是各个实例的当前任务，所以根据角色名所查询出的很可能是不同实例的相同角色名对应的所有任务。

最后一个是completeTask()环节，该环节对应的同样是TaskService服务，它的作用也十分的单一，就是根据任务ID来结束任务，使得流程实例进入到下一个节点。

[Link 1]: https://www.baidu.com/s?wd=%E5%B7%A5%E4%BD%9C%E6%B5%81%E5%BC%95%E6%93%8E&tn=24004469_oem_dg&rsv_dl=gh_pl_sl_csd
[Link 2]: https://www.baidu.com/s?wd=%E7%9C%8B%E5%8C%BB%E7%94%9F&tn=24004469_oem_dg&rsv_dl=gh_pl_sl_csd
[Link 3]: https://www.baidu.com/s?wd=%E9%A1%BE%E5%90%8D%E6%80%9D%E4%B9%89&tn=24004469_oem_dg&rsv_dl=gh_pl_sl_csd
[Link 4]: http://lib.csdn.net/base/mysql