`

jbpm的入门1--简单实例

    博客分类:
  • JBPM
阅读更多
这里使用的是mysql数据库
开发工具是eclipse
首先我们需要初始化话数据库
package test.config;

import org.jbpm.JbpmConfiguration;

public class InitDB {

	public static void main(String[] args) {
		InitDB initDB = new InitDB();
		initDB.createJbpmDB();
	}
	//初始化JBPM的数据库表
	public  void createJbpmDB(){
		JbpmConfiguration.getInstance().createSchema();
	}
	//删除JBPM的数据库表
	public void dropJbpmDB(){
		JbpmConfiguration.getInstance().dropSchema();
	}

}


相关的配置文件 可以在jbpm的程序包中找到
hibernate.cfg.xml要与你的数据库配置相匹配。

接下来我们绘制一个工作流,这里基本上用到jbpm的一个工作流绘制的插件。
我们绘制了一个简单的流程:
大体过程如下
起始状态--》任务1--》任务2--》结束
<?xml version="1.0" encoding="UTF-8"?>

<process-definition  xmlns=""  name="qj">


	<start-state name="start-state1">
		<transition to="apply"></transition>
	</start-state>


	<task-node name="apply">
		<task name="apply">
			<assignment actor-id="1"></assignment>
		</task>
		<transition to="approve"></transition>
	</task-node>

	<task-node name="approve">
		<task name="approve">
			<assignment actor-id="2"></assignment>
		</task>
		<transition to="end-state1"></transition>
	</task-node>


	<end-state name="end-state1"></end-state>


</process-definition>




这里的actor-id 是一个查看权限

现在我们将流程定义发布上去
package test.config;

import java.io.FileInputStream;
import java.io.FileNotFoundException;
import java.io.InputStream;

import org.jbpm.JbpmConfiguration;
import org.jbpm.JbpmContext;
import org.jbpm.graph.def.ProcessDefinition;

/**
 * 部署流程
 *
 */
public class Deploy {
	public static void main(String[] args) throws FileNotFoundException {
		JbpmContext jbpmContext = JbpmConfiguration.getInstance().createJbpmContext();
		//取得流程定义
		InputStream is = new FileInputStream("D:\\workspace\\fwk\\jbpm\\src\\test\\qj\\processdefinition.xml");
        ProcessDefinition pd = ProcessDefinition.parseXmlInputStream(is); 
		//部署流程
		jbpmContext.deployProcessDefinition(pd);
		
		jbpmContext.close();
	}
}


发布之后我们在数据库中已经可以看到相关的配置了。






下面我们创建一个流程实例。
package test;

import org.jbpm.JbpmConfiguration;
import org.jbpm.JbpmContext;
import org.jbpm.db.GraphSession;
import org.jbpm.graph.def.ProcessDefinition;
import org.jbpm.graph.exe.ProcessInstance;

public class CreatePDInstance {

	/**
	 * @param args
	 */
	public static void main(String[] args) {
		JbpmContext jbpmContext = JbpmConfiguration.getInstance().createJbpmContext();
	    GraphSession graphSession = jbpmContext.getGraphSession();
	    //取得流程定义
	    ProcessDefinition pd = graphSession.findLatestProcessDefinition("qj");
	    //创造实例
	    ProcessInstance pi = pd.createProcessInstance();
	    //token下移 刚创建的实例token是指向start-state1,我们需要让token完整这里流程 去指向真正的任务节点
	    pi.signal();
	    //当前token指向apply节点的第一个任务
	    jbpmContext.close();
	}

}






signal();方法是将状态进行转换,由于转至第二个状态,所以apply任务在结束完起始状态的时候会被同步创建创建。

由于apply任务是分配给actorId=1进行处理的,下面我们看看autorId=1的任务列表
package test;

import java.util.List;

import org.jbpm.JbpmConfiguration;
import org.jbpm.JbpmContext;
import org.jbpm.taskmgmt.exe.TaskInstance;

public class TaskActor1 {

	/**
	 * @param args
	 */
	public static void main(String[] args) {
		TaskActor1 ta1 = new TaskActor1();
		ta1.showList();

	}
	public void showList(){
		JbpmContext jbpmContext = JbpmConfiguration.getInstance().createJbpmContext();
	    String autorId="1";
	    List<TaskInstance> list = jbpmContext.getTaskList(autorId);
	    for(int i = 0 ;i<list.size();i++){
	    	TaskInstance ti = list.get(i);
	    	System.out.println("ID :" + ti.getId());
	    	System.out.println("ActorId :" + ti.getActorId());
	    	System.out.println("任务名称 :" + ti.getName());
	    	System.out.println("开始时间 :" + ti.getCreate());
	    	System.out.println("开始时间 :" + ti.getStart());
	    	System.out.println("结束时间 :" + ti.getEnd());
	    }
	}
}

我们可以看到该用户权限下的任务列表
ID :1
ActorId :1
任务名称 :apply
开始时间 :2009-06-25 16:59:05.0
开始时间 :null
结束时间 :null
下面我们开始任务该任务
我的id已经在之前获取到,这里就直接用了,实际应用中则应通过传参获取
package test;

import java.util.List;

import org.jbpm.JbpmConfiguration;
import org.jbpm.JbpmContext;
import org.jbpm.taskmgmt.exe.TaskInstance;

public class TaskActor1 {

	/**
	 * @param args
	 */
	public static void main(String[] args) {
		TaskActor1 ta1 = new TaskActor1();
		//ta1.showList();
		ta1.startTask(new Long(1));
	}
	public void showList(){
		JbpmContext jbpmContext = JbpmConfiguration.getInstance().createJbpmContext();
	    String autorId="1";
	    List<TaskInstance> list = jbpmContext.getTaskList(autorId);
	    for(int i = 0 ;i<list.size();i++){
	    	TaskInstance ti = list.get(i);
	    	System.out.println("ID :" + ti.getId());
	    	System.out.println("ActorId :" + ti.getActorId());
	    	System.out.println("任务名称 :" + ti.getName());
	    	System.out.println("开始时间 :" + ti.getCreate());
	    	System.out.println("开始时间 :" + ti.getStart());
	    	System.out.println("结束时间 :" + ti.getEnd());
	    }
	    jbpmContext.close();
	}
	public void startTask(Long i){
		JbpmContext jbpmContext = JbpmConfiguration.getInstance().createJbpmContext();
		TaskInstance ti = jbpmContext.loadTaskInstance(i);
		//如果该任务没有启动就将他启动
		if(ti.getStart() == null)
			ti.start();
		jbpmContext.close();
		showList();
	}
}

ID :1
ActorId :1
任务名称 :apply
开始时间 :2009-06-25 16:59:05.0
开始时间 :2009-06-25 19:25:52.0
结束时间 :null
此时已经开始
下面我们进行任务的完成
package test;

import java.util.List;

import org.jbpm.JbpmConfiguration;
import org.jbpm.JbpmContext;
import org.jbpm.taskmgmt.exe.TaskInstance;

public class TaskActor1 {

	/**
	 * @param args
	 */
	public static void main(String[] args) {
		TaskActor1 ta1 = new TaskActor1();
		//ta1.showList();
		//ta1.startTask(new Long(1));
		ta1.endTask(new Long(1));
	}
	public void showList(){
		JbpmContext jbpmContext = JbpmConfiguration.getInstance().createJbpmContext();
	    String autorId="1";
	    List<TaskInstance> list = jbpmContext.getTaskList(autorId);
	    for(int i = 0 ;i<list.size();i++){
	    	TaskInstance ti = list.get(i);
	    	System.out.println("ID :" + ti.getId());
	    	System.out.println("ActorId :" + ti.getActorId());
	    	System.out.println("任务名称 :" + ti.getName());
	    	System.out.println("开始时间 :" + ti.getCreate());
	    	System.out.println("开始时间 :" + ti.getStart());
	    	System.out.println("结束时间 :" + ti.getEnd());
	    }
	    jbpmContext.close();
	}
	public void startTask(Long i){
		JbpmContext jbpmContext = JbpmConfiguration.getInstance().createJbpmContext();
		TaskInstance ti = jbpmContext.loadTaskInstance(i);
		//如果该任务没有启动就将他启动
		if(ti.getStart() == null)
			ti.start();
		jbpmContext.close();
		showList();
	}
	public void endTask(Long i){
		JbpmContext jbpmContext = JbpmConfiguration.getInstance().createJbpmContext();
		TaskInstance ti = jbpmContext.loadTaskInstance(i);
		//如果该任务没有完成启动就将他完成
		if(ti.getEnd() == null)
			ti.end();
		jbpmContext.close();
		showList();
	}
}


完成之后在任务列表中已经没有任务了。
下面我们看一下数据库,第一个任务已经完成,第二个任务已经创建



接下来我们对ActorId=2的任务进行执行,等同上面的,这里不进行重复
package test;

import java.util.List;

import org.jbpm.JbpmConfiguration;
import org.jbpm.JbpmContext;
import org.jbpm.taskmgmt.exe.TaskInstance;

public class TaskActor2 {

	/**
	 * @param args
	 */
	public static void main(String[] args) {
		TaskActor2 ta2 = new TaskActor2();
		ta2.showList();
		ta2.startTask(new Long(2));
		ta2.endTask(new Long(2));
	}
	public void showList(){
		JbpmContext jbpmContext = JbpmConfiguration.getInstance().createJbpmContext();
	    String autorId="2";
	    List<TaskInstance> list = jbpmContext.getTaskList(autorId);
	    for(int i = 0 ;i<list.size();i++){
	    	TaskInstance ti = list.get(i);
	    	System.out.println("ID :" + ti.getId());
	    	System.out.println("ActorId :" + ti.getActorId());
	    	System.out.println("任务名称 :" + ti.getName());
	    	System.out.println("开始时间 :" + ti.getCreate());
	    	System.out.println("开始时间 :" + ti.getStart());
	    	System.out.println("结束时间 :" + ti.getEnd());
	    }
	    jbpmContext.close();
	}
	public void startTask(Long i){
		JbpmContext jbpmContext = JbpmConfiguration.getInstance().createJbpmContext();
		TaskInstance ti = jbpmContext.loadTaskInstance(i);
		//如果该任务没有启动就将他启动
		if(ti.getStart() == null)
			ti.start();
		jbpmContext.close();
		showList();
	}
	public void endTask(Long i){
		JbpmContext jbpmContext = JbpmConfiguration.getInstance().createJbpmContext();
		TaskInstance ti = jbpmContext.loadTaskInstance(i);
		//如果该任务没有完成启动就将他完成
		if(ti.getEnd() == null)
			ti.end();
		jbpmContext.close();
		showList();
	}
}

当第二个任务执行完成之后,你会看到任务已经整个流程已经完成,db中流程的end字段已经赋值





之所以这样分步来说,就是希望可以深入了解jbpm的执行流程
在实际的项目中往往开始和结束都是同时进行的
比如已经请假(star--填单--审批--end):往往是请假表单的填写的提交的瞬间(创建实例,填写请假单),审批的成功与否也是瞬间而且同时结束流程
即只有两步操作。
  • 大小: 24.7 KB
  • 大小: 22.7 KB
  • 大小: 32.1 KB
  • 大小: 30.6 KB
  • 大小: 42.4 KB
  • 大小: 45.8 KB
  • 大小: 32.7 KB
  • 大小: 20.6 KB
分享到:
评论

相关推荐

    jbpm-jpdl-suite-3.2.3的安装配置

    1. **jbpm-jpdl.jar**:这是jPDL的核心程序包,包含了流程定义和运行时流程实例管理的API。它可以将流程定义存储为XML文件并在内存中管理执行过程。 2. **jbpm-jpdl-designer-3.1.2.zip**:这是一个基于Eclipse的...

    jbpm-starters-kit-3.1.4 lib

    【jbpm-starters-kit-3.1.4 lib】是一个针对JBoss Business Automation Platform中jbpm(Java Business Process Management)的入门套件的库文件集合。这个版本3.1.4是jbpm的一个早期版本,它包含了运行和开发基于...

    jbpm-starters-kit-3.1.2.part1

    jbpm-starters-kit-3.1.2.part1 和 jbpm-starters-kit-3.1.2.part2 是两个分卷压缩文件,它们共同组成一个完整的jbpm开发入门套件。jbpm(Java Business Process Management)是一个开源的工作流管理系统,用于实现...

    jbpm3 入门项目-环境搭建(1)

    【jbpm3 入门项目-环境搭建(1)】是一个关于学习和设置jbpm3工作流引擎的初始项目的教程。jbpm3是Java Business Process Management的第三版,它允许开发者设计、执行和管理业务流程。这篇博客文章,虽然链接不可在...

    jbpm的入门2--流程设计器的安装

    **jbpm入门第二步——流程设计器的安装** 在IT领域,`jbpm`(Java Business Process Management)是一款流行的工作流管理系统,它允许开发者设计、执行和管理业务流程。本篇将详细讲解如何安装并使用jbpm的流程设计...

    jbpm5.2学习1------安装与配置

    在提供的文档《jbpm入门实践-李鹏飞.doc》中,作者李鹏飞详细介绍了如何通过jbpm工作流设计器创建简单的请假流程。以下是简要步骤: 1. **流程设计**:使用Eclipse集成的jbpm插件或者jbpm提供的Web设计器,拖拽元素...

    jbpm学习指南-初学者的宝典

    3. 在线教程和视频:许多网站提供jbpm的入门教程和实战视频,辅助学习。 4. 开源项目:参与或研究基于jbpm的开源项目,实践提升技能。 通过深入学习和实践`jbpm-demo`,初学者将能够逐步理解并掌握jbpm的精髓,为...

    JBPM4.4入门开发实例

    版本4.4是JBPM的一个早期版本,尽管现在已经有更新的版本,但这个入门实例仍然对初学者具有很高的学习价值。在本文中,我们将探讨如何使用myeclipse7.5来搭建基于JBPM4.4的开发环境,并通过一个实际的请假流程实例...

    Jboss-Jbpm-Getting-Started.pdf

    《JBoss jBPM入门与实践》 一、引言:深入理解JBoss jBPM JBoss jBPM(jBusiness Process Management)是JBoss家族中的一个开源工作流引擎,用于实现业务流程管理(BPM)解决方案。它提供了一套完整的工具集,包括...

    jbpm-3.1.2.zip_jbpm_jbpm 3.1.2_jbpm-3.1.2.rar_jbpm3.1.2_工作流

    对于初学者来说,了解jBpm的架构和API,学习如何使用BPMN进行流程建模,以及掌握如何部署和运行流程实例是入门的关键。同时,深入研究jBpm的扩展性,如自定义工作项和监听器,可以进一步提高流程系统的适应性。此外...

    JBPM入门

    【JBPM入门】 JBPM,全称是Java Business Process Management,是一个开源的工作流管理系统,用于实现业务流程自动化。它提供了一套完整的工具集,包括设计、建模、执行和监控业务流程,支持BPMN2.0标准,使得业务...

    jBPM4入门基础环境配置

    **jBPM4入门基础环境配置** jBPM(Java Business Process Management)是一个开源的工作流管理系统,主要用于处理业务流程的建模、部署、执行和监控。jBPM4是其第四个主要版本,它提供了丰富的功能,包括流程定义、...

    jbpm开发工作流程管理

    为了更好地理解jBPM的工作原理,可以通过一个简单的示例来进行实际操作体验。 **1. 启动JBoss服务器** - 进入`jbpm-server`目录,运行`start.bat`脚本启动JBoss服务器。 - 查看控制台输出确认jBPM是否已正确启动。...

    JBPM4开发实例

    【JBPM4开发实例】是关于使用JBPM4进行工作流开发的一个具体实践教程,适合初学者进行入门学习。JBPM4是一个开源的工作流管理系统,它允许开发者设计、执行和管理业务流程。在这个实例中,我们将详细介绍如何设置...

Global site tag (gtag.js) - Google Analytics