ワークフローサービスとの間のトランザクションのフロー

2025-06-22

ワークフローサービスとクライアントはトランザクションに参加できます。サービス操作をアンビエントトランザクションの一部にするには、TransactedReceiveScope アクティビティ内にReceive アクティビティを配置します。 TransactedReceiveScope内のSendまたはSendReply アクティビティによって行われた呼び出しも、アンビエントトランザクション内で行われます。ワークフロークライアントアプリケーションは、 TransactionScope アクティビティを使用してアンビエントトランザクションを作成し、アンビエントトランザクションを使用してサービス操作を呼び出すことができます。このトピックでは、トランザクションに参加するワークフローサービスとワークフロークライアントを作成する手順について説明します。

Warnung

ワークフローサービスインスタンスがトランザクション内に読み込まれ、ワークフローに Persist アクティビティが含まれている場合、ワークフローインスタンスはトランザクションがタイムアウトするまでブロックされます。

Von Bedeutung

TransactedReceiveScopeを使用する場合は常に、すべての受信をTransactedReceiveScopeアクティビティ内のワークフローに配置することをお勧めします。

Von Bedeutung

TransactedReceiveScopeを使用し、メッセージが正しくない順序で到着すると、最初の順序外メッセージを配信しようとするとワークフローが中止されます。ワークフローがアイドル状態になったときに、ワークフローが常に一貫した停止ポイントにあることを確認する必要があります。これにより、ワークフローを中止した場合に、以前の永続化ポイントからワークフローを再起動できます。

共有ライブラリを作成する

新しい空の Visual Studio ソリューションを作成します。
Commonという名前の新しいクラスライブラリプロジェクトを追加します。次のアセンブリへの参照を追加します。
- System.Activities.dll
- System.ServiceModel.dll
- System.ServiceModel.Activities.dll
- System.Transactions.dll

Common プロジェクトに PrintTransactionInfo という新しいクラスを追加します。このクラスは NativeActivity から派生し、 Execute メソッドをオーバーロードします。

using System;  
using System;  
using System.Activities;  
using System.Transactions;  

namespace Common  
{  
    public class PrintTransactionInfo : NativeActivity  
    {  
        protected override void Execute(NativeActivityContext context)  
        {  
            RuntimeTransactionHandle rth = context.Properties.Find(typeof(RuntimeTransactionHandle).FullName) as RuntimeTransactionHandle;  

            if (rth == null)  
            {  
                Console.WriteLine("There is no ambient RuntimeTransactionHandle");  
            }  

            Transaction t = rth.GetCurrentTransaction(context);  

            if (t == null)  
            {  
                Console.WriteLine("There is no ambient transaction");  
            }  
            else  
            {  
                Console.WriteLine("Transaction: {0} is {1}", t.TransactionInformation.DistributedIdentifier, t.TransactionInformation.Status);  
            }  
        }  
    }  

}

これは、アンビエントトランザクションに関する情報を表示するネイティブアクティビティであり、このトピックで使用されるサービスワークフローとクライアントワークフローの両方で使用されます。ツールボックスの [共通 ] セクションでこのアクティビティを使用できるようにするためのソリューションをビルド します。

ワークフローサービスを実装する

WorkflowServiceと呼ばれる新しい WCF ワークフローサービスをCommon プロジェクトに追加します。これを行うには、Common プロジェクトを右クリックし、[追加]、[新しい項目]、[インストールされているテンプレート] の [ワークフロー] の順に選択し、[WCF ワークフローサービス] を選択します。
既定の ReceiveRequest と SendResponse アクティビティを削除します。
WriteLine アクティビティをSequential Service アクティビティにドラッグアンドドロップします。次の例に示すように、text プロパティを "Workflow Service starting ..." に設定します。

![順次サービスアクティビティへの WriteLine アクティビティの追加 (./media/flowing-transactions-into-and-out-of-workflow-services/add-writeline-sequential-service.jpg)
WriteLine アクティビティの後にTransactedReceiveScopeをドラッグアンドドロップします。 TransactedReceiveScopeアクティビティは、ツールボックスの [メッセージング] セクションにあります。 TransactedReceiveScope アクティビティは、要求と本文の 2 つのセクションで構成されます。 [要求] セクションには、Receiveアクティビティが含まれています。 [本文] セクションには、メッセージの受信後にトランザクション内で実行するアクティビティが含まれます。
TransactedReceiveScopeアクティビティを選択し、[変数] ボタンをクリックします。次の変数を追加します。

注

既定で存在するデータ変数を削除できます。既存のハンドル変数を使用することもできます。
TransactedReceiveScope アクティビティの [要求] セクション内で、Receive アクティビティをドラッグアンドドロップします。次のようにプロパティを設定します。

プロパティ価値

CanCreateInstance True (チェックボックスをオン)

オペレーションネーム StartSample

ServiceContractName ITransactionSample

ワークフローは次のようになります。
Receive アクティビティの [定義...] リンクをクリックし、次の設定を行います。
TransactedReceiveScopeの [本文] セクションにSequenceアクティビティをドラッグアンドドロップします。 Sequence アクティビティ内で、2 つのWriteLine アクティビティをドラッグアンドドロップし、次の表に示すようにTextプロパティを設定します。

活動価値

1st WriteLine "サービス: 受信完了"

2 番目の WriteLine "Service: Received = " + requestMessage

ワークフローは次のようになります。
TransactedReceiveScope アクティビティの Body の 2 番目のWriteLine アクティビティの後に、PrintTransactionInfo アクティビティをドラッグアンドドロップします。
PrintTransactionInfo アクティビティの後にAssign アクティビティをドラッグアンドドロップし、次の表に従ってプロパティを設定します。

プロパティ価値

移行先 replyMessage

価値 "サービス: 応答の送信"
Assign アクティビティの後にWriteLine アクティビティをドラッグアンドドロップし、そのText プロパティを "Service: Begin reply" に設定します。

ワークフローは次のようになります。
Receive アクティビティを右クリックし、[SendReply の作成] を選択し、最後のWriteLine アクティビティの後に貼り付けます。 SendReplyToReceive アクティビティの [定義...] リンクをクリックし、次の設定を行います。
SendReplyToReceive アクティビティの後にWriteLine アクティビティをドラッグアンドドロップし、Text プロパティを "Service: Reply sent" に設定します。
ワークフローの下部にある WriteLine アクティビティをドラッグアンドドロップし、その Text プロパティを "サービス: ワークフローの終了、Enter キーを押して終了" に設定します。

完成したサービスワークフローは次のようになります。

プロパティ	価値
CanCreateInstance	True (チェックボックスをオン)
オペレーションネーム	StartSample
ServiceContractName	ITransactionSample

活動	価値
1st WriteLine	"サービス: 受信完了"
2 番目の WriteLine	"Service: Received = " + requestMessage

プロパティ	価値
移行先	replyMessage
価値	"サービス: 応答の送信"

ワークフロークライアントを実装する

WorkflowClientと呼ばれる新しい WCF ワークフローアプリケーションをCommon プロジェクトに追加します。これを行うには、Common プロジェクトを右クリックし、[追加]、[新しい項目]、[インストールされているテンプレート] の下の [ワークフロー] の順に選択し、[アクティビティ] を選択します。
Sequence アクティビティをデザインサーフェイスにドラッグアンドドロップします。
Sequence アクティビティ内で、WriteLine アクティビティをドラッグアンドドロップし、そのTextプロパティを"Client: Workflow starting"に設定します。ワークフローは次のようになります。
WriteLine アクティビティの後にTransactionScope アクティビティをドラッグアンドドロップします。 TransactionScopeアクティビティを選択し、[変数] ボタンをクリックして、次の変数を追加します。
TransactionScope アクティビティの本文にSequence アクティビティをドラッグアンドドロップします。
内の PrintTransactionInfo アクティビティをドラッグアンドドロップします。 Sequence
PrintTransactionInfo アクティビティの後にWriteLine アクティビティをドラッグアンドドロップし、そのText プロパティを "Client: Beginning Send" に設定します。ワークフローは次のようになります。
Assign アクティビティの後にSend アクティビティをドラッグアンドドロップし、次のプロパティを設定します。

プロパティ価値

EndpointConfigurationName workflowServiceEndpoint

オペレーションネーム StartSample

ServiceContractName ITransactionSample

ワークフローは次のようになります。
[ 定義... ] リンクをクリックし、次の設定を行います。
Send アクティビティを右クリックし、[ReceiveReply の作成] を選択します。 ReceiveReply アクティビティは、Send アクティビティの後に自動的に配置されます。
[定義]をクリックします。..ReceiveReplyForSend アクティビティのリンクをクリックし、次の設定を行います。
SendアクティビティとReceiveReplyアクティビティの間でWriteLineアクティビティをドラッグアンドドロップし、そのTextプロパティを "Client: Send complete" に設定します。
ReceiveReply アクティビティの後にWriteLine アクティビティをドラッグアンドドロップし、そのTextプロパティを "クライアント側: 受信した応答 = " + replyMessage に設定します
WriteLine アクティビティの後にPrintTransactionInfo アクティビティをドラッグアンドドロップします。
ワークフローの最後に WriteLine アクティビティをドラッグアンドドロップし、その Text プロパティを "クライアントワークフローの終了" に設定します。完成したクライアントワークフローは、次の図のようになります。
ソリューションをビルドします。

プロパティ	価値
EndpointConfigurationName	workflowServiceEndpoint
オペレーションネーム	StartSample
ServiceContractName	ITransactionSample

サービスアプリケーションを作成する

Serviceという名前の新しいコンソールアプリケーションプロジェクトをソリューションに追加します。次のアセンブリへの参照を追加します。
1. System.Activities.dll
2. System.ServiceModel.dll
3. System.ServiceModel.Activities.dll

生成されたProgram.cs ファイルと次のコードを開きます。

      static void Main()  
      {  
          Console.WriteLine("Building the server.");  
          using (WorkflowServiceHost host = new WorkflowServiceHost(new DeclarativeServiceWorkflow(), new Uri("net.tcp://localhost:8000/TransactedReceiveService/Declarative")))  
          {
              //Start the server  
              host.Open();  
              Console.WriteLine("Service started.");  

              Console.WriteLine();  
              Console.ReadLine();  
              //Shutdown  
              host.Close();  
          };
      }

次の app.config ファイルをプロジェクトに追加します。

<?xml version="1.0" encoding="utf-8" ?>  
<!-- Copyright © Microsoft Corporation.  All rights reserved. -->  
<configuration>  
    <system.serviceModel>  
        <bindings>  
            <netTcpBinding>  
                <binding transactionFlow="true" />  
            </netTcpBinding>  
        </bindings>  
    </system.serviceModel>  
</configuration>

クライアントアプリケーションを作成する

Clientという名前の新しいコンソールアプリケーションプロジェクトをソリューションに追加します。 System.Activities.dllへの参照を追加します。

program.cs ファイルを開き、次のコードを追加します。

class Program  
{  

    private static AutoResetEvent syncEvent = new AutoResetEvent(false);  

    static void Main(string[] args)  
    {  
        //Build client  
        Console.WriteLine("Building the client.");  
        WorkflowApplication client = new WorkflowApplication(new DeclarativeClientWorkflow());  
        client.Completed = Program.Completed;  
        client.Aborted = Program.Aborted;  
        client.OnUnhandledException = Program.OnUnhandledException;  
        //Wait for service to start  
        Console.WriteLine("Press ENTER once service is started.");  
        Console.ReadLine();  

        //Start the client
        Console.WriteLine("Starting the client.");  
        client.Run();  
        syncEvent.WaitOne();  

        //Sample complete  
        Console.WriteLine();  
        Console.WriteLine("Client complete. Press ENTER to exit.");  
        Console.ReadLine();  
    }  

    private static void Completed(WorkflowApplicationCompletedEventArgs e)  
    {  
        Program.syncEvent.Set();  
    }  

    private static void Aborted(WorkflowApplicationAbortedEventArgs e)  
    {  
        Console.WriteLine("Client Aborted: {0}", e.Reason);  
        Program.syncEvent.Set();  
    }  

    private static UnhandledExceptionAction OnUnhandledException(WorkflowApplicationUnhandledExceptionEventArgs e)  
    {  
        Console.WriteLine("Client had an unhandled exception: {0}", e.UnhandledException);  
        return UnhandledExceptionAction.Cancel;  
    }  
}

次の方法で共有

ワークフロー サービスとの間のトランザクションのフロー

共有ライブラリを作成する

ワークフロー サービスを実装する

ワークフロー クライアントを実装する

サービス アプリケーションを作成する

クライアント アプリケーションを作成する

こちらも参照ください

その他のリソース

ワークフローサービスとの間のトランザクションのフロー

ワークフローサービスを実装する

ワークフロークライアントを実装する

サービスアプリケーションを作成する

クライアントアプリケーションを作成する