建立長期執行的工作流程服務

發行項
08/28/2024

本文說明如何建立長期執行的工作流程服務，此服務可以長時間執行。有時候，此工作流程可能會處於閒置狀態，等候其他資訊。發生這種情況時，此工作流程會保存至 SQL 資料庫並從記憶體中移除。當其他資訊可用時，此工作流程執行個體就會重新載入記憶體中並繼續執行。

在本案例中，您要實作非常簡化的訂購系統。用戶端會將初始訊息傳送至工作流程服務，以便啟動訂單。然後，服務會將訂單 ID 傳回給用戶端。此時，工作流程服務會等候用戶端的其他訊息、進入閒置狀態並保存至 SQL Server 資料庫。當用戶端傳送下一則訊息以訂購項目時，工作流程服務就會重新載入記憶體中，並且完成訂單處理作業。

在程式碼範例中，它會傳回一個字串，表示項目已經加入至訂單。此程式碼範例並非採用此技術的實際應用程式，而是說明長時間執行工作流程服務的簡單範例。

必要條件

您必須先安裝下列軟體，才能使用此逐步解說：

Microsoft SQL Server 2008
Visual Studio 2012
Microsoft .NET Framework 4.6.1

您還必須熟悉 WCF 和 Visual Studio 2012，並知道如何建立專案/方案。

設定 SQL Database

為了保存工作流程服務執行個體，您必須已經安裝 Microsoft SQL Server 而且必須設定資料庫來儲存已保存的工作流程執行個體。請按一下 [開始] 按鈕，然後依序選取 [所有程式]、[Microsoft SQL Server 2008] 和 [Microsoft SQL Management Studio]，藉以執行 Microsoft SQL Management Studio。
按一下 [連線] 按鈕，登入 SQL Server 執行個體
以滑鼠右鍵按一下樹狀檢視中的資料庫，然後選取新增資料庫，建立一個名為 SQLPersistenceStore 的新資料庫。
執行 SqlWorkflowInstanceStoreSchema.sql 指令碼檔 (位於 SQLPersistenceStore 資料庫的 C:\Windows\Microsoft.NET\Framework\v4.0\SQL\en 目錄中)，以便設定所需的資料庫結構描述。
執行 SqlWorkflowInstanceStoreLogic.sql 指令碼檔 (位於 SQLPersistenceStore 資料庫的 C:\Windows\Microsoft.NET\Framework\v4.0\SQL\en 目錄中)，以便設定所需的資料庫邏輯。

建立 Web 裝載的工作流程服務

建立空的 Visual Studio 2012 方案，將其命名為 OrderProcessing。
將名為 OrderService 的新 WCF 工作流程服務應用程式專案加入至此方案。
在 [專案屬性] 對話方塊中，選取 [Web] 索引標籤。
1. 在 [起始動作] 底下，選取 [特定頁面] 並指定 Service1.xamlx。
2. 在 [伺服器] 底下，選取 [使用本機 IIS Web 伺服器]。
  
  警告
  
  您必須以系統管理員模式執行 Visual Studio 2012，才能進行此設定。
  
  這兩個步驟會將工作流程服務專案設定為由 IIS 裝載。
開啟 Service1.xamlx (如果尚未開啟的話) 並刪除現有的 [ReceiveRequest] 和 [SendResponse] 活動。
選取 [循序服務] 活動、按一下 [變數] 連結，然後加入下圖所示的變數。這樣做就會加入一些之後將用於工作流程服務的變數。

注意

如果 CorrelationHandle 不在 [變數型別] 下拉式清單中，請從下拉式清單中選取 [瀏覽型別]。在 [型別名稱] 方塊中輸入 CorrelationHandle、從清單方塊中選取 CorrelationHandle，然後按一下 [確定]。
將 [ReceiveAndSendReply] 活動範本拖放至 [循序服務] 活動中。這組活動將會接收用戶端的訊息並傳回回覆。
1. 選取 [Receive] 活動，然後設定在下圖中反白顯示的屬性。
  
  DisplayName 屬性會針對設計工具中的 Receive 活動設定顯示名稱。 ServiceContractName 和 OperationName 屬性會指定 Receive 活動所實作之服務合約和作業的名稱。如需如何在工作流程服務中使用合約的詳細資訊，請參閱在工作流程中使用合約。
2. 按一下 ReceiveStartOrder 活動中的定義連結並設定下圖所示的屬性。請注意，[參數] 選項按鈕已選取，而且名為 p_customerName 的參數已繫結至 customerName 變數。這樣會將 [Receive] 活動設定為接收部分資料，並將該項資料繫結至區域變數。
3. 選取 [SendReplyToReceive] 活動，然後設定在下圖中反白顯示的屬性。
4. 按一下 SendReplyToStartOrder 活動中的定義連結並設定下圖所示的屬性。請注意，[參數] 選項按鈕已選取，而且名為 p_orderId 的參數已繫結至 orderId 變數。這項設定會指定 SendReplyToStartOrder 活動將字串型別的值傳回給呼叫端。
5. 將 Assign 活動拖放至 [Receive] 與 [SendReply] 活動之間，然後設定下圖所示的屬性：
  
  這樣就會建立新的訂單 ID 並將此值放入 orderId 變數中。
6. 選取 [ReplyToStartOrder] 活動。在 [屬性] 視窗中，按一下 [CorrelationInitializers] 的省略符號按鈕。選取 [新增初始設定式] 連結、在 [初始設定式] 文字方塊中輸入 orderIdHandle、針對 [相互關聯型別] 選取查詢相互關聯初始設定式，然後在 [XPATH 查詢] 下拉式方塊底下選取 p_orderId。下圖將顯示這些設定。按一下 [確定]。這樣就會初始化用戶端與這個工作流程服務執行個體之間的相互關聯。收到包含此訂單 ID 的訊息時，它就會路由傳送至這個工作流程服務執行個體。
將另一個 [ReceiveAndSendReply] 活動拖放至工作流程的結尾 (包含第一個 [Receive] 和 [SendReply] 活動的 [序列] 以外)。這樣就會接收用戶端所傳送的第二則訊息並回應訊息。
1. 選取包含新增 [Receive] 和 [SendReply] 活動的 [序列]，然後按一下 [變數] 按鈕。加入在下圖中反白顯示的變數：
  
  同時在 Sequence 範圍中將 orderResult 新增為 String。
2. 選取 [Receive] 活動，然後設定下圖所示的屬性：
  
  注意
  
  別忘了使用 ../IAddItem 變更 ServiceContractName 欄位。
3. 按一下 ReceiveAddItem 活動中的定義連結並新增下圖所示的參數：這將接收活動設定為接受兩個參數：訂單識別碼和所訂購項目的識別碼。
4. 按一下 [CorrelateOn] 省略符號按鈕並輸入 orderIdHandle。在 [XPath 查詢] 底下，按一下下拉式箭號並選取 p_orderId。這樣就會設定第二個 Receive 活動的相互關聯。如需相互關聯的詳細資訊，請參閱相互關聯。
5. 將 [If] 活動拖放至緊接在 [ReceiveAddItem] 活動後面。這個活動的運作方式就如同 if 陳述式。
  1. 將 [Condition] 屬性設定為 itemId=="Zune HD" (itemId="Zune HD" for Visual Basic)
  2. 將 [Assign] 活動拖放至 [Then] 區段中、將另一個活動拖放至 [Else] 區段中，然後設定 [Assign] 活動的屬性，如下圖所示。
    
    如果條件為 true，就會執行 [Then] 區段。如果條件為 false，則會執行 [Else] 區段。
  3. 選取 [SendReplyToReceive] 活動，然後設定下圖所示的 [DisplayName] 屬性。
  4. 按一下 SetReplyToAddItem 活動中的定義連結，並對其進行設定，如下圖所示。這樣就會將 [SendReplyToAddItem] 活動設定為傳回 orderResult 變數的值。

開啟 web.config 檔案並在 <behavior> 區段中加入下列項目，以便啟用工作流程持續性。 (確保完成連接字串)。

<sqlWorkflowInstanceStore connectionString="...;Asynchronous Processing=True" instanceEncodingOption="None" instanceCompletionAction="DeleteAll" instanceLockedExceptionAction="BasicRetry" hostLockRenewalPeriod="00:00:30" runnableInstancesDetectionPeriod="00:00:02" />
          <workflowIdle timeToUnload="0"/>

建置方案。

建立用戶端應用程式來呼叫工作流程服務

將名為 OrderClient 的新主控台應用程式專案加入至方案。
將下列組件的參考加入至 OrderClient 專案。
1. System.ServiceModel.dll
2. System.ServiceModel.Activities.dll
將服務參考加入至工作流程服務並將 OrderService 指定為命名空間。

在用戶端專案的 Main() 方法中，加入下列程式碼：

static void Main(string[] args)
{
   // Send initial message to start the workflow service
   Console.WriteLine("Sending start message");
   StartOrderClient startProxy = new StartOrderClient();
   string orderId = startProxy.StartOrder("Kim Abercrombie");

   // The workflow service is now waiting for the second message to be sent
   Console.WriteLine("Workflow service is idle...");
   Console.WriteLine("Press [ENTER] to send an add item message to reactivate the workflow service...");
   Console.ReadLine();

   // Send the second message
   Console.WriteLine("Sending add item message");
   AddItemClient addProxy = new AddItemClient();
   AddItem item = new AddItem();
   item.p_itemId = "Zune HD";
   item.p_orderId = orderId;

   string orderResult = addProxy.AddItem(item);
   Console.WriteLine("Service returned: " + orderResult);
}

建置方案並執行 OrderClient 應用程式。用戶端就會顯示下列文字：

Sending start messageWorkflow service is idle...Press [ENTER] to send an add item message to reactivate the workflow service...

若要確認工作流程服務已保存，請移至 [開始] 功能表，然後依序選取 [所有程式]、[Microsoft SQL Server 2008] 和 [SQL Server Management Studio]，藉以啟動 SQL Server Management Studio。
1. 在左側窗格中，依序展開 [資料庫]、[SQLPersistenceStore] 和 [檢視]、以滑鼠右鍵按一下 [System.Activities.DurableInstancing.Instances]，然後選取 [選取前 1000 個資料列]。在 [結果] 窗格中，確認您至少看見列出一個執行個體。如果執行時發生例外狀況，可能會有先前執行的其他執行個體。您可以用滑鼠右鍵按一下 [System.Activities.DurableInstancing.Instances]、選取 [編輯前 200 個資料列]、按下 [執行] 按鈕、選取 [結果] 窗格中的所有資料列，然後選取 [刪除]，藉以刪除現有的資料列。若要確認顯示在資料庫中的執行個體就是應用程式所建立的執行個體，請先確認 Instances 檢視表是空的，然後再執行用戶端。一旦用戶端執行之後，請重新執行查詢 (選取前 1000 個資料列) 並確認已經加入新的執行個體。
按下 Enter，將 add item 訊息傳送至工作流程服務。用戶端就會顯示下列文字：
```
Sending add item messageService returned: Item added to orderPress any key to continue . . .
```

另請參閱

工作流程服務

共用方式為