双方向サービス

[アーティクル]
02/24/2011

双方向サービスコントラクトは、両方のエンドポイントが互いに独立してメッセージを送信できるメッセージ交換パターンです。双方向サービスでは、クライアントのエンドポイントにメッセージを返信できるため、イベントのような動作を実現できます。双方向通信は、クライアントがサービスに接続し、サービスからクライアントにメッセージを返信できるチャネルがサービスに提供されると発生します。双方向サービスにおけるイベントのような動作は、セッション内でのみ機能することに注意してください。

双方向コントラクトを作成するには、インターフェイスのペアを作成します。最初のインターフェイスは、クライアントから呼び出すことのできる操作を記述したサービスコントラクトインターフェイスです。サービスコントラクトでは、System.ServiceModel.ServiceContractAttribute.CallbackContract プロパティにコールバックコントラクトを指定する必要があります。このコールバックコントラクトが、サービスがクライアントエンドポイントで呼び出すことのできる操作を定義するインターフェイスになります。双方向コントラクトではセッションは必要ありませんが、システム指定の二重バインディングではセッションを利用します。

双方向コントラクトの例を次に示します。

<ServiceContract(Namespace := "http://Microsoft.ServiceModel.Samples", SessionMode:=SessionMode.Required, CallbackContract:=GetType(ICalculatorDuplexCallback))> _
Public Interface ICalculatorDuplex
    <OperationContract(IsOneWay := True)> _
    Sub Clear()
    <OperationContract(IsOneWay := True)> _
    Sub AddTo(ByVal n As Double)
    <OperationContract(IsOneWay := True)> _
    Sub SubtractFrom(ByVal n As Double)
    <OperationContract(IsOneWay := True)> _
    Sub MultiplyBy(ByVal n As Double)
    <OperationContract(IsOneWay := True)> _
    Sub DivideBy(ByVal n As Double)
End Interface


Public Interface ICalculatorDuplexCallback
    <OperationContract(IsOneWay := True)> _
    Sub Equals(ByVal result As Double)
    <OperationContract(IsOneWay := True)> _
    Sub Equation(ByVal eqn As String)
End Interface

[ServiceContract(Namespace = "http://Microsoft.ServiceModel.Samples", SessionMode=SessionMode.Required,
                 CallbackContract=typeof(ICalculatorDuplexCallback))]
public interface ICalculatorDuplex
{
    [OperationContract(IsOneWay = true)]
    void Clear();
    [OperationContract(IsOneWay = true)]
    void AddTo(double n);
    [OperationContract(IsOneWay = true)]
    void SubtractFrom(double n);
    [OperationContract(IsOneWay = true)]
    void MultiplyBy(double n);
    [OperationContract(IsOneWay = true)]
    void DivideBy(double n);
}


public interface ICalculatorDuplexCallback
{
    [OperationContract(IsOneWay = true)]
    void Equals(double result);
    [OperationContract(IsOneWay = true)]
    void Equation(string eqn);
}

CalculatorService クラスは、プライマリ ICalculatorDuplex インターフェイスを実装します。このサービスは PerSession インスタンスモードを使用して、各セッションの結果を保持します。Callback というプライベートプロパティを使用して、クライアントへのコールバックチャネルにアクセスします。次のサンプルコードに示すように、サービスはこのコールバックを使用し、コールバックインターフェイスを介してメッセージをクライアントに返信します。

<ServiceBehavior(InstanceContextMode := InstanceContextMode.PerSession)> _
Public Class CalculatorService
    Implements ICalculatorDuplex
    Private result As Double = 0.0R
    Private equation As String

    Public Sub New()
        equation = result.ToString()
    End Sub

    Public Sub Clear() Implements ICalculatorDuplex.Clear
        Callback.Equation(equation & " = " & result.ToString())
        equation = result.ToString()
    End Sub

    Public Sub AddTo(ByVal n As Double) Implements ICalculatorDuplex.AddTo
        result += n
        equation &= " + " & n.ToString()
        CType(Callback, Object).Equals(result)
    End Sub

    Public Sub SubtractFrom(ByVal n As Double) Implements ICalculatorDuplex.SubtractFrom
        result -= n
        equation &= " - " & n.ToString()
        CType(Callback, Object).Equals(result)
    End Sub

    Public Sub MultiplyBy(ByVal n As Double) Implements ICalculatorDuplex.MultiplyBy
        result *= n
        equation &= " * " & n.ToString()
        CType(Callback, Object).Equals(result)
    End Sub

    Public Sub DivideBy(ByVal n As Double) Implements ICalculatorDuplex.DivideBy
        result /= n
        equation &= " / " & n.ToString()
        CType(Callback, Object).Equals(result)
    End Sub

    Private ReadOnly Property Callback() As ICalculatorDuplexCallback
        Get
            Return OperationContext.Current.GetCallbackChannel(Of ICalculatorDuplexCallback)()
        End Get
    End Property
End Class

[ServiceBehavior(InstanceContextMode = InstanceContextMode.PerSession)]
public class CalculatorService : ICalculatorDuplex
{
    double result = 0.0D;
    string equation;

    public CalculatorService()
    {
        equation = result.ToString();
    }

    public void Clear()
    {
        Callback.Equation(equation + " = " + result.ToString());
        equation = result.ToString();
    }

    public void AddTo(double n)
    {
        result += n;
        equation += " + " + n.ToString();
        Callback.Equals(result);
    }

    public void SubtractFrom(double n)
    {
        result -= n;
        equation += " - " + n.ToString();
        Callback.Equals(result);
    }

    public void MultiplyBy(double n)
    {
        result *= n;
        equation += " * " + n.ToString();
        Callback.Equals(result);
    }

    public void DivideBy(double n)
    {
        result /= n;
        equation += " / " + n.ToString();
        Callback.Equals(result);
    }

    ICalculatorDuplexCallback Callback
    {
        get
        {
            return OperationContext.Current.GetCallbackChannel<ICalculatorDuplexCallback>();
        }
    }
}

クライアントは、サービスからのメッセージを受信するために、双方向コントラクトのコールバックインターフェイスを実装するクラスを提供する必要があります。次のサンプルコードに、ICalculatorDuplexCallback インターフェイスを実装する CallbackHandler クラスを示します。

Public Class CallbackHandler
    Implements ICalculatorDuplexCallback
    Public Overridable Shadows Sub Equals(ByVal result As Double) Implements ICalculatorDuplexCallback.Equals
        Console.WriteLine("Equals({0})", result)
    End Sub

    Public Sub Equation(ByVal eqn As String) Implements ICalculatorDuplexCallback.Equation
        Console.WriteLine("Equation({0})", eqn)
    End Sub
End Class

public class CallbackHandler : ICalculatorDuplexCallback
{
    public void Equals(double result)
    {
        Console.WriteLine("Equals({0})", result);
    }

    public void Equation(string eqn)
    {
        Console.WriteLine("Equation({0})", eqn);
    }
}

双方向コントラクト用に生成された WCF クライアントには、構築時に InstanceContext クラスを提供する必要があります。この InstanceContext クラスが、コールバックインターフェイスを実装するオブジェクトのサイトとして使用され、サービスから返信されるメッセージを処理します。InstanceContext クラスは、CallbackHandler クラスのインスタンスを使用して構築されます。このオブジェクトは、コールバックインターフェイスでサービスからクライアントに送信されるメッセージを処理します。

' Construct InstanceContext to handle messages on callback interface
Dim instanceContext As New InstanceContext(New CallbackHandler())

' Create a client
Dim client As New CalculatorDuplexClient(instanceContext)

// Construct InstanceContext to handle messages on callback interface
InstanceContext instanceContext = new InstanceContext(new CallbackHandler());

// Create a client
CalculatorDuplexClient client = new CalculatorDuplexClient(instanceContext);

サービスの構成は、セッション通信と双方向通信の両方をサポートするバインディングを提供するように設定する必要があります。wsDualHttpBinding 要素はセッション通信をサポートし、どちらの方向にも HTTP 接続が 1 つ用意される双方向 HTTP 接続を提供して双方向通信を実現します。

クライアントで、サーバーがクライアントへの接続に使用するアドレスを構成する必要があります。次のサンプル構成を参照してください。

注 :
非双方向クライアントがセキュリティで保護されたメッセージ交換を使用して認証に失敗した場合、通常、MessageSecurityException がスローされます。ただし、セキュリティで保護されたメッセージ交換を使用する双方向クライアントが認証に失敗した場合、クライアントは代わりに TimeoutException を受信します。

非双方向クライアントがセキュリティで保護されたメッセージ交換を使用して認証に失敗した場合、通常、MessageSecurityException がスローされます。ただし、セキュリティで保護されたメッセージ交換を使用する双方向クライアントが認証に失敗した場合、クライアントは代わりに TimeoutException を受信します。

WSHttpBinding 要素を使用するクライアントとサービスを作成しても、クライアントのコールバックエンドポイントが含まれていない場合は、次のエラーが発生します。

HTTP could not register URL
htp://+:80/Temporary_Listen_Addresses/<guid> because TCP port 80 is being used by another application.

次のサンプルコードは、コードでクライアントのエンドポイントアドレスを指定する方法を示しています。

WSDualHttpBinding binding = new WSDualHttpBinding();
EndpointAddress endptadr = new EndpointAddress("https://localhost:12000/DuplexTestUsingCode/Server");
binding.ClientBaseAddress = new Uri("https://localhost:8000/DuplexTestUsingCode/Client/");

次のサンプルコードは、構成でクライアントのエンドポイントアドレスを指定する方法を示しています。

<client>
    <endpoint name ="ServerEndpoint" 
          address="https://localhost:12000/DuplexTestUsingConfig/Server"
          bindingConfiguration="WSDualHttpBinding_IDuplexTest" 
            binding="wsDualHttpBinding"
           contract="IDuplexTest" />
</client>
<bindings>
    <wsDualHttpBinding>
        <binding name="WSDualHttpBinding_IDuplexTest"  
          clientBaseAddress="https://localhost:8000/myClient/" >
            <security mode="None"/>
         </binding>
    </wsDualHttpBinding>
</bindings>

注意 :
双方向モデルでは、サービスまたはクライアントによってチャネルがいつ閉じられたかが自動的に検出されません。このため、サービスが突然終了した場合は、既定でサービスには通知されず、クライアントが突然終了した場合も、サービスには通知されません。クライアントとサービスは、独自のプロトコルを実装して、互いに通知するように選択できます。

双方向モデルでは、サービスまたはクライアントによってチャネルがいつ閉じられたかが自動的に検出されません。このため、サービスが突然終了した場合は、既定でサービスには通知されず、クライアントが突然終了した場合も、サービスには通知されません。クライアントとサービスは、独自のプロトコルを実装して、互いに通知するように選択できます。

参照

処理手順

双方向
 方法 : チャネルファクトリを作成および使用して、チャネルを作成および管理する

概念

クライアントのランタイム動作の指定

Share via

双方向サービス

参照

処理手順

概念

その他のリソース