為什么使用工作流引擎，什么是工作流引擎，工作流引擎選型以及如何使用
本文轉(zhuǎn)載自微信公眾號「Java大廠面試官」，作者laker 。轉(zhuǎn)載本文請聯(lián)系Java大廠面試官代碼眾號。
為什么使用工作流引擎?
反證法，如果不使用工作流引擎，先以請假流程舉例，從頭開始開發(fā)流程的業(yè)務(wù)邏輯：(來看看會出現(xiàn)哪些問題?使用工作流能解決哪些問題?又會帶來什么問題?)
一、業(yè)務(wù)流程梳理
“流程定義可能是hardcoding或者存儲在某張表
- 總經(jīng)理審批
- 結(jié)束
- 結(jié)束
- 員工發(fā)起請假單
- 組長審批
- 請假天數(shù)小于等于2天
- 請假天數(shù)大于2天
二、每個節(jié)點都要記錄當(dāng)前操作人和判斷下個節(jié)點
- if(day>2)
- 總經(jīng)理審批 (記錄誰發(fā)起的以及判斷下個節(jié)點)
- 結(jié)束
- if(day<=2)
- 結(jié)束
- 同意或者拒絕
- nextUserId根據(jù)上面的流程定義獲取
- 存入transfer狀態(tài)流轉(zhuǎn)表， userId nextUserId等 驅(qū)動到下一個節(jié)點
- 員工填寫請假單并提交
- nextUserId根據(jù)上面的流程定義獲取
- 存入leave表，創(chuàng)建人，創(chuàng)建時間
- 存入transfer狀態(tài)流轉(zhuǎn)表， userId nextUserId等 驅(qū)動到下一個節(jié)點
- 員工發(fā)起請假單 (記錄誰發(fā)起的以及判斷下個節(jié)點)
- 組長審批 (記錄誰發(fā)起的以及判斷下個節(jié)點)
- 請假天數(shù)小于等于2天 (記錄誰發(fā)起的以及判斷下個節(jié)點)
- 請假天數(shù)大于2天 (記錄誰發(fā)起的以及判斷下個節(jié)點)
如果再來個用車流程、報銷流程等，那么你的項目將無法維護
不使用工作流存在以下問題
- 流程設(shè)計沒有可視化
- 流程沒有版本管理，熱部署等
- 每個活動的流轉(zhuǎn)都需要硬性判斷下一步活動節(jié)點及其操作人
- 每次操作都需要維護業(yè)務(wù)數(shù)據(jù)和流程的相關(guān)數(shù)據(jù)
- 缺乏數(shù)據(jù)管理、流程監(jiān)控等功能
工作流優(yōu)缺點
對上面共性問題進行抽象，抽象，抽象，可以得出下面的視圖。
把業(yè)務(wù)和流程進行了抽象分離，降低耦合，
優(yōu)點
- 具有可視化的流程設(shè)計工具
- 業(yè)務(wù)數(shù)據(jù)和流程數(shù)據(jù)的分離，可以進行更專注的性能優(yōu)化，業(yè)務(wù)劃分
- 內(nèi)置API能很好的完成常見的功能場景
- 具有完善的流程監(jiān)控體系
- 具備大量的自定義擴展接口
缺點
需要額外的學(xué)習(xí)成本
什么是工作流引擎
所謂工作流引擎是指workflow作為應(yīng)用系統(tǒng)的一部分，并為之提供對各應(yīng)用系統(tǒng)有決定作用的根據(jù)角色、分工和條件的不同決定信息傳遞路由、內(nèi)容等級等核心解決方案。工作流引擎包括流程的節(jié)點管理、流向管理、流程樣例管理等重要功能。(來自百科)
嘗試自己構(gòu)建工作流引擎
以下內(nèi)容取自：https://www.cnblogs.com/duck-and-duck/p/14436373.html
并進行了部分修改。
第1天
我查了一天啥是工作流，然后做出了如下版本：
按順序添加任意個審批人組成一個鏈表，最后加一個結(jié)束節(jié)點
記錄當(dāng)前審批人，當(dāng)審批完后，審批人向后移動一位
當(dāng)審批人對應(yīng)結(jié)束節(jié)點時，流程結(jié)束
“每個節(jié)點執(zhí)行人是hardcoding的
第二天
發(fā)現(xiàn)部分業(yè)務(wù)需要支持會簽節(jié)點。
我又查了一天啥是會簽節(jié)點，發(fā)現(xiàn)會簽節(jié)點就是一個大節(jié)點，里面有很多審批人，當(dāng)這個大節(jié)點里的所有人都審批通過后，才能進入下一個節(jié)點。
翻了原來的鏈表式設(shè)計：
第三天
發(fā)現(xiàn)部分業(yè)務(wù)需要支持條件節(jié)點。
要根據(jù)表單的內(nèi)容確定下一步進入哪個分支。
第四天
審批人多加兩種類型，比如可以從表單中選擇下一個審批人，還有根據(jù)發(fā)起人不同選擇不同的審批人。
第五天
需要滿足xxx需求，卒。。。
“看來實現(xiàn)一個工作流引擎還是蠻難的，那有什么可選的輪子嗎
有哪些選型方案呢
工作流整體流程如下：
| 建模（事前） | 運行 （事中） | 管理 （事后） | 監(jiān)控（全生命周期） |
|---|---|---|---|
| 流程設(shè)計 | engine驅(qū)動 | 數(shù)據(jù)管理 | 流程監(jiān)控 |
基于bpmn標(biāo)準(zhǔn)進行流程定義
什么是BPMN
BPMN 是 Business Process Modeling Notation 的簡稱，即業(yè)務(wù)流程建模與標(biāo)注。BPMN 定義了一個業(yè)務(wù)流程圖，這個流程圖被設(shè)計用于創(chuàng)建業(yè)務(wù)流程操作的圖形化模型 。而一個業(yè)務(wù)流程模型( Business Process Model )，指一個由圖形對象( graphical objects )組成的網(wǎng)狀圖，圖形對象包括活動(activities) 和用于定義這些活動執(zhí)行順序的流程控制器( flow controls )。
代表實現(xiàn)產(chǎn)品如下：
- JBPM
- Activiti
- Flowable
國產(chǎn)自定義
- snaker
- jflow
如何使用SnakerFlow工作流
僅列出常見功能場景實現(xiàn)，具體介紹和詳情文檔參見：Spring Boot 集成SnakerFlow流程引擎，簡介、功能列表、詳細(xì)解讀、擴展點分析
“?? ?? ?? 已開源基于SnakerFlow輕量級工作流引擎的腳手架項目 easy-admin
“詳情參見：終于寫了個開源項目，easy-admin 為打造一款簡單、輕量級的后臺管理系統(tǒng)腳手架
以請假流程來看下數(shù)據(jù)庫中數(shù)據(jù)流轉(zhuǎn)情況
相關(guān)源碼已開源
已開源基于SnakerFlow輕量級工作流引擎的腳手架項目 easy-admin
詳情參見：終于寫了個開源項目，easy-admin 為打造一款簡單、輕量級的后臺管理系統(tǒng)腳手架
初始狀態(tài)
wf_process
員工發(fā)起請假申請
- args.put("user1", StpUtil.getLoginIdAsString());
- args.put("user2", "yang");
- args.put("user3", "zhang");
- Object day = args.get("day");
- if (day != null) {
- args.put("day", Integer.valueOf((String) day));
- }b
- snakerEngineFacets.startAndExecute(name, version, StpUtil.getLoginIdAsString(), args);
員工laker發(fā)起一個請假單，請假3天
laker的待辦列表為空，已辦列表如下：
yang的待辦列表如下：
當(dāng)前監(jiān)控流程圖
wf_order
wf_task
wf_task_actor
wf_hist_order
wf_hist_task
wf_hist_task_actor
常見功能
流程標(biāo)題
我們經(jīng)常希望待辦任務(wù)列表有一列是流程實例的名稱，即標(biāo)題，例如，我們希望流程的標(biāo)題是：張三 - 2019-12-04 16：40：20的請假申請 ，通常會采用一個命名規(guī)則：發(fā)起人+發(fā)起時間+流程模型名稱把它作為流程的標(biāo)題。這時候就希望啟動流程實例時可以設(shè)置流程實例的名稱。
- args.put(SnakerEngine.ID, "張三 - 2019-12-04 16：40：20的請假申請");
- snakerEngineFacets.startAndExecute(name, version, StpUtil.getLoginIdAsString(), args);
發(fā)起申請
- args.put(SnakerEngine.ID, "張三 - 2019-12-04 16：40：20的請假申請");
- snakerEngineFacets.startAndExecute(name, version, StpUtil.getLoginIdAsString(), args);
我的發(fā)起
- QueryFilter filter = new QueryFilter();
- filter.setOperator(operator);
- filter.orderBy("create_Time").order(DESC);
- snakerEngineFacets.getEngine().query().getHistoryOrders(page, filter);
我的待辦
- Page<WorkItem> page = new Page<>(30);
- snakerEngineFacets.getEngine().query().getWorkItems(page,
- new QueryFilter().setOperator(operator));
我的已辦
- Page<WorkItem> page = new Page<>(30);
- snakerEngineFacets.getEngine().query().getHistoryWorkItems(page,
- new QueryFilter().setOperator(operator));
催辦
- List<Task> tasks = snakerEngineFacets.getEngine().query().getActiveTasks(new QueryFilter().setOrderId(orderId));
- 根據(jù)這個task跟指定人發(fā)消息
轉(zhuǎn)辦
轉(zhuǎn)辦任務(wù)(換當(dāng)前辦理人,或者叫變更當(dāng)前辦理人)
- snakerEngineFacets.transferMajor(taskId, operator, nextOperators);
駁回
駁回/退回上一步/退回至(即退回到歷史某一個節(jié)點)
- snakerEngineFacets.executeAndJump(taskId, operator, args, nodeName);
撤回
根據(jù)歷史任務(wù)id，撤回由該歷史任務(wù)派發(fā)的所有活動任務(wù)，如果無活動任務(wù)，則不允許撤回
- snakerEngineFacets.getEngine().task().withdrawTask(taskId, operator);
抄送
實例的抄送類似于郵箱里面的抄送功能，一般用于將該流程實例抄送給領(lǐng)導(dǎo)查閱。
- 新增表wf_cc_order根據(jù)實例id、創(chuàng)建人、抄送人創(chuàng)建抄送記錄engine.order().createCCOrder(String orderId, String creator, String... actorIds)更新狀態(tài)用于更新抄送記錄為已經(jīng)閱讀engine.order().updateCCStatus(String orderId, String... actorIds)
加簽
加簽(增加另一人或多人的審批)
- engine.task().addTaskActor(String taskId, 1, String... actorIds)
會簽
會簽(通常用于審批后給相關(guān)的人簽字確認(rèn)，以獲得工作上的協(xié)調(diào)。)
snaker的會簽?zāi)壳跋鄬Ρ容^簡單，僅僅是根據(jù)任務(wù)節(jié)點的performType屬性值確定是否產(chǎn)生多個相同任務(wù)。
performType的值有兩種，分別是ANY、ALL。
ANY多個參與者時，任何一個完成任務(wù)即繼續(xù)流轉(zhuǎn) (或簽)
ALL多個參與者時，所有都需要完成任務(wù)才能繼續(xù)流轉(zhuǎn)
會簽只需要在流程定義時，將任務(wù)節(jié)點的屬性performType值設(shè)置為ALL即可，當(dāng)調(diào)用api時傳遞多個參與者時，則自動派發(fā)與參與者數(shù)量相同的任務(wù)。會簽任務(wù)必須等待所有參與者完成后，才繼續(xù)流轉(zhuǎn)
或簽
同上
已開源基于SnakerFlow輕量級工作流引擎的腳手架項目 easy-admin詳情參見：終于寫了個開源項目，easy-admin 為打造一款簡單、輕量級的后臺管理系統(tǒng)腳手架
