方法: 動的な更新

2023-04-07

ここでは、ルーティング構成の作成および動的な更新に必要な基本的手順について説明します。この例では、ルーティングの初期構成を構成ファイルから取得し、すべてのメッセージを regularCalc 電卓サービスにルーティングします。ただし、これは、roundingCalc のサービスの提供先となるエンドポイントを変更するために、後でプログラムによって更新されます。

Note

多くの実装では、構成が完全に動的で、既定の構成に依存しません。ただし、このトピックのシナリオのように、サービスの開始時は既定の構成の状態を使用することが望ましい場合もあります。

Note

動的な更新はメモリ内のみで実行され、構成ファイルが変更されることはありません。

regularCalc でも roundingCalc でも、同じ加算、減算、乗算、および除算の操作がサポートされますが、roundingCalc では、すべての計算結果が、四捨五入によって最も近い整数値に変換されてから返されます。 regularCalc サービスにすべてのメッセージをルーティングするようにサービスを構成するには、構成ファイルが使用されます。ルーティングサービスが開始されると、ApplyConfiguration を使用して、メッセージを roundingCalc サービスにルーティングするようにルーティングサービスが構成されます。

初期構成の実装

サービスによって公開されるサービスエンドポイントを指定することによって、ルーティングサービスの基本的な構成を作成します。次の例では、メッセージの受信に使用される、単一のサービスエンドポイントを定義します。また、regularCalc へのメッセージ送信に使用するクライアントエンドポイントも定義します。

<services>
  <service behaviorConfiguration="routingConfiguration"
           name="System.ServiceModel.Routing.RoutingService">
    <host>
      <baseAddresses>
        <add baseAddress="http://localhost/routingservice/router" />
      </baseAddresses>
    </host>
    <!--Set up the inbound endpoint for the Routing Service-->
    <endpoint address="calculator"
              binding="wsHttpBinding"
              name="routerEndpoint"
              contract="System.ServiceModel.Routing.IRequestReplyRouter" />
  </service>
</services>
<client>
<!--set up the destination endpoint-->
  <endpoint name="regularCalcEndpoint"
            address="net.tcp://localhost:9090/servicemodelsamples/service/"
            binding="netTcpBinding"
            contract="*" />
</client>

送信先エンドポイントへのメッセージのルーティングに使用するフィルターを定義します。この例では、MatchAll フィルターを使用して、前に定義した regularCalcEndpoint にすべてのメッセージをルーティングしています。次の例では、フィルターおよびフィルターテーブルを定義します。
```
<filters>
  
  <filter name="MatchAllFilter" filterType="MatchAll"/>
</filters>
<filterTables>
  <filterTable name="filterTable1">
      
      <add filterName="MatchAllFilter" endpointName="regularCalcEndpoint"/>
  </filterTable>
</filterTables>
```
フィルターテーブルに含まれているフィルターと照合して受信メッセージを評価するには、ルーティング動作を使用して、フィルターテーブルをサービスエンドポイントと関連付ける必要があります。次の例は、"filterTable1" をサービスエンドポイントと関連付ける方法を示しています。
```
<behaviors>
  
  <serviceBehaviors>
    <behavior name="routingConfiguration">
      <routing filterTableName="filterTable1" />
    </behavior>
  </serviceBehaviors>
</behaviors>
```

動的構成の実装

ルーティングサービスの動的構成は、コードでのみ実行できます。これを実行するには、新しい RoutingConfiguration を作成し、ApplyConfiguration を使用して現在の構成を置き換えます。この例では、ルーティングサービスがコンソールアプリケーション内に自己ホストされます。アプリケーションが起動したら、ルーティングの構成を変更できます。メッセージのルーティング先のエンドポイントを構成するには、コンソールウィンドウで「regular」または「rounding」と入力します。「regular」と入力した場合は regularCalc が、「rounding」と入力した場合は roundingCalc になります。

ルーティングサービスをサポートするには、次の using ディレクティブを追加する必要があります。

using System;
using System.Collections.Generic;
using System.ServiceModel;
using System.ServiceModel.Channels;
using System.ServiceModel.Description;
using System.ServiceModel.Dispatcher;
using System.ServiceModel.Routing;

ルーティングサービスをコンソールアプリケーションとして自己ホストするには、次のコードを使用します。これは、前の手順で説明した構成を使用してルーティングサービスを初期化します。この構成は、アプリケーション構成ファイルに保持されています。 while ループには、ルーティング構成の変更に使用されるコードが設定されています。

// Host the service within this EXE console application.
public static void Main()
{
    // Create a ServiceHost for the CalculatorService type.
    using (ServiceHost serviceHost =
        new ServiceHost(typeof(RoutingService)))
    {
        // Open the ServiceHost to create listeners
        // and start listening for messages.
        Console.WriteLine("The Routing Service configured, opening....");
        serviceHost.Open();
        Console.WriteLine("The Routing Service is now running.");
         Console.WriteLine("Type 'quit' to terminate router.");
         Console.WriteLine("<ENTER> to change routing configuration.");
         while (Console.ReadLine() != "quit")
         {
        ....
        }
    }
}

ルーティング構成を動的に更新するには、新しいルーティング構成を作成する必要があります。作成する構成には、新しいルーティング構成に必要なすべてのエンドポイント、フィルター、およびフィルターテーブルの情報が含まれている必要があります。これは、既存のルーティング構成全体が、この構成に置き換えられるためです。新しいルーティング構成を使用するには、ApplyConfiguration を呼び出して新しい構成を渡す必要があります。

前の手順で定義した while ループに次のコードを追加して、ユーザー入力を基にサービスを再構成できるようにします。

Console.WriteLine("Enter 'regular' or 'rounding' to set the destination endpoint:");
string destEndpoint = Console.ReadLine();
// Create a new RoutingConfiguration
RoutingConfiguration rc = new RoutingConfiguration();
// Determine the endpoint to configure for
switch (destEndpoint)
{
    case "regular":
        // Define the destination endpoint
        ServiceEndpoint regularCalc = new ServiceEndpoint(
           ContractDescription.GetContract(typeof(IRequestReplyRouter)),
           new NetTcpBinding(),
           new EndpointAddress("net.tcp://localhost:9090/servicemodelsamples/service/"));
        // Create a MatchAll filter and add to the filter table
        rc.FilterTable.Add(new MatchAllMessageFilter(), new List<ServiceEndpoint> { regularCalc });
        // Use ApplyConfiguration to update the Routing Service
        serviceHost.Extensions.Find<RoutingExtension>().ApplyConfiguration(rc);
        Console.WriteLine("Applied new routing configuration.");
        break;
    case "rounding":
        // Define the destination endpoint
        ServiceEndpoint roundingCalc = new ServiceEndpoint(
           ContractDescription.GetContract(typeof(IRequestReplyRouter)),
           new NetTcpBinding(),
           new EndpointAddress("net.tcp://localhost:8080/servicemodelsamples/service/"));
        // Create a MatchAll filter and add to the filter table
        rc.FilterTable.Add(new MatchAllMessageFilter(), new List<ServiceEndpoint> { roundingCalc });
        // Use ApplyConfiguration to update the Routing Service
        serviceHost.Extensions.Find<RoutingExtension>().ApplyConfiguration(rc);
        Console.WriteLine("Applied new routing configuration.");
        break;
    default:
        Console.WriteLine("Incorrect value entered, no change.");
        break;
}

Note

新しい RoutingConfiguration を提供するメソッドは RoutingExtension service サービス拡張に含まれているため、新しい RoutingConfiguration オブジェクトは、ServiceHost または ServiceExtension (別の ServiceExtension など) への参照を含む WCF 拡張モデル、またはこの参照を取得できる WCF 拡張モデル内の任意の場所で提供できます。

例 1

この例で使用されているコンソールアプリケーション全体の一覧を次に示します。

//-----------------------------------------------------------------
//  Copyright (c) Microsoft Corporation.  All Rights Reserved.
//-----------------------------------------------------------------

using System;
using System.Collections.Generic;
using System.ServiceModel;
using System.ServiceModel.Channels;
using System.ServiceModel.Description;
using System.ServiceModel.Dispatcher;
using System.ServiceModel.Routing;

namespace Microsoft.Samples.AdvancedFilters
{
    public class Router
    {
        // Host the service within this EXE console application.
        public static void Main()
        {
            // Create a ServiceHost for the CalculatorService type.
            using (ServiceHost serviceHost =
                new ServiceHost(typeof(RoutingService)))
            {
                // Open the ServiceHost to create listeners
                // and start listening for messages.
                Console.WriteLine("The Routing Service configured, opening....");
                serviceHost.Open();
                Console.WriteLine("The Routing Service is now running.");
                Console.WriteLine("Type 'quit' to terminate router.");
                Console.WriteLine("<ENTER> to change routing configuration.");
                while (Console.ReadLine() != "quit")
                {
                    Console.WriteLine("Enter 'regular' or 'rounding' to set the destination endpoint:");
                    string destEndpoint = Console.ReadLine();
                    // Create a new RoutingConfiguration
                    RoutingConfiguration rc = new RoutingConfiguration();
                    // Determine the endpoint to configure for
                    switch (destEndpoint)
                    {
                        case "regular":
                            // Define the destination endpoint
                            ServiceEndpoint regularCalc = new ServiceEndpoint(
                            ContractDescription.GetContract(typeof(IRequestReplyRouter)),
                            new NetTcpBinding(),
                            new EndpointAddress("net.tcp://localhost:9090/servicemodelsamples/service/"));
                            // Create a MatchAll filter and add to the filter table
                            rc.FilterTable.Add(new MatchAllMessageFilter(), new List<ServiceEndpoint> { regularCalc });
                            // Use ApplyConfiguration to update the Routing Service
                            serviceHost.Extensions.Find<RoutingExtension>().ApplyConfiguration(rc);
                            Console.WriteLine("Applied new routing configuration.");
                            break;
                        case "rounding":
                            // Define the destination endpoint
                            ServiceEndpoint roundingCalc = new ServiceEndpoint(
                                ContractDescription.GetContract(typeof(IRequestReplyRouter)),
                                new NetTcpBinding(),
                                new EndpointAddress("net.tcp://localhost:8080/servicemodelsamples/service/"));
                            // Create a MatchAll filter and add to the filter table
                            rc.FilterTable.Add(new MatchAllMessageFilter(), new List<ServiceEndpoint> { roundingCalc });
                            // Use ApplyConfiguration to update the Routing Service
                            serviceHost.Extensions.Find<RoutingExtension>().ApplyConfiguration(rc);
                            Console.WriteLine("Applied new routing configuration.");
                            break;
                        default:
                            Console.WriteLine("Incorrect value entered, no change.");
                            break;
                    }
                }
            }
        }
    }
}

例 2

この例で使用されている構成ファイルの全体の一覧を次に示します。

<?xml version="1.0" encoding="utf-8" ?>
<!-- Copyright (c) Microsoft Corporation. All rights reserved -->
<configuration>
  <system.serviceModel>
    <services>
      <service behaviorConfiguration="routingConfiguration"
               name="System.ServiceModel.Routing.RoutingService">
        <host>
          <baseAddresses>
            <add baseAddress="http://localhost/routingservice/router" />
          </baseAddresses>
        </host>
        <!--Set up the inbound endpoint for the Routing Service-->
        <endpoint address="calculator"
                  binding="wsHttpBinding"
                  name="routerEndpoint"
                  contract="System.ServiceModel.Routing.IRequestReplyRouter" />
      </service>
    </services>
    <behaviors>
      <!--default routing service behavior definition-->
      <serviceBehaviors>
        <behavior name="routingConfiguration">
          <routing filterTableName="filterTable1" />
        </behavior>
      </serviceBehaviors>
    </behaviors>

    <client>
<!--set up the destination endpoint-->
      <endpoint name="regularCalcEndpoint"
                address="net.tcp://localhost:9090/servicemodelsamples/service/"
                binding="netTcpBinding"
                contract="*" />
    </client>
    <routing>

      <filters>
        <!--define the message filter-->
        <filter name="MatchAllFilter" filterType="MatchAll"/>
      </filters>
      <filterTables>
        <filterTable name="filterTable1">
            <!--add the filter to the message filter table-->
            <add filterName="MatchAllFilter" endpointName="regularCalcEndpoint"/>
        </filterTable>
      </filterTables>
    </routing>
  </system.serviceModel>
</configuration>

次の方法で共有

方法: 動的な更新

初期構成の実装

動的構成の実装

例 1

例 2

関連項目

その他のリソース