1.OSWorkFlow基本概念 mysql
在商用和開源世界裏,OSWorkflow 都不一樣於這些已有的工做流系統。最大不一樣在於 OSWorkflow 有着很是優秀的靈活性。在開始 接觸 OSWorkflow 時可能較難掌握(有人說不適合工做流新手入門),好比,OSWorkflow 不要求圖形化工具來開發工做流,而推薦手工編 寫 xml 格式的工做流程描述符。它能爲應用程序開發者提供集成,也能與現有的代碼和數據庫進行集成。這一切彷佛給正在尋找快速「即插即用」工做流解決 方案的人制造了麻煩,但研究發現,那些「即插即用」方案也不能在一個成熟的應用程序中提供足夠的靈活性來實現全部需求。 sql
2. OSWorkFlow主要優點
OSWorkflow 給你絕對的靈活性。OSWorkflow 被認爲是一種「低級別」工做流實現。與其餘工做流系統能用圖標表現「Loops(回 路)」和「Conditions(條件)」相比,OSWorkflow 只是手工「編碼(Coded)」來實現的。但這並不能說實際的代碼是須要徹底手工 編碼的,腳本語言能勝任這種情形。OSWorkflow 不但願一個非技術用戶修改工做流程,雖然一些其餘工做流系統提供了簡單的 GUI 用於工做流編 輯,但像這樣改變工做流,一般會破壞這些應用。因此,進行工做流調整的最佳人選是開發人員,他們知道該怎麼改變。不過,在最新的版本 中,OSWorkflow 也提供了 GUI 設計器來協助工做流的編輯。 數據庫
OSWorkflow 基於有限狀態機概念。每一個 state 由 step ID 和 status 聯合表現(可簡單理解爲 step 及 其 status 表示有限狀態機的 state)。一個 state 到另外一 state 的 transition 依賴於 action 的發生, 在工做流生命期內有至少一個或多個活動的 state。這些簡單概念展示了 OSWorkflow 引擎的核心思想,並容許一個簡單 XML 文件解釋工 做流業務流程。 express
3. OSWorkFlow核心概念 session
3.1. 概念定義
步驟(Step)
一個 Step 描述的是工做流所處的位置。可能從一個 Step Transtion(流轉)到另一個 Step,或者也能夠在同一個 Step 內流轉(由於 Step 能夠通 Status 來細分,造成多個State)。一個流程裏面能夠多個Step。 app
狀態(Status)
工做流 Status 是用來描述工做流程中具體Step(步驟)狀態的字符串。OSWorkflow 的有 Underway(進行中)、 Queued(等候處理中)、Finished(完成)三種 Status。一個實際State(狀態)真正是由兩部分組 成:State = (Step + Status) 。 jsp
流轉(Transtion)
一個State到另外一個State的轉移。 函數
動做(Action)
Action 觸發了發生在 Step 內或 Step 間的流轉,或者說是基於 State 的流轉。一個 step 裏面能夠有多個 Action。Action 和Step 之間的關係是,Step 說明「在哪裏」,Action 說明「去哪裏」。 一個 Action 典型地由兩部 分組成:能夠執行此Action(動做)的
Condition(條件),以及執行此動做後的 Result(結果)。 工具
條件(Condition)
相似於邏輯判斷,可包含「AND」和「OR」邏輯。好比一個請假流程中的「本部門審批階段」,該階段利用「AND」邏輯,判斷流程狀態是否爲等候處理中,以及審批者是否爲本部門主管。 oop
結果(Result)
Result 表明執行Action(動做)後的結果,指向新的 Step 及其 Step Status,也可能進入 Split 或者 Join。 Result 分爲兩種, Contidional-Result (有條件結果),只有條件爲真時才使用該結果,和 Unconditional- Result(無條件結果),當條件不知足或沒有條件時使用該結果。
分離/鏈接(Split/Join)
流程的切分和融合。很簡單的概念,Split 能夠提供多個 Result(結果);Join 則判斷多個 Current Step 的態提供一個 Result(結果)。
3.2. 步驟、狀態和動做(Step, Status, and Action)
工做流要描述步驟(Step)、步驟的狀態(Status)、各個步驟之間的關係以及執行各個步驟的條件和權限,每一個步驟中能夠含有一個或多個動做(Action),動做將會使一個步驟的狀態發生改變。
對於一個執行的工做流來說,步驟的切換是不可避免的。一個工做流在某一時刻會有一個或多個當前步驟,每一個當前步驟都有一個狀態值,當前步驟的狀態值 組成了 工做流實例的狀態值。一旦完成了一個步驟,那麼這個步驟將再也不是當前步驟(而是切換到一個新的步驟),一般一個新的當前步驟將隨之創建起來,以保證工做流 繼續執行。完成了的步驟的最終狀態值是用Old-Status屬性指定的,這個狀態值的設定將發生在切換到其餘步驟以前。Old-Status的值能夠是 任意的,但在通常狀況下,咱們設置爲Finished。
切換自己是一個動做(Action)的執行結果。每一個步驟能夠含有多個動做,究竟要載入哪一個動做是由最終用戶、外部事件或者Tiggerd的自動調 用決定 的。隨着動做的完成,一個特定的步驟切換也將發生。動做能夠被限制在用戶、用戶組或當前狀態。每個動做都必須包含一個 Unconditional Result和0個或多個Conditional Results。
因此,整體來講,一個工做流由多個步驟組成。每一個步驟有一個當前狀態(例如:Queued, Underway or Finished),一個步驟包含 多個動做。每一個步驟含有多個能夠執行的動做。每一個動做都有執行的條件,也有要執行的函數。動做包含有能夠改變狀態和當前工做流步驟的results。
3.3. 結果、分支和鏈接(Results, Joins, and Splits)
3.3.1. 無條件結果(Unconditional Result)
對於每個動做來說,必須存在一個Unconditional Result。一個result是一系列指令,這些指令將告訴OSWorkFlow下一個任務要作什麼。這包括使工做流從一個狀態切換到另外一個狀態。
3.3.2. 有條件結果(Conditional Result)
Conditional Result是Unconditional Result的一個擴展。它須要一個或多個Condition子標籤。第一個爲 true的Conditional(使用AND或OR類型),會指明發生切換的步驟,這個切換步驟的發生是因爲某個用戶執行了某個動做的結果致使的。
3.3.3. 三種不一樣的Results(conditional or unconditional)
一個新的、單一的步驟和狀態的組合。
一個分裂成兩個或多個步驟和狀態的組合。
將這個和其餘的切換組合成一個新的單一的步驟和狀態的組合。
每種不一樣的result對應了不一樣的xml描述,你能夠閱讀http://www.opensymphony.com/osworkflow/workflow_2_7.dtd,獲取更多的信息。
注意:一般,一個split或一個join不會再致使一個split 或 join的發生。
3.4. 自動步驟(Auto actions)
有的時候,咱們須要一些動做能夠基於一些條件自動地執行。爲了達到這個目的,你能夠 在action中加入auto="true"屬性。流程將考察這個動做 的條件和限制,若是條件符合,那麼將執行這個動做。 Auto action是由當前的調用者執行的,因此將對該動做的調用者執行權限檢查。
3.5. 整合抽象實例(Integrating with Abstract Entities)
建議在你的核心實體中, 例如"Document" 或 "Order",在內部建立一個新的屬性:workflowId。這樣,當新 的"Document" 或 "Order"被建立的時候,它可以和一個workflow實例關聯起來。那麼,你的代碼能夠經過 OSWorkflow API查找到這個workflow實例而且獲得這個workflow的信息和動做。
3.6. 工做流實例狀態(Workflow Instance State)
有的時候,爲整個workflow實例指定一 個狀態是頗有幫助的,它獨立於流程的執行步驟。OSWorkflow提供一些workflow實例中能夠包含 的"meta-states"。這些"meta-states"能夠是 CREATED, ACTIVATED, SUSPENDED, KILLED 和 COMPLETED。當一個工做流實例被建立的時候,它將處於 CREATED狀態。而後,只要一個動做被執行,它就會自動的變成ACTIVATED狀態。若是調用者沒有明確地改變實例的狀態,工做流將一直保持這個狀 態直到工做流結束。當工做流不可能再執行任何其餘的動做的時候,工做流將自動的變成COMPLETED狀態。
然而,當工做流處於ACTIVATED狀態的時候,調用者能夠終止或掛起這個工做流(設置工做流的狀態爲KILLED 或 SUSPENDED)。一個終 止了的工做流將不能再執行任何動做,並且將永遠保持着終止狀態。一個被掛起了的工做流會被凍結,他也不能執行任何的動做,除非它的狀態再變成 ACTIVATED。
4. OSWorkFlow包用途分析及代碼片段
4.1. com.opensymphony.workflow
該 包爲整個OSWorkflow 引擎提供核心接口。例如 com.opensymphony.workflow.Workflow 接口,能夠說,實際 開發中的大部分工做都是圍繞該接口展開的,該接口有 BasicWorkflow、EJBWorkflow、OfbizWorkflow 三個實現類。
4.2. com.opensymphony.workflow.basic
該包有兩個類,BasicWorkflow 與 BasicWorkflowContext。BasicWorkflow 不支持事務,儘管依賴持久實現,事務也不能包裹它。BasicWorkflowContext 在實際開發中不多使用。
+ expand sourceview plaincopy to clipboardprint?
public void setWorkflow(int userId) {
Workflow workflow = new BasicWorkflow(Integer.toString(userId));
}
public void setWorkflow(int userId) {
Workflow workflow = new BasicWorkflow(Integer.toString(userId));
}
4.3. com.opensymphony.workflow.config
該包有一個接口和兩個該接口的實現類。在 OSWorkflow 2.7 之前,狀態由多個地方的靜態字段維護,這種方式很方便,可是有不少缺陷和約束。 最主要的缺點是沒法經過不一樣配置運行多個 OSWorkflow 實例。實現類 DefaultConfiguration 用於通常的配置文件載入。 而 SpringConfiguration 則是讓 Spring 容器管理配置信息。
+ expand sourceview plaincopy to clipboardprint?
public void setWorkflow(int userId) {
Workflow workflow = new BasicWorkflow(Integer.toString(userId));
}
public void setWorkflow(int userId) {
Workflow workflow = new BasicWorkflow(Integer.toString(userId));
}
4.4. com.opensymphony.workflow.ejb
該包有兩個接口 WorkflowHome 和 WorkflowRemote。該包的若干類中,最重要的是 EJBWorkflow,該類 和 BasicWorkflow 的做用同樣,是 OSWorkflow 的核心,並利用 EJB 容器管理事務,也做爲工做 流 session bean 的包裝器。
4.5. com.opensymphony.workflow.loader
該包有若干類,用得最多的是 XxxxDescriptor,若是在工做流引擎運行時須要瞭解指定的動做、步驟的狀態、名字,等信息時,這些描述符會起到很大做用。
view plaincopy to clipboardprint?
01.public String findNameByStepId(int stepId,String wfName) {
02.WorkflowDescriptor wd = workflow.getWorkflowDescriptor(wfName);
03.StepDescriptor stepDes = wd.getStep(stepId);
04.return stepDes.getName();
05.}
public String findNameByStepId(int stepId,String wfName) {
WorkflowDescriptor wd = workflow.getWorkflowDescriptor(wfName);
StepDescriptor stepDes = wd.getStep(stepId);
return stepDes.getName();
}
4.6. com.opensymphony.workflow.ofbiz
OfbizWorkflow 和 BasicWorkflow 在不少方面很是類似,除了須要調用 ofbiz 的 TransactionUtil 來包裝事務。
4.7. com.opensymphony.workflow.query
該包主要爲查詢而設計,但不是全部的工做流存儲都支持查 詢。一般,Hibernate 和 JDBC 都支持,而內存工做流存儲不支持。值得注意的 是 Hibernate 存儲不支持混合型查詢(例如,一個查詢同時包含了 history step 上下文和 current step 上下文)。 執行一個查詢,須要建立 WorkflowExpressionQuery 實例,接着調用 Workflow 對象的 query 方法來獲得最終查詢 結果。
+ expand sourceview plaincopy to clipboardprint?
public List queryDepAdmin(int userId,int type) {
int[] arr = getSubPerson(userId,type);
//構造表達式
Expression[] expressions = new Expression[1 + arr.length];
Expression expStatus = new FieldExpression(FieldExpression.STATUS,
FieldExpression.CURRENT_STEPS, FieldExpression.EQUALS, "Queued");
expressions[0] = expStatus;
for (int i = 0; i < arr.length; i++) {
Expression expOwner = new FieldExpression(FieldExpression.OWNER,
FieldExpression.CURRENT_STEPS, FieldExpression.EQUALS,
Integer.toString(arr[i]));
expressions[i + 1] = expOwner;
}
//查詢未完成流編號
List wfIdList = null;
try {
WorkflowExpressionQuery query = new WorkflowExpressionQuery(
new NestedExpression(expressions, NestedExpression.AND));
wfIdList = workflow.query(query);
} catch (Exception e) {
e.printStackTrace();
}
}
public List queryDepAdmin(int userId,int type) {
int[] arr = getSubPerson(userId,type);
//構造表達式
Expression[] expressions = new Expression[1 + arr.length];
Expression expStatus = new FieldExpression(FieldExpression.STATUS,
FieldExpression.CURRENT_STEPS, FieldExpression.EQUALS, "Queued");
expressions[0] = expStatus;
for (int i = 0; i < arr.length; i++) {
Expression expOwner = new FieldExpression(FieldExpression.OWNER,
FieldExpression.CURRENT_STEPS, FieldExpression.EQUALS,
Integer.toString(arr[i]));
expressions[i + 1] = expOwner;
}
//查詢未完成流編號
List wfIdList = null;
try {
WorkflowExpressionQuery query = new WorkflowExpressionQuery(
new NestedExpression(expressions, NestedExpression.AND));
wfIdList = workflow.query(query);
} catch (Exception e) {
e.printStackTrace();
}
}
4.8. com.opensymphony.workflow.soap
OSWorkflow 經過 SOAP 來支持遠端調用。這種調用藉助 WebMethods 實現。
4.9. com.opensymphony.workflow.spi
該包能夠說是 OSWorkflow 與持久層打交道的途徑,如當前工做流的實體,其中包括:EJB、Hibernate、JDBC、Memory、Ofbiz、OJB、Prevayler。
HibernateWorkflowEntry hwfe = (HibernateWorkflowEntry) getHibernateTemplate()
.find("from HibernateWorkflowEntry where Id="
+ wfIdList.get(i)).get(0);
4.10. com.opensymphony.workflow.util
該包是 OSWorkflow 的工具包,包括了對 BeanShell、BSF、EJB Local、EJB Remote、JNDI 的支持。
5. OSWorkFlow表結構分析
5.1. OS_WFENTRY
工做流主表,存放工做流名稱和狀態
字段名 數據類型 說明
ID NUMBER 自動編號
NAME VARCHAR2(20) 工做流名稱
STATE NUMBER 工做流狀態
5.2. OS_CURRENTSTEP
當前步驟表,存放當前正在進行步驟的數據
字段名 數據類型 說明
ID NUMBER 自動編號
ENTRY_ID NUMBER 工做流編號
STEP_ID NUMBER 步驟編號
ACTION_ID NUMBER 動做編號
OWNER VARCHAR2(20) 步驟的全部者
START_DATE DATE 開始時間
FINISH_DATE DATE 結束時間
DUE_DATE DATE 受權時間
STATUS VARCHAR2(20) 狀態
CALLER VARCHAR2(20) 操做人員的賬號名稱
5.3. OS_CURRENTSTEP_PREV
前步驟表,存放當前步驟和上一個步驟的關聯數據
字段名 數據類型 說明
ID NUMBER 當前步驟編號
PREVIOUS NUMBER 前步驟編號
5.4. OS_HISTORYSTEP
歷史步驟表,存放當前正在進行步驟的數據
字段名 數據類型 說明
ID NUMBER 自動編號
ENTRY_ID NUMBER 工做流編號
STEP_ID NUMBER 步驟編號
ACTION_ID NUMBER 動做編號
OWNER VARCHAR2(20) 步驟的全部者
START_DATE DATE 開始時間
FINISH_DATE DATE 結束時間
DUE_DATE DATE 受權時間
STATUS VARCHAR2(20) 狀態
CALLER VARCHAR2(20) 操做人員的賬號名稱
5.5. OS_HISTORYSTEP_PREV
前歷史步驟表,存放歷史步驟和上一個步驟的關聯數據
字段名 數據類型 說明
ID NUMBER 當前歷史步驟編號
PREVIOUS NUMBER 前歷史步驟編號
5.6. OS_PROPERTYENTRY
屬性表,存放臨時變量
字段名 數據類型 說明
GLOBAL_KEY VARCHAR2(255) 全局關鍵字
ITEM_KEY VARCHAR2(255) 條目關鍵字
ITEM_TYPE NUMBER 條目類型
STRING_VALUE VARCHAR2(255) 字符值
DATE_VALUE DATE 日期值
DATA_VALUE BLOB 數據值
FLOAT_VALUE FLOAT 浮點值
osworkflow代碼分析
1.com.opensymphony.workflow.Workflow 工做流的用戶接口。
主要定義了用戶對工做流的操做方法和用戶得到工做流信息的方法。如doAction(long id, int actionId, Map inputs)方法能夠執行工做流的Action併產生transaction;用戶調用getAvailableActions(long id, Map inputs)能夠得到知道工做流實例中符合條件的能夠執行的Action。
2.com.opensymphony.workflow.WorkflowContext 工做流的Context接口。
只有兩個方法,其中getCaller()得到調用者,setRollbackOnly()能夠回滾Action形成的transaction。
setRollbackOnly()方法很是重要,能夠在此方法中實現工做流數據與業務數據的事務處理。因爲工做流引擎將流程數據與業務數據分離開管理, 因此工做流數據與業務數據之間的事務處理每每比較困難,甚至有不少商業的工做流引擎都沒有解決這個問題,形成軟件上的漏洞。惋惜在 BasicWorkflowContext中並無實現回滾時的事務處理,但實現起來應該不會很困難,在之後會單獨考慮。
3.com.opensymphony.workflow.spi.WorkflowEntry 工做流實例的接口。
定義了得到工做流實例信息的方法。
4.com.opensymphony.workflow.config.Configuration 工做流配置接口。
得到osworkflw的配置信息和流程的定義信息, osworkflow中的例子就是使用此接口的默認實現。若是想讓osworkflw與本身的系統更好的整合,這個接口須要本身實現。
5.com.opensymphony.workflow.loader.AbstractWorkflowFactory 流程定義的解析器。
osworkflow中提供了此抽象類的3種實現,最經常使用的是XMLWorkflowFactory,能夠對編寫的工做流定義xml文件進行解析。
6.com.opensymphony.workflow.spi.WorkflowStore 工做流存儲接口。
實現此接口能夠實現用多種途徑保存工做流信息,jdbc,hibernate,ejb,memory.........
AbstractWorkflow類是workflow接口的最基本的實現。
1.public int[] getAvailableActions(long id, Map inputs)方法:
返回當前能夠執行的Ation。
•獲得工做流流程實例。
•獲得工做流實例的定義。
•獲得工做流實例的PropertySet。
•獲得工做流的當前Step。
•產生TransientVars。
•獲得Global Actions。
•判斷能夠執行的Global Action增長到可執行Action列表中。
•得到當前Steps中的可執行Action並添加到可執行Action列表中。
•返回可執行Actions。
2. public void setConfiguration(Configuration configuration)方法:
設置工做流配置方法。
3.public Configuration getConfiguration()方法:
返回工做流配置方法,若是沒有得到配置信息,初始化配置信息。
4.public List getCurrentSteps(long id):
得到工做流當前所在步驟。
5.public int getEntryState(long id):
得到工做流的狀態。
6.public List getHistorySteps(long id)
得到工做流的歷史步驟。
7. public Properties getPersistenceProperties()
得到設置的持久化參數。
8.public PropertySet getPropertySet(long id)
獲得工做流的PropertySet,調用store中的方法。
9.public List getSecurityPermissions(long id)
獲得工做流當前Step的permissions。
10.public WorkflowDescriptor getWorkflowDescriptor(String workflowName)
獲得工做流的定義。
11.public String getWorkflowName(long id)
根據工做流實例返回工做流定義名。
12. public String[] getWorkflowNames()
返回系統中配置的全部工做流的名字。
13.public boolean canInitialize(String workflowName, int initialAction),public boolean canInitialize(String workflowName, int initialAction, Map inputs),private boolean canInitialize(String workflowName, int initialAction, Map transientVars, PropertySet ps) throws WorkflowException
判斷指定的工做流初始化Action是否是能夠執行。
14.public boolean canModifyEntryState(long id, int newState)
判斷工做流是否是能夠轉換到指定狀態。
•不能夠轉換到CREATED狀態。
•CREATED,SUSPENDED能夠轉換到ACTIVATED狀態。
•ACTIVATED能夠轉換到SUSPENDED狀態。
•CREATED,ACTIVATED,SUSPENDED 能夠轉換到KILLED狀態。
15.public void changeEntryState(long id, int newState) throws WorkflowException
轉換工做流狀態。
16.public void doAction(long id, int actionId, Map inputs) throws WorkflowException
執行Action。
•得到工做流store,和流程實例entry。
•判斷是否是活動的工做流,不是就返回。
•得到工做流的定義。
•得到工做流當前所再Steps。
•得到工做流PropertySet。
•生成transientVars。
•從GlobalActions中和當前Steps的普通Actions中判斷執行的Action是否試可執行的。
•完成Action的Transition。
17.public void executeTriggerFunction(long id, int triggerId) throws WorkflowException
調用工做流的Trigger Function
18.public long initialize(String workflowName, int initialAction, Map inputs) throws InvalidRoleException, InvalidInputException, WorkflowException
初始化一個新的流程實例。返回流程實例id。
19.public List query(WorkflowQuery query),public List query(WorkflowExpressionQuery query)
查詢流程實例。
20.public boolean removeWorkflowDescriptor(String workflowName) throws FactoryException
刪除已經配置的工做流定義。
21.public boolean saveWorkflowDescriptor(String workflowName, WorkflowDescriptor descriptor, boolean replace) throws FactoryException
保存工做流定義。
22.protected List getAvailableActionsForStep(WorkflowDescriptor wf, Step step, Map transientVars, PropertySet ps) throws WorkflowException
得到指定步驟的可用Actions。
23.protected int[] getAvailableAutoActions(long id, Map inputs)
返回可執行的AutoActions。
24.protected List getAvailableAutoActionsForStep(WorkflowDescriptor wf, Step step, Map transientVars, PropertySet ps) throws WorkflowException
返回指定Step中可執行的AutoActions。
25.protected WorkflowStore getPersistence() throws StoreException
返回配置的store。
26.protected void checkImplicitFinish(long id) throws WorkflowException
判斷工做流是否是還有可執行的Action,若是沒有,完成此工做流實例。
27.protected void completeEntry(long id, Collection currentSteps) throws StoreException
結束工做流實例,就是把改變流程實例的狀態並把當前的Steps都放入到歷史表中。
28.protected boolean passesCondition(ConditionDescriptor conditionDesc, Map transientVars, PropertySet ps, int currentStepId) throws WorkflowException
29.protected boolean passesCondition(ConditionDescriptor conditionDesc, Map transientVars, PropertySet ps, int currentStepId) throws WorkflowException,protected boolean passesConditions(String conditionType, List conditions, Map transientVars, PropertySet ps, int currentStepId) throws WorkflowException
判斷條件是否是符合。
30.protected void populateTransientMap(WorkflowEntry entry, Map transientVars, List registers, Integer actionId, Collection currentSteps) throws WorkflowException
產生臨時變量transientVars,包含context,entry,store,descriptor,actionId,currentSteps,以及定義的register和用戶的輸入變量。
31.protected void verifyInputs(WorkflowEntry entry, List validators, Map transientVars, PropertySet ps) throws WorkflowException
驗證用戶的輸入。
32.private boolean isActionAvailable(ActionDescriptor action, Map transientVars, PropertySet ps, int stepId) throws WorkflowException
判斷Action是否可用。
33.private Step getCurrentStep(WorkflowDescriptor wfDesc, int actionId, List currentSteps, Map transientVars, PropertySet ps) throws WorkflowException
得到Action所在Step。
34.private boolean canInitialize(String workflowName, int initialAction, Map transientVars, PropertySet ps) throws WorkflowException
判斷工做流是否是能夠實例化。
35.private Step createNewCurrentStep(ResultDescriptor theResult, WorkflowEntry entry, WorkflowStore store, int actionId, Step currentStep, long[] previousIds, Map transientVars, PropertySet ps) throws WorkflowException
產生新的當前Step。
•從resulte中得到nextStep,若是爲-1,nextStep爲當前Step。
•得到定義中的owner,oldStatus,status。
•完成當前Step,而且將當前Step保存到歷史庫中。
•生成新的Step。
36.private void executeFunction(FunctionDescriptor function, Map transientVars, PropertySet ps) throws WorkflowException
執行Function。
37.private boolean transitionWorkflow(WorkflowEntry entry, List currentSteps, WorkflowStore store, WorkflowDescriptor wf, ActionDescriptor action, Map transientVars, Map inputs, PropertySet ps) throws WorkflowException
完成工做流的transation。
DefaultConfiguration是Configuration接口的默認實現,用於初始化系統的基本配置信息。
1.public WorkflowDescriptor getWorkflow(String name) throws FactoryException
根據工做流的定義名得到工做流的定義。
2.public WorkflowStore getWorkflowStore() throws StoreException
得到配置的持久化類Store。
3.public void load(URL url) throws FactoryException
裝載配置信息。
•獲得配置文件流,並解析。
•得到持久化信息,包括持久化類的路徑和持久化類初始化參數。
•得到工做流信息解析類路徑,並初始化。
4. public WorkflowStore getWorkflowStore() throws StoreException
得到工做流初始化類。
XMLWorkflowFactory用於解析工做流定義xml文件,得到工做流信息。
1.public WorkflowDescriptor getWorkflow(String name) throws FactoryException
根據工做流定義名得到工做流定義。
2.public String[] getWorkflowNames()
獲得全部已經定義的工做流名稱。
3.public void initDone() throws FactoryException
初始化workflows.xml文件中列出的工做流定義文件信息。
osworkflow概念
1. Step:工做流所在的位置,整個工做流的步驟,也能夠是一系列工做中的某個工做,好比某個審批流程中的文件交到某個領導處審批,此過程可能包括接收祕書 交來的文件、而後閱讀、提出本身的意見、簽字、叫給祕書繼續處理,這整個過程能夠是一個Step。但並非FSM中的Status。
2. Status:某個Step的狀態,每一個Step能夠有多個Status。好比上例中閱讀,等待提意見,等待簽字,等待交祕書處理,都是Step的狀態。 Step+Status共同組成了工做流的狀態,也就實現了FSM中的Status。Step的Status在OSWorkflow中就是一段文本,狀態 的判斷其實就是自定義的一段文本的比較,很是靈活。
3. Action:形成工做流狀態轉換的動做,好比」閱讀文件「動做,形成了工做流狀態從」領導審批+等待閱讀"轉換成「領導審批+等待提出意見」。因爲工做流的狀態是Step+Status,因此Action能夠形成Stats的變化,也能夠形成Step的變化。
4. Result:工做流狀態的轉換,也就是Action形成的結果。也就是FSM中的Transition。每一個Action中至少包含一個 unconditional result和包含0或多個conditional result,Result的優先級順序是 第一個符合條件的conditional result > 其餘符合條件的conditional result > unconditional result。
5.Split/Join:字面意思就能夠解釋。Split能夠產生多個unconditional result;而Join能夠判斷多個Step的狀態,若是都知足條件的時候,Join產生一個unconditional result。能夠用來實現其餘工做流產品定義中的同步區的做用,好比一個投標文件的評標過程,分別要在技術方面和商務方面對標書進行評分,這樣就可使 用Split將工做流分開進入商務評標組和技術評標組分別進行評標,當兩個評標過程都完成後使用Join將兩個流程合併,並對兩個評標作的評分進行彙總。
6.External Functions:執行的功能和動做。任何的工做流引擎都要與實際的業務操做相結合,External Functions就是OSWorkflow中執行業務操做的部分,好比審批流程中,領導填寫意見後將領導的意見更新到業務數據庫中的過程。 Functions有兩種類型,pre step function和post step function,分別發生轉移前和發生轉移後執行。Functions能夠被定義到Step中和Action中。
7.Trigger Functions,一種不是定義在Action中的Function,依靠計劃自動執行。
8.Validators:用來檢驗用戶輸入是否符合條件,只有符合條件,Action對應的轉移才能執行,若是不符合條件,返回InvalidInputException異常。
配置OSWorkFlow經過Hibernate持久化
1.修改WEB-INF/classes/目錄下的osworkflow.xml,改成
+ expand sourceview plaincopy to clipboardprint?
<persistence class="com.opensymphony.workflow.spi.hibernate.HibernateWorkflowStore">
lt;/persistence>
<persistence class="com.opensymphony.workflow.spi.hibernate.HibernateWorkflowStore">
</persistence>
2.將下面的Hibernate.cfg.xml加到WEB-INF/classes/下面,這裏使用mysql數據庫。
+ expand sourceview plaincopy to clipboardprint?
<?xml version='1.0' encoding='utf-8'?>
<!DOCTYPE hibernate-configuration PUBLIC "-//Hibernate/Hibernate Configuration DTD 2.0//EN" "http://hibernate.sourceforge.net/hibernate-configuration-2.0.dtd">
<hibernate-configuration>
<session-factory>
<!-- properties -->
<property name="connection.driver_class">org.gjt.mm.mysql.Driver</property>
<property name="connection.url">jdbc:mysql://redhat:3306/osworkflow</property>
<property name="connection.username">redhat</property>
<property name="connection.password">redhat</property>
<property name="dialect">net.sf.hibernate.dialect.MySQLDialect</property>
<property name="show_sql">true</property>
<property name="use_outer_join">true</property>
<property name="connection.pool_size">10</property>
<property name="statement_cache.size">25</property>
<property name="hibernate.hbm2ddl.auto">update</property>
<mapping resource="com/opensymphony/workflow/spi/hibernate/HibernateCurrentStep.hbm.xml"></mapping>
<mapping resource="com/opensymphony/workflow/spi/hibernate/HibernateHistoryStep.hbm.xml"></mapping>
<mapping resource="com/opensymphony/workflow/spi/hibernate/HibernateWorkflowEntry.hbm.xml"></mapping>
<mapping resource="com/opensymphony/module/propertyset/hibernate/PropertySetItemImpl.hbm.xml"></mapping>
</session-factory>
</hibernate-configuration>
<?xml version='1.0' encoding='utf-8'?>
<!DOCTYPE hibernate-configuration PUBLIC "-//Hibernate/Hibernate Configuration DTD 2.0//EN" "http://hibernate.sourceforge.net/hibernate-configuration-2.0.dtd">
<hibernate-configuration>
<session-factory>
<!-- properties -->
<property name="connection.driver_class">org.gjt.mm.mysql.Driver</property>
<property name="connection.url">jdbc:mysql://redhat:3306/osworkflow</property>
<property name="connection.username">redhat</property>
<property name="connection.password">redhat</property>
<property name="dialect">net.sf.hibernate.dialect.MySQLDialect</property>
<property name="show_sql">true</property>
<property name="use_outer_join">true</property>
<property name="connection.pool_size">10</property>
<property name="statement_cache.size">25</property>
<property name="hibernate.hbm2ddl.auto">update</property>
<mapping resource="com/opensymphony/workflow/spi/hibernate/HibernateCurrentStep.hbm.xml"></mapping>
<mapping resource="com/opensymphony/workflow/spi/hibernate/HibernateHistoryStep.hbm.xml"></mapping>
<mapping resource="com/opensymphony/workflow/spi/hibernate/HibernateWorkflowEntry.hbm.xml"></mapping>
<mapping resource="com/opensymphony/module/propertyset/hibernate/PropertySetItemImpl.hbm.xml"></mapping>
</session-factory>
</hibernate-configuration>
3.把hibernate的jar及hibernate全部要到的jar,到WEB-INF/lib/
4.OSWorkflow要求客戶端 提供SessionFactory,自主控制session和transaction。在容器裏能夠直接生成 SessionFactory而後注入到workflow中。這裏只是演示,因此直接修改.jsp文件,生成SessionFactory,傳入 workflow中。
+ expand sourceview plaincopy to clipboardprint?
Workflow wf = new BasicWorkflow((String) session.getAttribute("username"));
// osworkflow和hibernate居然都是經過Configuration類來進行配置的,沒辦法,誰讓你們都須要進行配置而就那麼幾個單詞呢
com.opensymphony.workflow.config.Configuration conf = new DefaultConfiguration();
SessionFactory sessionFactory = new net.sf.hibernate.cfg.Configuration().configure().buildSessionFactory();
conf.getPersistenceArgs().put("sessionFactory", sessionFactory);
wf.setConfiguration(conf);
Workflow wf = new BasicWorkflow((String) session.getAttribute("username"));
// osworkflow和hibernate居然都是經過Configuration類來進行配置的,沒辦法,誰讓你們都須要進行配置而就那麼幾個單詞呢
com.opensymphony.workflow.config.Configuration conf = new DefaultConfiguration();
SessionFactory sessionFactory = new net.sf.hibernate.cfg.Configuration().configure().buildSessionFactory();
conf.getPersistenceArgs().put("sessionFactory", sessionFactory);
wf.setConfiguration(conf);
5.OK搞定。