ここでは、チャネル ファクトリとチャネルの作成について説明します。
チャネル ファクトリとチャネル
チャネル ファクトリには、チャネルを作成する役割があります。チャネル ファクトリによって作成されるチャネルは、メッセージの送信に使用されます。このチャネルは、上の層からメッセージを取得し、必要な処理を実行し、そのメッセージを下の層に送信する必要があります。このプロセスを説明する図を次に示します。
.gif "クライアント ファクトリおよびチャネル")
終了時に、チャネル ファクトリは、作成したチャネルのうちまだ閉じていないチャネルを閉じる必要があります。チャネル リスナを閉じたとき、新しいチャネルの受け入れだけが停止され、既存のチャネルは開いたままで、メッセージの受信を続行できるので、ここに示すモデルは非対称です。
WCF には、このプロセスに対する基本クラス ヘルパーが用意されています(このトピックで説明するチャネル ヘルパー クラスの図については、「チャネル モデルの概要」を参照してください)。
- CommunicationObject クラスには ICommunicationObject が実装され、チャネルの開発 の手順 2. で説明されているステート マシンが強制実行されます。
CreateChannelオーバーロードを 1 つのOnCreateChannel抽象メソッドに統合します。
次の説明は、「Transport: UDP」のサンプルに基づいています。
チャネル ファクトリの作成
``UdpChannelFactory は ChannelFactoryBase から派生します。サンプルでは、GetProperty をオーバーライドして、メッセージ エンコーダのメッセージ バージョンにアクセスできるようにします。さらに、OnClose をオーバーライドして、ステート マシンの移行時に BufferManager のインスタンスを破棄します。
UDP 出力チャネル
``UdpOutputChannel は、IOutputChannel を実装します。このコンストラクタは、引数を検証し、渡される EndpointAddress に基づいて出力先の EndPoint オブジェクトを構築します。
OnOpen のオーバーライドによって、この EndPoint にメッセージを送信するために使用されるソケットが作成されます。
this.socket = new Socket(
this.remoteEndPoint.AddressFamily,
SocketType.Dgram,
ProtocolType.Udp
);
チャネルが閉じる際には、正常終了することも異常終了することもあります。チャネルが正常に閉じた場合はソケットも終了し、基本クラスの OnClose メソッドが呼び出されます。このときに例外がスローされると、インフラストラクチャによって Abort が呼び出され、チャネルがクリーンアップされます。
this.socket.Close();
base.OnClose(timeout);
Send() と BeginSend()/EndSend() を実装します。この実装は、2 つの主要セクションに分かれます。最初に、メッセージを次のようにシリアル化してバイト配列で表します。
ArraySegment<byte> messageBuffer = EncodeMessage(message);
次に、結果として生成されたデータを次のようにネットワークに送信します。
this.socket.SendTo(
messageBuffer.Array,
messageBuffer.Offset,
messageBuffer.Count,
SocketFlags.None,
this.remoteEndPoint
);