1. jBPM的简介
jBPM是JBOSS下的一个开源java工作流项目，该项目提供eclipse插件，基于Hibernate实现数据持久化存储。
參考
http://www.jboss.com/products/jbpm
2. jBPM和myeclipse的冲突
当eclipse安装了myeclipse和jBPM时候，可能有冲突，详细表如今jBPM的流程设计器不能在eclipse中使用。
3. Hibernate连接mysql数据库的一般參数
以下的配置參数，依据须要能够改动：
jbpmtest是mysql中的schema的名字；
GBK是字符集，能够依据须要改动；
username=root，mysql数据库的用户名是root；
password=mysql，mysql数据库的用户密码是mysql；
hibernate.dialect=org.hibernate.dialect.MySQLDialect
hibernate.connection.driver_class=com.mysql.jdbc.Driver
hibernate.connection.url=jdbc:mysql://localhost/jbpmtest?useUnicode=true&characterEncoding=GBK
hibernate.connection.username=root
hibernate.connection.password=mysql
hibernate.show_sql=true
hibernate.c3p0.min_size=1
hibernate.c3p0.max_size=3
4. Hibernate连接Oracle数据库的一般參数
hibernate.dialect=org.hibernate.dialect.Oracle9Dialect
hibernate.connection.driver_class=oracle.jdbc.driver.OracleDriver
hibernate.connection.url= jdbc:oracle:thin:@localhost:1521:orcl hibernate.connection.username=jbpm
hibernate.connection.password=jbpm
5. 为jBPM创建数据库表等内容
5.1. 为mysql创建数据库以及数据内容
JbpmSessionFactory.buildJbpmSessionFactory().getJbpmSchema().dropSchema();
JbpmSessionFactory.buildJbpmSessionFactory().getJbpmSchema().createSchema();
这2个语针对mysq有效.
5.2. 为oralce创建数据库以及数据内容
JbpmSessionFactory.buildJbpmSessionFactory().getJbpmSchema().dropSchema();
JbpmSessionFactory.buildJbpmSessionFactory().getJbpmSchema().createSchema();
上面的语句对oralce无效。
模型文件夹jBPM/jbpm_database/jBPM_oralce10g.pdm 是jBPM的Oralce模型,包括相应的Sequence的信息.
须要在数据库中创建 Sequence name=hibernate_sequence
http://wiki.jboss.org/wiki/Wiki.jsp?page=JbpmOnOracle
5.3. 流程信息保存到数据库
JbpmSessionFactory factory = JbpmSessionFactory.buildJbpmSessionFactory();
JbpmSession session = factory.openJbpmSession();
GraphSession graphSession = session.getGraphSession();
session.beginTransaction();
/// new ProcessDefinition 实例
ProcessDefinition myProcessDefinition = null;
ProcessInstance processInstance = new ProcessInstance(processDefinition);
processInstance.getContextInstance().setVariable("myvar","xxx");
///
graphSession.saveProcessDefinition(myProcessDefinition);
session.commitTransaction();
session.close();
jBPM和Hibernate,MySQL的使用中会遇到字符集的问题.
须要注意几个地方。
5.4. 在Mysql安装过程指定字符集
在Mysql安装过程中指定对应的默认字符集是GBK
5.5. Hibernate.properties文件里的字符集设置
hibernate.connection.url=jdbc:mysql://localhost/jbpmtest?useUnicode=true&characterEncoding=GBK
5.6. hibernate.cfg.xml 文件里的字符集设置
<property name="hibernate.connection.url">jdbc:mysql://192.168.1.2/jbpmtest</property>
5.7. MySQL的配置文件的改动:
my.ini中 default-character-set=GBK
注意有2处须要改动
6. 为流程定义变量
分成3种流程变量
全局变量（全局流程变量）
全局暂时变量（全局流程暂时变量）
局部变量（流程某个接点内有效的变量）
@see org.jbpm.context.exe.ContextInstance
眼下还没有使用过局部变量（流程某个接点内有效的变量）
流程变量的定义
6.1. 流程变量的类型
· java.lang.String
· java.lang.Boolean
· java.lang.Character
· java.lang.Float
· java.lang.Double
· java.lang.Long
· java.lang.Byte
· java.lang.Short
· java.lang.Integer
· java.util.Date
· byte[]
· java.io.Serializable
· classes that are persistable with hibernate
全部基本类型的包裹类型，以及实现了Serializable的类型都能够作为流程參数变量使用，注意參数类不能是一个类的内部类或者属性类（除非包括參数类的类实现了Serializable接口）
參考 org.jbpm.context.exe.VariableInstance
6.2. 流程变量的使用
l 变量的定义和获取
void ContextInstance.setVariable(String variableName, Object value);
void ContextInstance.setVariable(String variableName, Object value, Token token);
Object ContextInstance.getVariable(String variableName);
Object ContextInstance.getVariable(String variableName, Token token);
l Variables can be deleted with
ContextInstance.deleteVariable(String variableName);
ContextInstance.deleteVariable(String variableName, Token token);
6.3. Variable lifetime
一个变量在被定义后，在变量从ContextInstance删除前，都能够被訪问。当变量被删除后，去获取该变量将返回为空。
6.4. 自己定义类的实例作为流程变量
假设一个类的实例要作为流程变量使用,该类须要实现java.io.Serializable接口,而且定义序列化版本号.
//一个能够作为流程变量使用的类
class Wdz implements Serializable{
//为类指定序列化版本
private static final long serialVersionUID = 1L;
private String name="wdz";
private int age=10;
public String toString(){
return "name="+name+",age="+age;
}
}
上面的样例中,假设把类Wdz作为类WdzParent内部类使用,然后当成流程变量使用,那类WdzParent必须 也实现Serializable接口,否则会有问题.
6.5. Transient variables
流程的历史变量是不能持久化的，作用范围是对整个流程全局有效的。
在ContextInstance类内部，採用的是一个Map来存储TransientVariable的信息
參考代码
org.jbpm.context.exe.ContextInstance 的源码。
基本的相关方法
public void deleteTransientVariable(java.lang.String name)
public void setTransientVariable(java.lang.String name,
java.lang.Object value)
public java.lang.Object getTransientVariable(java.lang.String name)
6.6. Variables overloading
当一个变量和流实例关联(变量名字=”wdz”,value=”test”)，假设在设置一个变量
(变量名字=”wdz”,value= new Integer(10)) ,那最后变量（变量名字=”wdz）的值是Integer(10)。
这称之为overload.
6.7. Variables overriding
假设父流程有变量A(值=”value1”),子流程又定义了变量A值=”value2”,那在子流程范围内，获取变量A的值，那结果是值=”value2”。这是遵循一般语言的局部变量在它的局部范围内override上级变量。
6.8. 流程变量的持久化
它依赖于流程实例的持久化，非TransientVariable随流程实例的持久化一起被保存。
保存在数据表jbpm_variableinstance
參考 org.jbpm.context.exe.VariableInstance
6.9. Customizing variable persistence (能够进一步了解)
User java object <---> converter <---> variable instance
也就是自己定义类的持久化须要定义自己的converter和变量实例类
converter和变量实例类须要继承org.jbpm.context.exe.VariableInstance
converter须要实现org.jbpm.context.exe.Converter接口
一
工作流尽管还在不成熟的发展阶段，甚至还没有一个公认的规范标准。但其应用却已经在高速展开，这说明市场对工作流框架的需求是急迫而巨大的。
我们公司的后台短信管理系统涉及短信编发、领导层层审核等操作，这是一个比較典型的工作流系统。过去我们用的工作流引擎是 shark ，然后在使用后发现其过于庞大，后台数据库操作频繁而未进行优化，直接导致的后果就是前台操作缓慢。于是经研究决定，将工作流引擎由 shark 换成 jBPM 。
jBPM 之前是一个开源软件，后增加 JBoss 组织。正好我们公司也是用 JBoss 的。只是 jBPM 并没有绑定在 JBOSS 上， Tomcat 等也能够使用它。
jBPM 的正处在不断发展中，做为开源软件的特点，其设计变化往往非常大。所以一些过去的资料可能已经不适用了。于是作者依据自己的使用经验，又一次整理出这份文档，以备学习參考。
注：本文使用的 jBPM 版本号为 3.1.1
环境准备
1、安装JDK
全部 JAVA 开发第一个须要安装的，没什么好说的。记得把系统变量 JAVA_HOME 设上。
2、安装Ant
Ant 是使用 jBPM 必须的一个工具。 jBPM 中的非常多操作都要用到 Ant 。
安装方法：
（ 1 ）先下载： http://archive.apache.org/dist/ant/binaries/ ，选一个如： apache-ant-1.6.5-bin.zip 。
（ 2 ）解压到 D:/ant （当然其它文件夹也能够）。
（ 3 ）设置例如以下系统变量： ANT_HOME=d:/ant 。
（ 4 ）把 %ANT_HOME%/bin 增加到系统变量 PATH 中。
3、安装Eclipse
Eclipse 不是开发 jBPM 必须的工具，但它是对 jBPM 开发非常有帮助的工具，特别是 jBPM 提供了一个 Eclipse 插件用来辅助开发 jBPM 。关于 Eclipse 的安装不赘述了，本文用的版本号是： Eclipse3.2
安装 jBPM
jBPM 的下载地址： http://www.jboss.com/products/jbpm/downloads
l JBoss jBPM 是 jBPM 的软件包
l JBoss jBPM Starters Kit 是一个综合包，它包含了 jBPM 软件包、开发插件、一个配置好了的基于 JBoss 的 jBPM 演示样例、一些数据库配置文件演示样例。
l JBoss jBPM Process Designer Plugin 是辅助开发 jBPM 的 Eclipse 插件。
l JBoss jBPM BPEL Extension jBPM 关于 BPEL 的扩展包
本指南选择下载： JBoss jBPM Starters Kit 。下载后解压到 D:/jbpm-starters-kit-3.1 ，文件夹下含有五个子文件夹：
l jbpm jBPM 的软件包
l jbpm-bpel 仅仅含有一个网页
l jbpm-db 各种数据库 hibernate 配置文件演示样例，有些还包括了对应的 jdbc 驱动程序。
l jbpm-designer 辅助开发 jBPM 的 Eclipse 插件，详细在 jbpm-gpd-feature 子文件夹中
l jbpm-server 一个已经配置好了的基于 JBoss 的 jBPM 演示样例 .
感觉下工作流
前面我们说了，在 JBoss jBPM Starters Kit 的 jbpm-server 文件夹是一个已经配置好的了 jBPM 演示样例，那么让我们来感觉一下 jBPM 做出的东西吧。
双击 jbpm-server 文件夹下的 start.bat 文件，启动 JBoss 服务。这时会打开一个 DOS 窗体，启动完毕后，日志会不断输出，当中最后一句是“ 13:55:39,937 DEBUG [StaticNotifier] going to wait for (CMD_EXECUTOR, [email protected]) ”，这表示 jBPM 在開始工作了，它不断进行轮询。
打开网页： http://localhost:8080/jbpm/ 得到例如以下画面 
这是一个已经用 jBPM 开发好的用户定单流程，具有下单、审核、估价等流程。它所用的数据库是一个内置的数据库。
以 cookie monster 用户登录，选择“ create new web sale order ”能够创建一个定单。例如以下图所看到的，在图左边是填写的定单情况，右边一整个定货流程的示意图，红色框表示流程进行到哪一步了。填写好定单好，选择“ Save and Close Task ”，完毕定单提交。 
选择右上角的“ Login as another user ”以另外一个username ernie 登录。这时能够看到 ernie 用户的任务列表中多了一项。 
点进去后，显演示样例如以下画面。这个演示样例对中文的支持不好，全都显示成了 unicode 码了。无论这什么多，反正知道是这么回事即可了。在 comment 项填写意见，选 OK button，进入到下一步。假设选择 more info needed button，则打回给 cookie monster 用户改动定单。 
以下的流程，这里就不再赘述了。在这个非常标准的工作流演示样例中，我们基本能够看到 jBPM 的应用范围还是比較广的。并且从这个演示样例，我们是看不出有 jBPM 的，也就是说 jBPM 在后台起着作用。
从这个样例，还看不出 jBPM 的优势。只是，假设在一个流程不确定，常常须要变动的项目中， jBPM 的优点将会显然出来。应用 jBPM 后，改变流程仅仅需改变流程描写叙述文件，这将在后面的内容提到。
这是一个已做好的演示样例，接下来我们将仿造这个实例来开发一个请假流程。
4 数据库初始化
jBPM 须要数据库支持， jBPM 会把自己的一个初始化数据存储到数据库，同一时候工作流的数据也是存储到数据库中的。 jBPM 使用 Hibernate 来做为自己的存储层，因此仅仅要是 Hibernate 支持的数据库， jBPM 也就支持。
本文先以 MySQL 为例，然后再以 Oracle 为例，来谈谈 jBPM 的数据库初始化操作。
注：在上面的 JBoss 自带的演示样例中，并没有设置数据库，那是由于 jBPM 默认使用的是内存数据库 hsqldb 。
4.1 MySQL
1 、首先安装 MySQL 。
MySQL 的安装比較简单，网上也有非常多文章，本文不再赘述。本指南所用 MySQL 版本号为 MySQL 4.1 （ for windows ）。再找一个 MySQL client，目的是方便查看数据库中的数据，本文推荐使用 MySQL 站点上免费提供的“ MySQL Query Brower ”，当然你用其它的client也行，比方 MySQL-Front 。
2 、建库
MySQL 中创建一个库，库名： jbpm
3 、生成建表的 SQL 语句并建表
将 jbpm-starters-kit-3.1.1 下的子文件夹 jbpm 改名为 jbpm.3 ，否则在运行以下的 ant 命令时会报如 jbpm.3 文件夹不存在的错误：
D:/jbpm-starters-kit-3.1.1/jbpm-db/build.xml:361: The following error occurred while executing this line:
D:/jbpm-starters-kit-3.1.1/jbpm-db/build.xml:68: Basedir D:/jbpm-starters-kit-3.1.1/jbpm.3 does not exist
在 DOS 窗下，进入 D:/jbpm-starters-kit-3.1.1/jbpm-db 文件夹，运行例如以下命令：
ant mysql.scripts
运行成功后，在 D:/jbpm-starters-kit-3.1.1/jbpm-db/build/mysql/scripts 文件夹里生成了四个 sql 文件，它们做什么用的一看名字就知道了。在 MySQL client中运行“ mysql.create.sql ”脚本，这样将在 jbpm 库中创建一个个的数据表。
4.2 Oracle
先安装好 Oracle server。我们公司有现存的 Oracle server，也提供给了我一个属于我自己的username，一登录就能够随意在我的库之下创建表了。所以这一步就省了，没有的自个先装好吧。
訪问 Oracle 推荐用“ PLSQL Developer ”。只是要连接 Oracle 还要在本机上装上 Oracle 自己的client程序，里面提供了 JDBC 包和一些配置。要连接server还得配置一下，我一般都是不用 GUI 而直接改 tnsnames.ora 文件，在我的电脑里此文件的文件夹地址是： D:/oracle/ora92/network/ADMIN/tnsnames.ora ，内容例如以下 ( 两面有两个配置了 ) ：
# TNSNAMES.ORA Network Configuration File: E:/oracle/ora92/network/admin/tnsnames.ora
# Generated by Oracle configuration tools.
WXXRDB_192.168.3.2 =
(DESCRIPTION =
(ADDRESS_LIST =
(ADDRESS = (PROTOCOL = TCP)(HOST = 192.168.3.2)(PORT = 1521))
)
(CONNECT_DATA =
(SID = wxxrDB)
(SERVER = DEDICATED)
)
)
WXXRDB_192.168.4.2 =
(DESCRIPTION =
(ADDRESS_LIST =
(ADDRESS = (PROTOCOL = TCP)(HOST = 192.168.4.2)(PORT = 1521))
)
(CONNECT_DATA =
(SID = wxxrDB)
(SERVER = DEDICATED)
)
)
前面都是 Oracle 的一些知识，不会的 Google 一下吧。最后配置好后，用 PLSQL Developer 输入你的username和password联接到 Oracle ，就算 OK 了。
參考上面 MySQL 的步骤，基本一样：
（1） 将 jbpm 改名为 jbpm.3 (或者改动jbpm-db文件夹下的build.properties文件)
（2） 再运行 ant oracle.scripts
（3） 用 jbpm-db/build/oracle/scripts 文件夹的 oracle.create.sql 脚本，在 Oracle 中生成 jBPM 的全部表。在“ PLSQL Developer ”中能够新建一个 Command Windows 窗体然后输入命令： @D:/jbpm-starters-kit-3.1.1/jbpm-db/build/oracle/scripts/oracle.create.sql
(假设报错,就将报错的地方凝视掉)
5 安装 jBPM 的 Eclipse 开发插件
有个辅助工具开发起来方便一点，仅仅只是如今 jBPM 的开发工具插件功能还不算太强，也就一个“项目创建向导”的功能，让你：
（1）不用再去配置 classpath 库的引用了
（2）直接得到了一个 jBPM 的项目初始结构
事实上吧，开发 jBPM 也不须要什么插件工具，在熟练了以后，库引用了项目初始结构都能够手工创建。
插件不用再去下载了， jbpm-starters-kit-3.1.1 包里就有，文件夹地址例如以下： D:/jbpm-starters-kit-3.1.1/jbpm-designer/jbpm-gpd-feature/eclipse ，插件的安装方式是链接式还是直接复制式，任选吧。不懂的就去看看《 Eclipse 从入门精通》这本书，在前面章节都有讲到。另外，注明一下 Eclipse 的版本号我是用 3.2 ，插件和 Eclispe 版本号相关的，要注意了。
假设成功安装，则 Eclipse 首选项里多了一个 JBoss jBPM ，另外我们也须要到这个 jBPM 的首选项里做一些配置工作――指定 jBPM 的安装路径（例如以下图所看到的）。这个配置主要是为了找到 jbpm 下的各种 jar 包，好让 Eclipse 设置项目的库引用。本文指向路径是 d:/jbpm-starters-kit-3.1.1/jbpm.3 
6 jBPM 的 Hello World
6.1 新建jBPM项目
主菜单“文件－＞新建－＞项目”，在弹出的对话框里，有“ Process Project ”项，例如以下图所看到的： 
选上好，单击“下一步”，起个名“ myjbpm ”，然后就能够单击“完毕”了。然后就生成了例如以下图所看到的的一个项目结构： 
这个项目和通常 Eclipse 的项目结构有点不同，只是这是一个如今很流行的项目结构， src/java 存放源文件， test/java 存放对应的 JUnit 单元測试代码。假设你用 Maven 来编译构建项目，对这样的文件夹结构一定不陌生。
项目创建起了，介绍一下里面的文件吧：
l MessageActionHandler ，自己主动生成的一个 ActionHandler 。不想要能够删掉。
l ehcache.xml cache 的配置文件，里面有非常具体解释的英文说明。没有必要能够不用改它。
l hibernate.cfg.xml jBPM 是用 Hibernate 进行工作流的数据存储的，这个就是 Hibernate 的配置文件。后面我们将讲到怎样配置这个文件。
l jbpm.cfg.xml jbpm 本身的配置文件。如今是空的，它用的是缺省配置，你想知道有哪些配置就去看这个文件 D:/jbpm-starters-kit-3.1.1/jbpm.3/src/java.jbpm/org/jbpm/default.jbpm.cfg.xml
l log4j.properties 这个是日志 API 包 log4j 的配置文件，用过 log4j 的都知道。
l SimpleProcessTest.java 这个是对最重要的流程配置文件的 processdefinition.xml 单元測试代码。这里表扬一点， jBPM 的优良设计使得它的可測试性很之高，喜欢写 t 单元測试的人有福了。
l gpd.xml 用于生成流程图的定义文件。都是一些方框的坐标和长宽
l processdefinition.xml 这个是对最重要的流程配置文件，以后写流程要常常和它打交道。
l processimage.jpg 一个流程图
从项目结构来看，我们没有看到 JSP 网页程序，也没有看到 GUI client程序，这些代码都是要我们以后开发中来写的。但本文不准备用 JSP 、 GUI （ Swing 、 SWT ）来做演示样例，而是用 JUnit 代码来做使用 jBPM client来演示。由于 jBPM 实际上是一个后台框架，至于前台是 JSP 还是 Swing 还是无界面的 java.class 都是无关紧要的。在教程里用无界面的 java.class 来做client则更方便一些，假设进一步採用 JUnit ，则这种 java.class 同一时候还具备了单元測试的功能。以后就是用 JSP 写了 WEB 页面，我们还是能够用这些 JUnit 程序来做单元測试，避免了频繁的鼠标点按 WEB 页面这种力气活。所以在 jBPM 自带的英文教程里都是一个 JUnit 程序，不仔佃看还真摸不着头脑。
6.2 改动hibernate.cfg.xml
hibernate.cfg.xml 的默认设置是用 HSQL ，这是一个内存数据库，这样的内存数据库用来取代项目实际所用的数据库来做单元測试挺不错的。只是我们这里是要试试用 MySQL 、 Oracle ，那就改一下设置吧。
注：配置值可參考 D:/jbpm-starters-kit-3.1.1/jbpm-db 相应子文件夹下的 hibernate.properties 文件。
1 、 MySQL 的更改例如以下：
<property name="hibernate.dialect">org.hibernate.dialect.MySQLDialect</property>
<property name="hibernate.connection.driver_class">com.mysql.jdbc.Driver</property>
<property name="hibernate.connection.url">jdbc:mysql://localhost:3306/jbpm</property>
<property name="hibernate.connection.username">root</property>
<property name="hibernate.connection.password">123456</property>
2 、 Oracle 的更改例如以下：
<property name="hibernate.dialect">org.hibernate.dialect.OracleDialect</property>
<property name="hibernate.connection.driver_class">oracle.jdbc.driver.OracleDriver</property>
<property name="hibernate.connection.url">jdbc:oracle:thin:@192.168.123.10:1521:wxxrDB</property>
<property name="hibernate.connection.username">chengang</property>
<property name="hibernate.connection.password">chengang</property>
假设你装了 Oracle 的client，而且 D:/oracle/ora92/network/ADMIN/tnsnames.ora 里做了例如以下的设置
WXXRDB_192.168.123.10 =
(DESCRIPTION =
(ADDRESS_LIST =
(ADDRESS = (PROTOCOL = TCP)(HOST = 192.168.123.10)(PORT = 1521))
)
(CONNECT_DATA =
(SID = wxxrDB)
(SERVER = DEDICATED)
)
)
则 Oracle 的 hibernate.connection.url 项也能够设为： jdbc:oracle:oci:@WXXRDB_192.168.123.10
6.3 完好库引用
尽管 jBPM 在创建项目之初给我们设置好了库引用，例如以下图 
但后面执行时还是报一些 NoClassDefFoundError 异常，如没有对 hibernate3.jar 的引用导致以下的错误
java.lang.NoClassDefFoundError: org/hibernate/Session
at org.jbpm.persistence.db.DbPersistenceServiceFactory.openService(DbPersistenceServiceFactory.java:55)
at org.jbpm.svc.Services.getService(Services.java:136)
.......
所以我们要为本文的实例完好库引用。主要是把 MySQL 和 Oracle 的 JDBC 库、以及 Hibernate 的 hibernate3.jar 增加到项目的库引用中。
（1） 找到缺少的 jar 包
l mysql 的 jdbc 包，在 D:/jbpm-starters-kit-3.1.1/jbpm-db/mysql/lib 文件夹里
l oracle 的 jdbc 包， jbmp 中没有包括（可能是没拿到 oracle 授权），我们能够自已去 oracle 站点上下载，或者去 oracle 安装文件夹 D:/oracle/ora92/jdbc/lib 找 ojdbc14.jar （我们公司用的是 Oracle9i ）
l Hibernate3.jar 在文件夹 D:/jbpm-starters-kit-3.1.1/jbpm.3/lib/hibernate 里。
（2） 在项目里创建一个 lib 文件夹，将这三个 jar 拷贝到 lib 文件夹。
（3） 例如以下图设置三 jar 包的库引用
6.4 開始HellorWorld
这里是一个非常easy的请假流程，请假人提交假单给经理审批，经理审批后结束。要说明的是，这个流程并不严谨，比方经理不通过流程应该到哪？只是这并不防碍拿它来做演示样例，螃蟹还得一个一个的吃。我们先拿这一杆子捅究竟的流程做一个最简单的演示样例，从总体上对 jBPM 工作流开发有概念先。然后我们再慢慢丰富。
1 、定义流程
流程的定义文件是 processdefinition.xml ，这个是一个重要文件， jBPM 的非常大一部份内容都是关于它的。在这里我们把原来自己主动生成的内容，稍做修改：
<?xml version="1.0" encoding="GBK"?>
<process-definition xmlns="urn:jbpm.org:jpdl-3.1" name="helloworld">
<!-- 申请 -->
<start-state name="request">
<task>
<controller>
<variable name="name" />
<variable name="day" />
<variable name="note" />
</controller>
</task>
<!-- 流程转向 -->
<transition name="to_confirm" to="confirm">
<action name="requestAction"
class ="cn.com.chengang.jbpm.RequestAction">
<reason> 我要请假 </reason>
</action>
</transition>
</start-state>
<!-- 审批 -->
<state name="confirm">
<transition name="to_end" to="end">
<action name="finishAction"
class ="cn.com.chengang.jbpm.ConfirmAction" />
</transition>
</state>
<!-- 结束 -->
<end-state name="end" />
</process-definition>
说明：
流程的名称改成了 helloworld 。（呵呵，也就是这里和 helloworld 有关了）
<controller> 标签定义了三个数据：姓名、请假天数、说明。
<transition> 标签定了 request 节点的一个流程转向，这里是转到 confirm 节点。
<action> 标签定义了流程由一个节点转到还有一个节点时，所要运行的动作，动作封装在一个 ActionHandler 类中。比方这里当 request 到 confirm 结点时将运行 RequestAction 类的 execute 方法。
FinishAction 以下另一个 <reason> （请假理由），它相应于 FinshAction 的属性 String reason 。
2 、 编写 ActionHandler
在上面 processdefinition.xml 里我们定义了两个 ActionHandler ： RequestAction 、 ConfirmAction 。其代码例如以下：
package cn.com.chengang.jbpm;
import org.jbpm.graph.def.ActionHandler;
import org.jbpm.graph.exe.ExecutionContext;
public class RequestAction implements ActionHandler {
private static final long serialVersionUID = 1L;
private String reason;
public String getReason() {
return reason;
}
public void setReason(String reason) {
this .reason = reason;
}
public void execute(ExecutionContext context) throws Exception {
context.getContextInstance().setVariable("note", reason);
}
}
说明： ExecutionContext 是一个贯通流程的容器。它是个大宝箱，里面啥玩意都有，后面将更深入的提到。这里的 reasion 就是 processdefinition.xml 中的 ” 我要请假 ”
package cn.com.chengang.jbpm;
import org.jbpm.graph.def.ActionHandler;
import org.jbpm.graph.exe.ExecutionContext;
public class ConfirmAction implements ActionHandler {
private static final long serialVersionUID = 1L;
public void execute(ExecutionContext context) throws Exception {
context.getContextInstance().setVariable("note", " 准假 " );
}
}
OK ，后台的程序就算写完了（前台client的程序还没写），以下開始部署。
6.5 部署processdefinition.xml
我们要把 processdefinition.xml 的流程定义的数据部署到数据库中，由于 jBPM 在正式执行的时候不是去读 processdefinition.xml 文件，而是去读数据库中的流程定义。 这里写了一个个 JUnit 程序来部署 processdefinition.xml ，当然你用普通的 Java Main 也能够。
package com.sample;
import java.io.FileInputStream;
import java.io.FileNotFoundException;
import java.io.InputStream;
import junit.framework.TestCase;
import org.jbpm.JbpmConfiguration;
import org.jbpm.JbpmContext;
import org.jbpm.graph.def.ProcessDefinition;
/**
* 部署 processdefinition.xml
*
* @author chengang
*
*/
public class DeployProcessTest extends TestCase {
/**
* 在本方法运行完成后，检查 jbpm_processdefinition 表会多了一条记录
*
* @throws FileNotFoundException
*/
public void testDeployProcessDefinition() throws FileNotFoundException {
// 从 jbpm.cfg.xml 取得 jbpm 的配置
JbpmConfiguration config = JbpmConfiguration.getInstance();
// 创建一个 jbpm 容器
JbpmContext jbpmContext = config.createJbpmContext();
// 由 processdefinition.xml 生成相相应的流程定义类 ProcessDefinition
InputStream is = new FileInputStream("processes/simple/processdefinition.xml");
ProcessDefinition processDefinition = ProcessDefinition.parseXmlInputStream(is);
// 利用容器的方法将流程定义数据部署到数据库上
jbpmContext.deployProcessDefinition(processDefinition);
// 关闭 jbpmContext
jbpmContext.close();
}
}
执行此程序，在控制台打印了一些日志，通过。假设出错，仔佃阅读出错信息以推断错误原因，并确定你依照前面两节：“改动 hibernate.cfg.xml ”和“完好库引用”的内容做好了设置。
(假设抛出异常09:32:43,791 [main] ERROR ErrorCounter : *** ERROR: line 3:45: expecting "set", found ‘t‘
09:32:43,822 [main] ERROR ErrorCounter : *** ERROR: line 3:45: expecting "set", found ‘t‘
09:32:43,869 [main] ERROR ErrorCounter : *** ERROR: line 3:50: unexpected token: t
09:32:43,931 [main] ERROR SessionFactoryImpl : Error in named query: SchedulerSession.deleteTimersForProcessInstance
org.hibernate.hql.ast.QuerySyntaxError: unexpected token: t near line 3, column 50 [
delete from org.jbpm.scheduler.exe.Timer t
where t.processInstance = :processInstance
]
at org.hibernate.hql.ast.ErrorCounter.throwQueryException(ErrorCounter.java:63)
at org.hibernate.hql.ast.QueryTranslatorImpl.parse(QueryTranslatorImpl.java:215)
at org.hibernate.hql.ast.QueryTranslatorImpl.doCompile(QueryTranslatorImpl.java:127)
at org.hibernate.hql.ast.QueryTranslatorImpl.compile(QueryTranslatorImpl.java:83)
at org.hibernate.impl.SessionFactoryImpl.getQuery(SessionFactoryImpl.java:427)
at org.hibernate.impl.SessionFactoryImpl.checkNamedQueries(SessionFactoryImpl.java:388)
at org.hibernate.impl.SessionFactoryImpl.<init>(SessionFactoryImpl.java:291)
at org.hibernate.cfg.Configuration.buildSessionFactory(Configuration.java:1005)
at org.jbpm.persistence.db.DbPersistenceServiceFactory.getSessionFactory(DbPersistenceServiceFactory.java:93)
at org.jbpm.persistence.db.DbPersistenceService.getSessionFactory(DbPersistenceService.java:74)
at org.jbpm.persistence.db.DbPersistenceService.getSession(DbPersistenceService.java:78)
at org.jbpm.persistence.db.DbPersistenceService.getGraphSession(DbPersistenceService.java:201)
at org.jbpm.JbpmContext.getGraphSession(JbpmContext.java:427)
at org.jbpm.JbpmContext.deployProcessDefinition(JbpmContext.java:166)
at com.hanxr.jbpm.action.DeployProcessTest.testDeployProcessDefinition(DeployProcessTest.java:35)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:39)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:25)
at java.lang.reflect.Method.invoke(Method.java:324)
at junit.framework.TestCase.runTest(TestCase.java:154)
at junit.framework.TestCase.runBare(TestCase.java:127)
at junit.framework.TestResult$1.protect(TestResult.java:106)
at junit.framework.TestResult.runProtected(TestResult.java:124)
at junit.framework.TestResult.run(TestResult.java:109)
at junit.framework.TestCase.run(TestCase.java:118)
at junit.framework.TestSuite.runTest(TestSuite.java:208)
at junit.framework.TestSuite.run(TestSuite.java:203)
at org.eclipse.jdt.internal.junit.runner.RemoteTestRunner.runTests(RemoteTestRunner.java:478)
at org.eclipse.jdt.internal.junit.runner.RemoteTestRunner.run(RemoteTestRunner.java:344)
at org.eclipse.jdt.internal.junit.runner.RemoteTestRunner.main(RemoteTestRunner.java:196)
Caused by: line 3:50: unexpected token: t
at org.hibernate.hql.antlr.HqlBaseParser.deleteStatement(HqlBaseParser.java:242)
at org.hibernate.hql.antlr.HqlBaseParser.statement(HqlBaseParser.java:139)
at org.hibernate.hql.ast.QueryTranslatorImpl.parse(QueryTranslatorImpl.java:209)
... 28 more
09:32:43,947 [main] ERROR SessionFactoryImpl : Error in named query: SchedulerSession.suspendTimersForToken
org.hibernate.hql.ast.QuerySyntaxError: expecting "set", found ‘t‘ near line 3, column 45 [
update org.jbpm.scheduler.exe.Timer t
set t.isSuspended = true
where t.token = :token
]
at org.hibernate.hql.ast.ErrorCounter.throwQueryException(ErrorCounter.java:63)
at org.hibernate.hql.ast.QueryTranslatorImpl.parse(QueryTranslatorImpl.java:215)
at org.hibernate.hql.ast.QueryTranslatorImpl.doCompile(QueryTranslatorImpl.java:127)
at org.hibernate.hql.ast.QueryTranslatorImpl.compile(QueryTranslatorImpl.java:83)
at org.hibernate.impl.SessionFactoryImpl.getQuery(SessionFactoryImpl.java:427)
at org.hibernate.impl.SessionFactoryImpl.checkNamedQueries(SessionFactoryImpl.java:388)
at org.hibernate.impl.SessionFactoryImpl.<init>(SessionFactoryImpl.java:291)
at org.hibernate.cfg.Configuration.buildSessionFactory(Configuration.java:1005)
at org.jbpm.persistence.db.DbPersistenceServiceFactory.getSessionFactory(DbPersistenceServiceFactory.java:93)
at org.jbpm.persistence.db.DbPersistenceService.getSessionFactory(DbPersistenceService.java:74)
at org.jbpm.persistence.db.DbPersistenceService.getSession(DbPersistenceService.java:78)
at org.jbpm.persistence.db.DbPersistenceService.getGraphSession(DbPersistenceService.java:201)
at org.jbpm.JbpmContext.getGraphSession(JbpmContext.java:427)
at org.jbpm.JbpmContext.deployProcessDefinition(JbpmContext.java:166)
at com.hanxr.jbpm.action.DeployProcessTest.testDeployProcessDefinition(DeployProcessTest.java:35)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:39)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:25)
at java.lang.reflect.Method.invoke(Method.java:324)
at junit.framework.TestCase.runTest(TestCase.java:154)
at junit.framework.TestCase.runBare(TestCase.java:127)
at junit.framework.TestResult$1.protect(TestResult.java:106)
at junit.framework.TestResult.runProtected(TestResult.java:124)
at junit.framework.TestResult.run(TestResult.java:109)
at junit.framework.TestCase.run(TestCase.java:118)
at junit.framework.TestSuite.runTest(TestSuite.java:208)
at junit.framework.TestSuite.run(TestSuite.java:203)
at org.eclipse.jdt.internal.junit.runner.RemoteTestRunner.runTests(RemoteTestRunner.java:478)
at org.eclipse.jdt.internal.junit.runner.RemoteTestRunner.run(RemoteTestRunner.java:344)
at org.eclipse.jdt.internal.junit.runner.RemoteTestRunner.main(RemoteTestRunner.java:196)
Caused by: line 3:45: expecting "set", found ‘t‘
at antlr.Parser.match(Parser.java:211)
at org.hibernate.hql.antlr.HqlBaseParser.setClause(HqlBaseParser.java:337)
at org.hibernate.hql.antlr.HqlBaseParser.updateStatement(HqlBaseParser.java:183)
at org.hibernate.hql.antlr.HqlBaseParser.statement(HqlBaseParser.java:133)
at org.hibernate.hql.ast.QueryTranslatorImpl.parse(QueryTranslatorImpl.java:209)
... 28 more
09:32:43,947 [main] ERROR SessionFactoryImpl : Error in named query: SchedulerSession.resumeTimersForToken
org.hibernate.hql.ast.QuerySyntaxError: expecting "set", found ‘t‘ near line 3, column 45 [
update org.jbpm.scheduler.exe.Timer t
set t.isSuspended = false
where t.token = :token
]
at org.hibernate.hql.ast.ErrorCounter.throwQueryException(ErrorCounter.java:63)
at org.hibernate.hql.ast.QueryTranslatorImpl.parse(QueryTranslatorImpl.java:215)
at org.hibernate.hql.ast.QueryTranslatorImpl.doCompile(QueryTranslatorImpl.java:127)
at org.hibernate.hql.ast.QueryTranslatorImpl.compile(QueryTranslatorImpl.java:83)
at org.hibernate.impl.SessionFactoryImpl.getQuery(SessionFactoryImpl.java:427)
at org.hibernate.impl.SessionFactoryImpl.checkNamedQueries(SessionFactoryImpl.java:388)
at org.hibernate.impl.SessionFactoryImpl.<init>(SessionFactoryImpl.java:291)
at org.hibernate.cfg.Configuration.buildSessionFactory(Configuration.java:1005)
at org.jbpm.persistence.db.DbPersistenceServiceFactory.getSessionFactory(DbPersistenceServiceFactory.java:93)
at org.jbpm.persistence.db.DbPersistenceService.getSessionFactory(DbPersistenceService.java:74)
at org.jbpm.persistence.db.DbPersistenceService.getSession(DbPersistenceService.java:78)
at org.jbpm.persistence.db.DbPersistenceService.getGraphSession(DbPersistenceService.java:201)
at org.jbpm.JbpmContext.getGraphSession(JbpmContext.java:427)
at org.jbpm.JbpmContext.deployProcessDefinition(JbpmContext.java:166)
at com.hanxr.jbpm.action.DeployProcessTest.testDeployProcessDefinition(DeployProcessTest.java:35)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:39)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:25)
at java.lang.reflect.Method.invoke(Method.java:324)
at junit.framework.TestCase.runTest(TestCase.java:154)
at junit.framework.TestCase.runBare(TestCase.java:127)
at junit.framework.TestResult$1.protect(TestResult.java:106)
at junit.framework.TestResult.runProtected(TestResult.java:124)
at junit.framework.TestResult.run(TestResult.java:109)
at junit.framework.TestCase.run(TestCase.java:118)
at junit.framework.TestSuite.runTest(TestSuite.java:208)
at junit.framework.TestSuite.run(TestSuite.java:203)
at org.eclipse.jdt.internal.junit.runner.RemoteTestRunner.runTests(RemoteTestRunner.java:478)
at org.eclipse.jdt.internal.junit.runner.RemoteTestRunner.run(RemoteTestRunner.java:344)
at org.eclipse.jdt.internal.junit.runner.RemoteTestRunner.main(RemoteTestRunner.java:196)
Caused by: line 3:45: expecting "set", found ‘t‘
at antlr.Parser.match(Parser.java:211)
at org.hibernate.hql.antlr.HqlBaseParser.setClause(HqlBaseParser.java:337)
at org.hibernate.hql.antlr.HqlBaseParser.updateStatement(HqlBaseParser.java:183)
at org.hibernate.hql.antlr.HqlBaseParser.statement(HqlBaseParser.java:133)
at org.hibernate.hql.ast.QueryTranslatorImpl.parse(QueryTranslatorImpl.java:209)
... 28 more
则改动JBossIDE-1.5.1.GA-ALL/eclipse/plugins/org.jbpm.core_3.0.8.1/build/jbpm-3.1-beta3.jar/org/jbpm/db/hibernate.queries.hbm.xml文件
将
<query name="SchedulerSession.deleteTimersForProcessInstance">
<![CDATA[
delete from org.jbpm.scheduler.exe.Timer t
where t.processInstance = :processInstance
]]>
</query>
<query name="SchedulerSession.suspendTimersForToken">
<![CDATA[
update org.jbpm.scheduler.exe.Timer t
set t.isSuspended = true
where t.token = :token
]]>
</query>
<query name="SchedulerSession.resumeTimersForToken">
<![CDATA[
update org.jbpm.scheduler.exe.Timer t
set t.isSuspended = false
where t.token = :token
]]>
</query>
改为:
<query name="SchedulerSession.deleteTimersForProcessInstance">
<![CDATA[
delete from org.jbpm.scheduler.exe.Timer
where processInstance = :processInstance
]]>
</query>
<query name="SchedulerSession.suspendTimersForToken">
<![CDATA[
update org.jbpm.scheduler.exe.Timer
set isSuspended = true
where token = :token
]]>
</query>
<query name="SchedulerSession.resumeTimersForToken">
<![CDATA[
update org.jbpm.scheduler.exe.Timer
set isSuspended = false
where token = :token
]]>
</query>
)
6.6 从数据库中的查看部署效果
不管是 MySQL 还是 Oracle ，查询 jbpm_processdefinition 表，你会发现多了一条记录，例如以下图 ( 以 PLSQL Developer 的显示为例 ) 
依次检查各表我们能够发现有例如以下变化： 
并由此简单推断出各表的作用，表中各字段的作用由字段名也能知晓一二。
|
jbpm_processdefinition |
一个流程定义文件相应一条记录，可记录多个流程定义文件，可记录一个流程定义文件的对个版本号。 |
|
jbpm_action |
记录 ActionHandler 的对象实例（以名称为标识） |
|
jbpm_delegation |
记录了 ActionHandler 全类名，以便于用反射方式来载入 |
|
jbpm_envent |
它的 transition 引用了 Jbpm_transition 表的 id ，再看其他字段，预计此表是表示流程转向事件的一个实例，或者是一个各表之间的联接表。 |
|
jbpm_node |
流程结点 |
|
jbpm_transition |
流程的转向定义 |
|
jbpm_variableaccess |
流程中携带的变量。 ACCESS 字段是这些变量的读写权限 |
jBPM 的client开发
有了前面的 HelloWorld 后台流程，我们就要開始client程序了。正如前面提到的，本文不写 JSP ，而改採用 JUnit 的形式，输出则用 System.out.println 。举一反三，知道在方法中输入及用 println 输出，在 JSP 和 SWING 等 GUI 界面还不是一样嘛。
这个 JUnit client，我们就借用创建项目时自己主动生成的 SimpleProcessTest.java 了，改写后例如以下：
package com.sample;
import junit.framework.TestCase;
import org.jbpm.JbpmConfiguration;
import org.jbpm.JbpmContext;
import org.jbpm.context.exe.ContextInstance;
import org.jbpm.graph.def.ProcessDefinition;
import org.jbpm.graph.exe.ProcessInstance;
public class SimpleProcessTest extends TestCase {
private JbpmConfiguration config = JbpmConfiguration.getInstance();
private JbpmContext ctx = config.createJbpmContext();
// helloworld 相应于 jbpm_processdefinition 表的 name 字段值，也即 processdefinition.xml 的 name
// 这个值得取比較耗时，实际项目里最好和“数据库的 JDBC 连接”一样，让它共享，不要频繁打开关闭。
private ProcessDefinition processDefinition = ctx.getGraphSession().findLatestProcessDefinition("helloworld");
public void testNewRequest() {
long id = newRequest();
System.out.println("id=" + id);
checkNewRequest(id);
confirmRequest(id);
checkconfirmRequest(id);
ctx.close();// 关闭 jbpm 容器
}
/**
* 创建一个请假单
*
* @return
*/
private long newRequest() {
// 创建一个新流程
ProcessInstance pi = processDefinition.createProcessInstance();
// 取得流程的数据环境
ContextInstance ci = pi.getContextInstance();
// 创建一张请假单
ci.setVariable("name", " 陈刚 www.chengang.com.cn" );
ci.setVariable("day", 2);
assertEquals(null, ci.getVariable("note"));
// 请假申请结束，转到下一个流程结点
pi.signal();
return pi.getId();
}
/**
* 检查请假单的数据
*
* @param id
*/
private void checkNewRequest(long id) {
// 从数据库提取原流程
ProcessInstance pi = ctx.loadProcessInstance(id);
// 取得流程的数据环境
ContextInstance ci = pi.getContextInstance();
// 创建一张请假单
assertEquals(" 陈刚 www.chengang.com.cn" , ci.getVariable("name"));
assertEquals(Integer.valueOf(2), ci.getVariable("day"));
assertEquals(" 我要请假 " , ci.getVariable("note"));
// 当前是结点为 confirm
assertEquals(pi.getRootToken().getNode().getName(), "confirm");
// 流程还没结束
assertFalse(pi.hasEnded());
}
/**
* 审批陈刚的请假申请
*
* @param id
*/
private void confirmRequest(long id) {
ProcessInstance pi = ctx.loadProcessInstance(id);
ContextInstance ci = pi.getContextInstance();
// 不通过
ci.setVariable("note", " 不准请假，继续加班 " );
// 审批结束，到下一个流程结点
pi.signal();
}
private void checkConfirmRequest(long id) {
ProcessInstance pi = ctx.loadProcessInstance(id);
ContextInstance ci = pi.getContextInstance();
// ConfirmAction 类在 signal 后运行，所以覆盖了经理的审批意见
assertEquals(" 准假 " , ci.getVariable("note"));
// 当前是结点为 end
assertEquals(pi.getRootToken().getNode().getName(), "end");
// 流程结束了
assertTrue(pi.hasEnded());
}
}