工作流數據的持久化處理方法、裝置及工作流系統的製作方法

2023-09-21 18:58:25

專利名稱：工作流數據的持久化處理方法、裝置及工作流系統的製作方法
技術領域：
本發明涉及計算機系統數據處理領域，特別涉及一種工作流數據的 持久化處理方法、 一種工作流數據的持久化處理裝置以及一種工作流系 統。
背景技術：
持久化(Persistence),即把數據(如內存中的對象)保存到可永久 保存的存儲設備中(如磁碟)。在實際中，持久化的主要應用是將內存中 的數據存儲在關係型的資料庫中，當然也可以存儲在磁碟文件中、XML 數據文件中等等。持久化技術可以封裝數據訪問細節，為大部分業務邏 輯提供面向對象的API。因而，通過持久化技術可以減少訪問資料庫數據 次數，增加應用程式執行速度；並且，代碼重用性高，能夠完成大部分 資料庫操作；以及，鬆散耦合，使持久化不依賴於底層資料庫和上層業 務邏輯實現，更換資料庫時只需修改配置文件而不用修改代碼。由於上 述特性，持久化技術被廣泛應用在各種計算機系統中，如工作流系統等。
計算機系統在運行過程中，通常會產生大量的數據，可以理解的是， 數據持久化的處理勢必會對計算機系統帶來較大的性能消耗，這種性能 消耗又會直接影響持久化的處理效率，尤其在數據量較大時，持久化處 理效率過低的問題更為嚴重。以工作流系統為例，由於工作流系統的運 行過程通常都會包括複雜的業務流程，所以在運行過程中會產生大量的 工作流數據持久化請求，如流程中多個活動、任務等內部對象的狀態改 變等，這種工作流系統的數據持久化過程為普通的資料庫持久化過程， 即工作流系統通過自身的數據持久化接口 ，根據相應工作流數據的持久 化請求，直接將該工作流數據關聯加載至資料庫中，顯然，這種處理過 程將過度佔用系統資源，從而引發持久化低效的問題。
因此，本領域技術人員迫切需要發展出 一種可以有效提高數據持久 化處理效率的方法及裝置。

發明內容
本發明所要解決的技術問題是提供一種工作流數據的持久化處理方 法，用以解決現有技術中數據持久化效率較低的問題。
本發明還提供了 一種工作流數據的持久化處理裝置和 一種工作流系 統，用以保證上述方法在實際中的實現及應用。
為解決上述技術問題，本發明實施例公開了 一種工作流數據的持久
化處理方法，包括 啟動工作流事務；
根據所述工作流事務中工作流數據的改變，記錄所述工作流數據改 變前後的內存快照；
對比所述工作流數據的在當前工作流事務中的所有內存快照，獲得 特徵內存快照；
根據所述特徵內存快照發出持久化請求。
優選的是，通過以下步驟獲得所述特徵內存快照
獲取具有最小改變量的內存快照為特徵內存快照。
優選的是，所述特徵內存快照包括所述工作流數據初始狀態的內存 快照和最終狀態的內存快照。
優選的是，所述的方法，還包括
按照所述持久化請求對所述工作流數據進行持久化處理。
本發明實施例還公開了 一種工作流數據的持久化處理裝置，包括
啟動單元，用於啟動工作流事務；
內存快照單元，用於根據所述工作流事務中工作流數據的改變，記 錄所述工作流數據改變前後的內存快照；
對比單元，用於對比所述工作流數據的在當前工作流事務中的所有 內存快照，獲得特徵內存快照；
請求單元，用於根據所述特徵內存快照發出持久化請求。
優選的是，所述對比單元還包括
獲取子單元，用於獲取具有最小改變量的內存快照為特徵內存快照。 優選的是，所述特徵內存快照包括所述工作流數據初始狀態的內存
快照和最終狀態的內存快照。
優選的是，所述的裝置，還包括
處理單元，用於按照所述持久化請求對所述工作流數據進行持久化 處理。
本發明實施例還公開了一種工作流系統，包括 工作流執行器，用於接受業務請求，並通知工作流事務管理器的啟 動單元；
工作流事務管理器，包括啟動單元、執行單元和請求單元；所述啟 動單元用於啟動工作流事務；所述執行單元用於執行當前工作流事務中 工作流數據的修改；所述請求單元用於根據特徵內存快照發出持久化請 求；
工作流持久化管理器，包括內存快照單元和對比單元；所述內存快 照單元用於根據所述工作流數據的改變，記錄所述工作流數據改變前後 的內存快照；所述對比單元用於對比所述工作流數據的在當前工作流事 務中的所有內存快照，獲得特徵內存快照。
優選的是，所述對比單元還包括
獲取子單元，用於獲取具有最小改變量的內存快照為特徵內存快照。 優選的是，所述特徵內存快照包括所述工作流數據初始狀態的內存 快照和最終狀態的內存快照。
優選的是，所述工作流持久化管理器還包括
處理單元，用於按照所述持久化請求對所述工作流數據進行持久化 處理。
與現有4支術相比，本發明實施例具有以下優點
應用本發明，在工作流事務中，當需要修改工作流數據時，並不是 直接向發出持久化請求，而是記錄工作流數據在》務改前後的內存快照， 此時真正的數據持久化操作並未進行，而是被延遲到工作流事務提交時 進行。在工作流事務提交時，通過對比內存快照得到特徵內存快照後， 才根據該特徵內存快照發出持久化請求，因而可以有效提高工作流數據 持久化的處理效率。


圖1是本發明的一種工作流數據的持久化處理方法實施例的流程圖； 圖2是本發明的一種工作流數據的持久化處理裝置實施例的結構框
圖3是應用圖2所示的優選實施例持久化處理工作流數據的流程圖； 圖4是本發明的一種工作流系統實施例的結構框圖； 圖5是一種應用圖4所示的優選實施例在實際中進行工作流數據持 久化處理的流程圖。
具體實施例方式
為使本發明的上述目的、特徵和優點能夠更加明顯易懂，下面結合 附圖和具體實施方式
對本發明作進一步詳細的說明。
本發明實施例的核心構思之一在於，啟動工作流事務後，對於在同 一個工作流事務內，工作流內部對象的任何持久化操作都通過內存快照
的方式記錄下來，但此時不進行真正的數據持久化操作，而是延遲到工 作流事務提交時進行。即在工作流事務提交時，通過對比工作流數據的 內存快照進行持久化請求合併與批量處理，從而有效提高了工作流數據 持久化的處理效率。
參考圖1，示出了本發明的一種工作流數據的持久化處理方法實施例 的流程圖，具體可以包括以下步驟
步驟IOI、啟動工作流事務；
步驟102、根據所述工作流事務中工作流數據的改變，記錄所述工作 流數據改變前後的內存快照；
步驟103、對比所述工作流數據的在當前工作流事務中的所有內存快 照，獲得特徵內存快照；
步驟104、根據所述特徵內存快照發出持久化請求。
根據WfMC的定義，工作流(Work Flow)就是自動運作的業務過 程部分或整體，表現為參與者對文件、信息或任務按照規程採取行動， 並令其在參與者之間傳遞。簡單地說，工作流就是一系列相互銜接、自 動進行的業務活動或任務。其中，工作流數據是指工作流系統內部對象
的狀態數據，而工作流系統內部對象是指工作流系統在執行流程時產生 的內部對象，包括流程對象、活動對象、任務對象等等。內存快照是記
錄某 一 時刻在系統內存中的對象狀態信息的拷貝。而工作流事務是在數 據庫事務基礎上由工作流系統擴展出來的工作流處理事務。而事務是一
個最小的工作單元，不論成功與否事務都作為一個整體進行工作。由於 事務通常是由幾個任務組成的，因此如果一個事務作為一個整體是成功 的，則事務中的每個任務都必須是成功的。如果事務中有一部分失敗， 則整個事務也必然是失敗的。即事務具有原子性， 一致性，隔離性，持 久性的特點。
從上可以得知，本發明實施例所述的工作流事務具體以下特徵(1) 具有明確的事務邊界對於工作流系統來說，事務的發起與結束都是它 來控制，所以知道工作流事務的邊界。(2)在事務內能夠通過內存的方 式管理被持久化對象的生命周期。在工作流事務中，需要持久化的對象 (工作流數據)都是在工作流系統內的，並且由工作流系統來管理它的 生命周期，所以能夠通過"內存快照，，的方式對持久化請求進行優化。
在實際中，工作流事務可以才艮據業務請求而啟動，啟動工作流事務， 並準備上下文信息。應用本實施例中，當改變工作流內部對象狀態並且 需要持久化時，則觸發當前工作流內部對象狀態數據(即工作流數據) 的以內存快照(即內存拷貝)的方式進行記錄，即記錄下改變前的內存 快照；然後，改變內存中的該工作流數據，並以內存快照的方式將該改 變後的工作流數據記錄下來。
在本實施例中，在工作流事務未提交時，不進行持久化操作，只有 在提交工作流事務時，才通過對比內存快照以獲得具有最小改變量的特 徵內存快照，然後才根據該特徵內存快照發出持久化請求。在實際中， 所述特徵內存快照通常可以包括反映所述工作流數據初始狀態的內存快 照和最終狀態的內存快照。
當然，本領域技術人員採用現有技術中的任一種內存快照的記錄方 法都是可行的，本發明對此不需要進行限定。
在實際中，本領域技術員還可以結合實際需要釆用其它獲得特徵內 存的方法，例如，採用刷新內存快照的方式，即不斷以新生成的內存快 照替換原來的內存快照，或固定提取某個工作流事務中某個工作流數據 最初狀態的內存快照和某個特徵中間狀態的內存快照的方式等，本發明 對此不作限制。為使本領域技術人員更好地理解本發明，以下通過具體實例對本發 明的工作流數據持久化處理過程進行說明。以工作流活動實例為例，假設在工作流流程運行中， 一個活動實例的生命周期如下(1) 創建活動實例，並且設置活動狀態為未初始化；(2) 設置活動狀態為未啟動(即活動的初始化狀態)；(3) 設置活動狀態為運行中(即活動的執行狀態)；(4) 設置活動狀態為完成(即活動的結束狀態)。假設這三個狀態的變化在 一 個工作流事務中，應用本實施例的處理 過程如下步驟S1、啟動工作流事務；步驟S2、在內存中創建活動實例，記錄改變前後的內存快照； 改變前(活動實例創建前)的內存快照為無，改變後(活動實例創建後)的內存快照為有，且活動實例狀態為未初始化。步驟S3、記錄(2)(設置活動狀態為未啟動)改變前後的內存快照； 改變前的內存快照為活動實例狀態為未初始化，改變後的內存快照為活動實例狀態為未啟動。步驟S4、記錄(3)(設置活動狀態為運行中)改變前後的內存快照； 改變前的內存快照為活動實例狀態為未啟動，改變後的內存快照為活動實例狀態為運行中。步驟S5、記錄(4)(設置活動狀態為完成)改變前後的內存快照； 改變前的內存快照為活動實例狀態為運行中，改變後的內存快照為活動實例狀態為完成。步驟S6、通過比較上述內存快照，發現該活動實例的最小改變量就是活動實例創建前的內存快照和活動實例狀態為完成的內存快照的變化量，因此向資料庫發出創建狀態為完成的活動實例的持久化請求。 通過上例可以看出，當採用現有技術的方法，則需要提交4次持久化 請求，即插入數據、第一次更新數據、第二次更新數據和第三次更新數據的請求；而採用本發明實施例，則只需要提交一次資料庫持久化請求， 因而本發明有效提高了工作流數據持久化處理的效率。在實際中，通過確定具有最小改變量的內存快照發起持久化請求，通 常可以對以下情形進行處理一、 同實例的數據持久化操作的合併，具體可以分為( 一 )將"同 一 實例同 一屬性的多次持久化請求"合併為"同 一 實例同 一屬性的一次持久化請求"處理；(二 )將"對同 一實例不同屬性的多次持久化請求"合併為"對同 一 實 例多個不同屬性的一次持久化請求"；二、 將"同類型多個實例的多次持久化請求"合併為"批處理同類型實 例的一次持久化請求"；顯然，當進行數據量較大的持久化操作時，本發 明的優勢更為突出。為使本領域技術人員更好地理解本發明，以下通過舉例對上述(一) 的情況具體說明。假設對象A在工作流事務中經歷"創建對象"和"兩次修改對象的al 屬性值，第一次將0改為1,第二次將1改為2"的過程，應用本發明實施 例進行持久化請求合併的過程為1) 記錄對象創建前後的內存快照 創建前快照Snapshotl快照內容空，因為此時對象A不存在。 創建後快照Snapshot2快照內容內存中對象A的拷貝，並且其屬性al的初始值為0。2) 第一次修改對象A的al屬性，將初始值0改為1的前後內存快照〃修改前快照Snapshot3快照內容內存中對象A的拷貝，其屬性al的初始值為0。 修改後快照Snapshot4快照內容內存中對象A的拷貝，其屬性al的初始值為l。3)第二次修改對象A的al屬性，將初始值1為改為2的前後內存 快照修改前快照Snapshot5快照內容內存中對象A的拷貝，其屬性al的初始值為l。 修改後快照Snapshot6快照內容內存中對象A的拷貝，其屬性al的初始值為2。 當事務提交時，提取當前存在的6個關於對象A的內存快照 Snapshotl 、 Snapshot2、 Snapshot3、 Snapshot4、 Snapshot5、 Snapshot6， 經過內存快照對比處理後，發現對象A的最小改變量就是Snapshotl和 Snapshot6的變化量，所以在持久化時只需要創建屬性al值為2的對象A 即可，即將多次持久化請求合併成一次持久化請求。 優選的是，本實施例還可以包括步驟 按照所述持久化請求對所述工作流數據進行持久化處理。 公知的是，持久化用於將工作流實例數據保存在一個持久存儲，比 如SQL資料庫，對於本實施而言，採用現有技術中的任一種持久化處理 方法對工作流數據進行持久化處理都是可行的，本發明對此就不贅述了 。參考圖2,示出了本發明的一種工作流數據的持久化處理裝置實施例 的結構框圖，具體可以包括以下單元啟動單元201,用於啟動工作流事務；內存快照單元202,用於根據所述工作流事務中工作流數據的改變， 記錄所述工作流數據改變前後的內存快照；對比單元203,用於對比所述工作流數據的在當前工作流事務中的所 有內存快照，獲得特徵內存快照；請求單元204,用於根據所述特徵內存快照發出持久化請求。優選的是，在本實施例中，所述對比單元203還可以包括獲取子單 元，用於獲取具有最小改變量的內存快照為特徵內存快照。在本實施例 中，所述特徵內存快照通常可以包括反映所述工作流數據初始狀態的內 存'決照和最終狀態的內存快照。優選的是，本實施例還可以包括處理單元，用於按照所述持久化請求對所述工作流數據進行持久化處理。參考圖3，示出了應用圖2所示的優選實施例持久化處理工作流數據 的流程圖，具體可以包括以下步驟步驟301、啟動單元啟動工作流事務；步驟302、內存快照單元根據所述工作流事務中工作流數據的改變， 記錄所述工作流數據改變前後的內存'決照；步驟303、對比單元對比所述工作流數據的在當前工作流事務中的所 有內存快照，獲得特徵內存快照；步驟304、請求單元根據所述特徵內存快照發出持久化請求。對於圖2所示的裝置實施例而言，由於其基本相應於圖1所示的方 法實施例，所以描述比較簡單，相關之處參見方法實施例的部分說明即 可。參考圖4，示出了本發明的一種工作流系統實施例的結構框圖，具體 可以包括以下裝置工作流執行器401，用於接受業務請求，並通知工作流事務管理器的 啟動單元；工作流事務管理器402，包括啟動單元4021、執行單元4022和請求 單元4033;所述啟動單元4021用於啟動工作流事務；所述執行單元4022 用於執行當前工作流事務中工作流數據的^f務改；所述請求單元4023用於 根據特徵內存快照發出持久化請求；工作流持久化管理器403,包括內存快照單元4031和對比單元4032; 所述內存快照單元4031用於根據所述工作流數據的改變，記錄所述工作 流數據改變前後的內存快照；所述對比單元4032用於對比所述工作流數 據的在當前工作流事務中的所有內存快照，獲得特徵內存快照。優選的是，在本實施例中，所述對比單元還可以包括獲取子單元， 用於獲取具有最小改變量的內存快照為特徵內存快照。在本實施例中， 所述特徵內存快照通常可以包括反映所述工作流數據初始狀態的內存快 照和最終狀態的內存快照。在本實施例中，所述工作流持久化管理器還可以包括處理單元，用
於按照所述持久化請求對所述工作流數據進行持久化處理。參考圖5,示出了應用圖4所示的優選實施例在實際中進行工作流數 據持久化處理的流程圖，具體可以包括以下步驟 1、工作流執行器處理工作流務請求； 1.1工作流執行器通知工作流事務管理器啟動工作流事務； 啟動工作流事務，並準備上下文信息。 1.2需要改變工作流內部對象狀態且需持久化； 即遇到持久點。1.2.1工作流數據改變前通知工作流持久化管理器記錄工作流數據 改變前的內存快照；1.2.2改變內存中的工作流lt據；1.2.3工作流數據改變前通知工作流持久化管理器記錄工作流數據 改變後的內存快照。1.3提交工作流事務；1.3.1由工作流事務管理器向工作流持久化管理器發出提交持久化 請求。1.3.1.1工作流持久化管理器通過對比內存快照來合併持久化請求， 最終根據最小的數據改變量發出真正的持久化請求。由於在工作流事務中，持久化對象的生命周期由工作流系統來管理， 工作流系統知道某個對象或某類對象在一個工作流事務中被創建、被修 改、甚至被刪除的情況，所以工作流系統就可以通過監控內存對象的變 化情況來得到最小改變量。為使本領域技術人員更好地理解本發明，以下通過具體實例對本發 明的工作流系統對工作流數據進行持久化處理的過程進行說明。以工作流活動實例為例，，i設在工作流流程運行中， 一個活動實例 的生命周期如下(1) 創建活動實例，並且設置活動狀態為未初始化；(2) 設置活動狀態為未啟動(即活動的初始化狀態)；(3) 設置活動狀態為運行中(即活動的執行狀態)；(4) 設置活動狀態為完成(即活動的結束狀態)。
假設這三個狀態的變化在一個工作流事務中，應用本實施例的處理過程如下步驟Sll、工作流執行器通過工作流事務管理器啟動工作流事務； 步驟S12、在內存中創建活動實例，工作流持久化管理器記錄改變前 後的內存快照；改變前(活動實例創建前)的內存快照為無，改變後(活動實例創 建後)的內存快照為有，且活動實例狀態為未初始化。步驟S13、工作流持久化管理器記錄(2)(設置活動狀態為未啟動) 改變前後的內存快照；改變前的內存快照為活動實例狀態為未初始化，改變後的內存快照 為活動實例狀態為未啟動。步驟S14、工作流持久化管理器記錄(3)(設置活動狀態為運行中) 改變前後的內存快照；改變前的內存快照為活動實例狀態為未啟動，改變後的內存快照為 活動實例狀態為運行中。步驟S15、工作流持久化管理器記錄(4)(設置活動狀態為完成)改 變前後的內存快照；改變前的內存快照為活動實例狀態為運行中，改變後的內存快照為 活動實例狀態為完成。步驟S16、工作流執行器通過工作流事務管理器發出事務提交請求， 觸發工作流持久化管理器比較上述內存快照，發現該活動實例的最小改 變量就是活動實例創建前的內存快照和活動實例狀態為完成的內存快照 的變化量，因此向資料庫發出創建狀態為完成的活動實例的持久化請求。對於圖4所示的系統實施例而言，由於其基本相應於前述方法和裝 置實施例，所以描述較為簡單，相關之處參見方法實施例的部分說明即 可。本發明可以用於眾多通用或專用的計算系統環境或配置中。例如 個人計算機、伺服器計算機、手持設備或可攜式設備、平板型設備、多 處理器系統、基於微處理器的系統、置頂盒、可編程的消費電子設備、 網絡PC、小型計算機、大型計算機、包括以上任何系統或設備的分布式
計算環境等等。此外，本發明還可以在由計算機執行的計算機可執行指 令的一般上下文中描述，例如程序模塊。 一般地，程序模塊包括執行特 定任務或實現特定抽象數據類型的例程、程序、對象、組件、數據結構 等等。也可以在分布式計算環境中實踐本發明，在這些分布式計算環境 中，由通過通訊網絡而被連接的遠程處理設備來執行任務。在分布式計 算環境中，程序模塊可以位於包括存儲設備在內的本地和遠程計算機存 儲介質中。以上對本發明所提供的 一種工作流數據的持久化處理方法、 一種工作 流數據的持久化處理裝置以及一種工作流系統進行了詳細介紹，本文中說明只是用於幫助理解本發明的方法及其核心思想；同時，對於本領域的一般技術人員，依據本發明的思想，在具體實施方式
及應用範圍上均 會有改變之處，綜上所述，本說明書內容不應理解為對本發明的限制。
權利要求
1、 一種工作流數據的持久化處理方法，其特徵在於，包括 啟動工作流事務；根據所述工作流事務中工作流數據的改變，記錄所述工作流數據改 變前後的內存快照；對比所述工作流數據的在當前工作流事務中的所有內存快照，獲得 特徵內存快照；根據所述特徵內存快照發出持久化請求。
2、 如權利要求l所述的方法，其特徵在於，通過以下步驟獲得所述 特徵內存快照獲取具有最小改變量的內存快照為特徵內存快照。
3、 如權利要求2所述的方法，其特徵在於，所述特徵內存快照包括 所述工作流數據初始狀態的內存快照和最終狀態的內存快照。
4、 如權利要求l、 2或3所述的方法，其特徵在於，還包括 按照所述持久化請求對所述工作流數據進行持久化處理。
5、 一種工作流數據的持久化處理裝置，其特徵在於，包括 啟動單元，用於啟動工作流事務；內存快照單元，用於根據所述工作流事務中工作流數據的改變，記 錄所述工作流數據改變前後的內存快照；對比單元，用於對比所述工作流數據的在當前工作流事務中的所有 內存快照，獲得特徵內存快照；請求單元，用於根據所述特徵內存快照發出持久化請求。
6、 如權利要求5所述的裝置，其特徵在於，所述對比單元還包括 獲取子單元，用於獲取具有最小改變量的內存快照為特徵內存快照。
7、 如權利要求6所述的裝置，其特徵在於，所述特徵內存快照包括 所述工作流數據初始狀態的內存快照和最終狀態的內存快照。
8、 如權利要求5、 6或7所述的裝置，其特徵在於，還包括 處理單元，用於按照所述持久化請求對所述工作流數據進行持久化處理。
9、 一種工作流系統，其特徵在於，包括工作流執行器，用於接受業務請求，並通知工作流事務管理器的啟 動單元；工作流事務管理器，包括啟動單元、執行單元和請求單元；所述啟 動單元用於啟動工作流事務；所述執行單元用於執行當前工作流事務中 工作流數據的修改；所述請求單元用於根據特徵內存快照發出持久化請 求；工作流持久化管理器，包括內存快照單元和對比單元；所述內存快 照單元用於根據所述工作流數據的改變，記錄所述工作流數據改變前後 的內存快照；所述對比單元用於對比所述工作流數據的在當前工作流事 務中的所有內存快照，獲得特徵內存快照。
10、 如權利要求9所述的系統，其特徵在於，所述對比單元還包括 獲取子單元，用於獲取具有最小改變量的內存快照為特徵內存快照。
11、 如權利要求IO所述的系統，其特徵在於，所述特徵內存快照包 括所述工作流數據初始狀態的內存快照和最終狀態的內存快照。
12、 如權利要求9、 10或11所述的裝置，其特徵在於，所述工作流 持久化管理器還包括處理單元，用於按照所述持久化請求對所述工作流數據進行持久化 處理。
全文摘要
本發明公開了一種工作流數據的持久化處理方法，包括啟動工作流事務；根據所述工作流事務中工作流數據的改變，記錄所述工作流數據改變前後的內存快照；對比所述工作流數據的在當前工作流事務中的所有內存快照，獲得特徵內存快照；根據所述特徵內存快照發出持久化請求。應用本發明，在工作流事務中，當需要修改工作流數據時，並不是直接向發出持久化請求，而是記錄工作流數據在修改前後的內存快照，此時真正的數據持久化操作並未進行，而是被延遲到工作流事務提交時進行。在工作流事務提交時，通過對比內存快照得到特徵內存快照後，才根據該特徵內存快照發出持久化請求，因而可以有效提高工作流數據持久化的處理效率。
文檔編號G06F17/30GK101145165SQ200710166038
公開日2008年3月19日 申請日期2007年10月30日 優先權日2007年10月30日
發明者剛 周, 凱 宋 申請人:金蝶軟體(中國)有限公司