小菜毛毛技術(shù)分享

    首先當(dāng)你想學(xué)一個框架的時候一定是你要有項目來用他了，OK，那么你項目當(dāng)中的流程是什么你應(yīng)該清楚吧，那么當(dāng)你清楚了這些的時候我們就開始我們這個最簡單的例子吧。

    假如我們現(xiàn)在有這么一個例子，公司員工想報銷點出差費，那么他要將他的申請?zhí)峤唤o他的第一級領(lǐng)導(dǎo)——部門主管去審批，然后部門主管審批完了之后還要交給這個部門主管的上級公司老總進(jìn)行審批。那么針對這個簡單的流程，我們應(yīng)該從哪里下手呢？

    首先第一件事情就是寫流程定義文件，那么這個文件我們用什么來寫呢，他就是一個符合某個語法的xml文件，幸運的是jbpm給我們提供了一個集成的開發(fā)環(huán)境讓我們來用。

    首先去官網(wǎng)上下一個jbpm-jpdl-suite-3.2.GA包，解壓 后你會發(fā)現(xiàn)他里面有一個designer文件夾，那個里面就是我們寫流程定義文件的開發(fā)環(huán)境，他是一個eclipse的插件，但是好像他給我們的那個 eclipse版本有問題，建議大家從新下一個eclipse-SDK-3.2.1-win32.zip這個版本的eclipse，然后覆蓋他給我們提供 的那個。

    準(zhǔn)備工作做完了，那么我們就開始吧，首先我們打開解壓目錄下的designer文件夾中的designer.bat文件，他彈出一個eclipse，然后我們就用這個東西來開發(fā)我們的流程定義文件了。

    打開之后你就會看見一個他的小例子，不過我們不去用他，我們自己新建一個工程。右鍵-new-other-jBoss jbpm-process project。這個時候你會看見他彈出一個對話框，輸入你的工程名字，然后點擊next，這個時候你會發(fā)現(xiàn)他已經(jīng)把jbpm加載進(jìn)去了，記住要選中Generate simple ......。

    工程建立完了，我們開始建立我們的流程定義文件。在工程里面你會發(fā)現(xiàn)src/main/jpdl這個source folder，然后你會看見他里面已經(jīng)有了一個流程定義文件了，但是我們不去用他的，我們自己建立一個，右鍵src/main/jpdl，然后new- other-jBoss jbpm-process definition。這個時候他就會彈出一個對話框，起一個你要寫的流程定義文件的名字輸入進(jìn)去，OK，可以了。這個時候你打開你建立的那個文件夾，里面就有processdefinition.xml文件，ok，打開他。

    在右面的圖里面你就可以看到一張什么都沒有的白紙，我們看看這部分左面的那些東西，什么start啊，end啊，tasknode啊，fork 啊，join啊。那我們來解釋一下這是個什么東西呢，我們看看我們的需求，員工要寫一個報銷單，然后交給部門主管來處理，那么部門主管就應(yīng)該算是一個 tasknode，他就是一個任務(wù)節(jié)點。start和end其實就是一個虛狀態(tài)，當(dāng)我們寫完報銷單的時候我們就提交了，這個時候他就到了第一個 tasknode這個節(jié)點了。然后他審批完了還要交給總經(jīng)理審批，那么他又是一個tasknode，然后總經(jīng)理審批完了結(jié)束，ok，是一個end。

    start--》tasknode（部門主管審批）--》tasknode（總經(jīng)理審批）--》end。

    如果覺得看的有點模糊可以看看我傳上來的那個圖。然后你在這個試圖框的下面可以看到有個source，點擊一下，就會發(fā)現(xiàn)他已經(jīng)自動的給你生成xml代碼 了。但是這樣還是有點不夠，我們只是定義了一個tasknode節(jié)點，并沒有定義tasknode節(jié)點的任務(wù)由誰來做。那么我們還要定義一個 tasknode節(jié)點是由誰來做的：
    那么這段代碼是這么寫的：

<?xml version="1.0" encoding="UTF-8"?>
<process-definition
xmlns=""  name="test1">
<start-state name="start">
<transition name="" to="部門經(jīng)理審批"></transition>
</start-state>
<task-node name="部門經(jīng)理審批">
<task>
<assigment actorId="部門經(jīng)理"></assigment>
</task>
<transition name="" to="總經(jīng)理審批"></transition>
</task-node>
<task-node name="總經(jīng)理審批">
<task>
<assigment actorId="總經(jīng)理"></assigment>
</task>
<transition name="" to="end1"></transition>
</task-node>
<end-state name="end1"></end-state>
</process-definition>

    這樣的話我們的流程定義文件就定義完了，但是這只是把文件定義完了，系統(tǒng)并不知道啊，所以我們還要把我們的文件部署到系統(tǒng)中去，那么這個過程是這樣的：

    首先我們在src/main/java里面新建立一個包，然后建立一個class，隨便起個名字，就叫TestJBPM_01吧，那么在這個類里面我們要做的是什么呢？我們要先導(dǎo)入表，因為jbpm要運行就要用到很多個表，ok，那么我們這個里面導(dǎo)入表和hibernate導(dǎo)入表是差不多的，它的代碼是這樣的：

package com.jbpm.test;
import junit.framework.TestCase;
import org.jbpm.JbpmConfiguration;
public class TestJbpm_01 extends TestCase {
public void testJbpm(){
//創(chuàng)建jbpm數(shù)據(jù)庫表。他就像hibernate里面的哪個export一樣。實際上他就是hibernate里面的哪個export。
//應(yīng)為他映射了很多個表，所以我們就能創(chuàng)建那么多個表。
JbpmConfiguration.getInstance().createSchema();
}
}

然后呢我們就開始部署我們的流程定義文件，我們將這個文件當(dāng)中的內(nèi)容呢放到數(shù)據(jù)庫當(dāng)中去，當(dāng)我們以后再用的時候呢我們就隨時的將它加載出來。

package com.jbpm.test;
import junit.framework.TestCase;
import org.jbpm.JbpmConfiguration;
import org.jbpm.JbpmContext;
import org.jbpm.graph.def.ProcessDefinition;
public class TestJbpm_02 extends TestCase {
//jbpmConfiguration對象的創(chuàng)建
static JbpmConfiguration jbpmConfiguration = JbpmConfiguration.getInstance();
public void testJbpm(){
//然后我們把processDefinition里面相關(guān)的對象持久化到數(shù)據(jù)庫里面去。
//流程定義文件里面有很多個概念，他有node，有transition，還有processDefinition，那么我們不需要一個
//一個保存，jbpm把保存這么多對象的方法封裝成一個接口，叫做deployProcessDefinition。我們只要調(diào)用這個
//方法，傳一個processDefinition對象，我們就能將他們存入到數(shù)據(jù)庫里面去。
//這個首先第一步我們要得到一個processDefinition對象，然后我們把他部署到流程中去。
ProcessDefinition processDefinition = ProcessDefinition.parseXmlResource("testJBPM/testJbpm.xml");
//我們要存就必須獲得一個session對象，而jbpm已經(jīng)把session對象封裝到一個JbpmContext對象里面了。
//那么這個jbpmContext對象是怎么得到的呢，我們要先有一個jbpmConfiguration對象，我們要對數(shù)據(jù)庫進(jìn)行
//操作的時候一定要有jbpmConfiguration這個對象，用他來創(chuàng)建一個類似于hibernate當(dāng)中的session一樣的
//對象——jbpmContext。他是我們對數(shù)據(jù)庫所有的操作的一個接口。
JbpmContext jbpmContext = jbpmConfiguration.createJbpmContext();
try{
//然后部署的操作已經(jīng)由jbpmContext給我們創(chuàng)建好了，我們只需要調(diào)一下他的一個方法就可以了。
jbpmContext.deployProcessDefinition(processDefinition);
}finally{
//最后我們還要對他close一下，就像我們用hibernate的時候要close session一樣。
jbpmContext.close();
}
}
}

Ok，第二步我們也做完了，那么現(xiàn)在我們開始做第三步，也就是說，我們流程定義文件寫好了，現(xiàn)在我們的系統(tǒng)當(dāng)中有了這樣一個報銷流程，那么就開始 實際的去用她吧，一個人小報銷了，那么她就要寫一個報銷的申請，但是這個報銷的申請寫完了存到數(shù)據(jù)庫當(dāng)中了還不能算完了，應(yīng)該和我們的這個流程關(guān)聯(lián)起來 啊，那么她應(yīng)該怎么去關(guān)聯(lián)呢，嘿嘿，是這樣地：我們在建立這個申請單這個類的時候應(yīng)該定義一個processInstanceId屬性，她是一個long 型的，她就記錄這我們的這個流程實例的id，那么什么是流程實例（processInstance）呢，她是我們工作流當(dāng)中第二重要的概念，他和流程定義 的關(guān)系就相當(dāng)于對象和類之間的關(guān)系，類是一個抽象的東西，她定義完了是什么也干不了的，要想用她內(nèi)部定義的東西我們就要new出一個實例來，當(dāng)然這個里面 也是這樣的。

那么也就是說，當(dāng)我們創(chuàng)建這個報銷申請的時候我們就要先根據(jù)這個流程‘new’出一個流程實例來存到數(shù)據(jù)庫當(dāng)中，然后在把她的id傳給報銷申請對象然后再將這個報銷申請對象存到數(shù)據(jù)庫當(dāng)中。那么這個代碼是這樣的：

package com.jbpm.test;
import junit.framework.TestCase;
import org.hibernate.Session;
public class TestJbpm_03 extends TestCase {
public void testJbpm(){
Session session = null;
try{
session = HibernateUtil.getSession();
session.beginTransaction();
Document doc = new Document();
doc.setTitle("title3");
doc.setContent("this is content3");
session.save(doc);
session.getTransaction().commit();
}catch(Exception e){
e.printStackTrace();
session.getTransaction().rollback();
}finally{
HibernateUtil.closeSession(session);
}
}
}

package com.jbpm.test;
import junit.framework.TestCase;
import org.jbpm.JbpmConfiguration;
import org.jbpm.JbpmContext;
import org.jbpm.graph.def.ProcessDefinition;
import org.jbpm.graph.exe.ProcessInstance;
/**
/*
/*將申請單和流程實例綁定
/*
public class TestJbpm_04 extends TestCase {
static JbpmConfiguration jbpmConfiguration = JbpmConfiguration.getInstance();
public void testJbpm(){
JbpmContext jbpmContext = jbpmConfiguration.createJbpmContext();
jbpmContext.setSessionFactory(HibernateUtil.getSessionFactory());
try {
ProcessDefinition processDefinition = jbpmContext.getGraphSession().findLatestProcessDefinition("testJbpm");
ProcessInstance processInstance = new ProcessInstance(processDefinition);
jbpmContext.save(processInstance);
//將我們的document和instance綁定。
long processInstanceId = processInstance.getId();
Document document = (Document)jbpmContext.getSession().load(Document.class,1);
document.setProcessInstanceId(processInstanceId);
jbpmContext.getSession().update(document);
processInstance.getContextInstance().setVariable("document", document.getId());
}catch(Exception e){
e.printStackTrace();
}finally{
jbpmContext.close();
}
}
}

現(xiàn)在我們的申請已經(jīng)和實例關(guān)聯(lián)起來了，那么接下來的下一步就開始用啦，就是讓這個申請流轉(zhuǎn)起來吧，那么她應(yīng)該怎么去流轉(zhuǎn)呢，嘿嘿，jbpm給我們提供一個signal方法，每當(dāng)執(zhí)行一次這個方法的時候她就流轉(zhuǎn)一下到下一個節(jié)點，你可以打印出當(dāng)前節(jié)點試一下，看看是不是執(zhí)行一次你的當(dāng)前節(jié)點就換一下。這段代碼是這樣的：

package com.jbpm.test;
import junit.framework.TestCase;
import org.jbpm.JbpmConfiguration;
import org.jbpm.JbpmContext;
import org.jbpm.graph.exe.ProcessInstance;
public class TestJbpm_05 extends TestCase {
static JbpmConfiguration jbpmConfiguration = JbpmConfiguration.getInstance();
public void testJbpm(){
JbpmContext jbpmContext = jbpmConfiguration.createJbpmContext();
jbpmContext.setSessionFactory(HibernateUtil.getSessionFactory());
try{
Document document = (Document)jbpmContext.getSession().load(Document.class, 3);
long processInstanceId = document.getProcessInstanceId();
ProcessInstance processInstance = jbpmContext.getProcessInstance(processInstanceId);
processInstance.signal();
}finally{
jbpmContext.close();
}
}
}

好啦，jbpm的簡單例子就到這里了，有什么問題大家可以給我留留言，還請大家多多指教小弟啊。后面我還會寫點更具體的一些問題，比如說列出提交到這個人這還沒有審批的公文啊，還有如果有多個分支的話應(yīng)該怎么去做啊等等等等。