Как реализовать обнаружимую службу, которая регистрируется в прокси-сервере обнаружения

Данный раздел является вторым из четырех разделов, в которых обсуждается реализация прокси-сервера обнаружения. В предыдущем разделе: Практическое руководство. Реализация прокси-сервера обнаружения вы реализовали прокси-сервер обнаружения. В этом разделе вы создадите службу WCF, которая отправляет сообщения об объявлении (Hello и Bye) в прокси-сервер обнаружения, что приводит к регистрации и отмене регистрации с помощью прокси-сервера обнаружения.

Определение контракта службы

1. Добавьте новый проект консольного приложения с именем DiscoveryProxyExample в решение Service.

2. Добавьте ссылки на следующие сборки:

   1. System.ServiceModel

   2. System.ServiceModel.Discovery

3. Добавьте в проект новый класс с именем CalculatorService.

4. Добавьте следующие директивы using.

   using System;
   using System.ServiceModel;
   

5. В файле CalculatorService.cs определите контракт службы.

   // Define a service contract.
   [ServiceContract(Namespace = "http://Microsoft.Samples.Discovery")]
   public interface ICalculatorService
   {
       [OperationContract]
       double Add(double n1, double n2);
       [OperationContract]
       double Subtract(double n1, double n2);
       [OperationContract]
       double Multiply(double n1, double n2);
       [OperationContract]
       double Divide(double n1, double n2);
   }
   

6. Также в файле CalculatorService.cs реализуйте контракт службы.

   // Service class which implements the service contract.
   public class CalculatorService : ICalculatorService
   {
       public double Add(double n1, double n2)
       {
           double result = n1 + n2;
           Console.WriteLine("Received Add({0},{1})", n1, n2);
           Console.WriteLine("Return: {0}", result);
           return result;
       }
   
       public double Subtract(double n1, double n2)
       {
           double result = n1 - n2;
           Console.WriteLine("Received Subtract({0},{1})", n1, n2);
           Console.WriteLine("Return: {0}", result);
           return result;
       }
   
       public double Multiply(double n1, double n2)
       {
           double result = n1 * n2;
           Console.WriteLine("Received Multiply({0},{1})", n1, n2);
           Console.WriteLine("Return: {0}", result);
           return result;
       }
   
       public double Divide(double n1, double n2)
       {
           double result = n1 / n2;
           Console.WriteLine("Received Divide({0},{1})", n1, n2);
           Console.WriteLine("Return: {0}", result);
           return result;
       }
   }
   

Размещение службы

1. Откройте файл Program.cs, сформированный при создании проекта.

2. Добавьте следующие директивы using.

   using System;
   using System.ServiceModel;
   using System.ServiceModel.Description;
   using System.ServiceModel.Discovery;
   

3. В метод Main() добавьте следующий код.

   // Define the base address of the service
   Uri baseAddress = new Uri("net.tcp://localhost:9002/CalculatorService/" + Guid.NewGuid().ToString());
   // Define the endpoint address where announcement messages will be sent
   Uri announcementEndpointAddress = new Uri("net.tcp://localhost:9021/Announcement");
   
   // Create the service host
   ServiceHost serviceHost = new ServiceHost(typeof(CalculatorService), baseAddress);
   try
   {
       // Add a service endpoint
       ServiceEndpoint netTcpEndpoint = serviceHost.AddServiceEndpoint(typeof(ICalculatorService),
           new NetTcpBinding(), string.Empty);
   
       // Create an announcement endpoint, which points to the Announcement Endpoint hosted by the proxy service.
       AnnouncementEndpoint announcementEndpoint = new AnnouncementEndpoint(new NetTcpBinding(),
           new EndpointAddress(announcementEndpointAddress));
   
       // Create a ServiceDiscoveryBehavior and add the announcement endpoint
       ServiceDiscoveryBehavior serviceDiscoveryBehavior = new ServiceDiscoveryBehavior();
       serviceDiscoveryBehavior.AnnouncementEndpoints.Add(announcementEndpoint);
   
       // Add the ServiceDiscoveryBehavior to the service host to make the service discoverable
       serviceHost.Description.Behaviors.Add(serviceDiscoveryBehavior);
   
       // Start listening for messages
       serviceHost.Open();
   
       Console.WriteLine("Calculator Service started at {0}", baseAddress);
       Console.WriteLine();
       Console.WriteLine("Press <ENTER> to terminate the service.");
       Console.WriteLine();
       Console.ReadLine();
   
       serviceHost.Close();
   }
   catch (CommunicationException e)
   {
       Console.WriteLine(e.Message);
   }
   catch (TimeoutException e)
   {
       Console.WriteLine(e.Message);
   }
   
   if (serviceHost.State != CommunicationState.Closed)
   {
       Console.WriteLine("Aborting the service...");
       serviceHost.Abort();
   }
   

Реализация обнаруживаемой службы завершена. Перейдите к инструкции. Реализация клиентского приложения, использующего прокси-сервер обнаружения для поиска службы.

Пример

Далее приведен полный код, используемый в этом подразделе.

// CalculatorService.cs
//----------------------------------------------------------------
// Copyright (c) Microsoft Corporation.  All rights reserved.
//----------------------------------------------------------------

using System;
using System.ServiceModel;

namespace Microsoft.Samples.Discovery
{
    // Define a service contract.
    [ServiceContract(Namespace = "http://Microsoft.Samples.Discovery")]
    public interface ICalculatorService
    {
        [OperationContract]
        double Add(double n1, double n2);
        [OperationContract]
        double Subtract(double n1, double n2);
        [OperationContract]
        double Multiply(double n1, double n2);
        [OperationContract]
        double Divide(double n1, double n2);
    }

    // Service class which implements the service contract.
    public class CalculatorService : ICalculatorService
    {
        public double Add(double n1, double n2)
        {
            double result = n1 + n2;
            Console.WriteLine("Received Add({0},{1})", n1, n2);
            Console.WriteLine("Return: {0}", result);
            return result;
        }
  
        public double Subtract(double n1, double n2)
        {
            double result = n1 - n2;
            Console.WriteLine("Received Subtract({0},{1})", n1, n2);
            Console.WriteLine("Return: {0}", result);
            return result;
        }

        public double Multiply(double n1, double n2)
        {
            double result = n1 * n2;
            Console.WriteLine("Received Multiply({0},{1})", n1, n2);
            Console.WriteLine("Return: {0}", result);
            return result;
        }

        public double Divide(double n1, double n2)
        {
            double result = n1 / n2;
            Console.WriteLine("Received Divide({0},{1})", n1, n2);
            Console.WriteLine("Return: {0}", result);
            return result;
        }
    }
}

// Program.cs
//----------------------------------------------------------------
// Copyright (c) Microsoft Corporation.  All rights reserved.
//----------------------------------------------------------------

using System;
using System.ServiceModel;
using System.ServiceModel.Description;
using System.ServiceModel.Discovery;

namespace Microsoft.Samples.Discovery
{
    class Program
    {
        public static void Main()
        {
            Uri baseAddress = new Uri("net.tcp://localhost:9002/CalculatorService/" + Guid.NewGuid().ToString());
            Uri announcementEndpointAddress = new Uri("net.tcp://localhost:9021/Announcement");

            ServiceHost serviceHost = new ServiceHost(typeof(CalculatorService), baseAddress);
            try
            {
                ServiceEndpoint netTcpEndpoint = serviceHost.AddServiceEndpoint(typeof(ICalculatorService),
                    new NetTcpBinding(), string.Empty);

                // Create an announcement endpoint, which points to the Announcement Endpoint hosted by the proxy service.
                AnnouncementEndpoint announcementEndpoint = new AnnouncementEndpoint(new NetTcpBinding(),
                    new EndpointAddress(announcementEndpointAddress));

                ServiceDiscoveryBehavior serviceDiscoveryBehavior = new ServiceDiscoveryBehavior();
                serviceDiscoveryBehavior.AnnouncementEndpoints.Add(announcementEndpoint);

                // Make the service discoverable
                serviceHost.Description.Behaviors.Add(serviceDiscoveryBehavior);

                serviceHost.Open();

                Console.WriteLine("Calculator Service started at {0}", baseAddress);
                Console.WriteLine();
                Console.WriteLine("Press <ENTER> to terminate the service.");
                Console.WriteLine();
                Console.ReadLine();

                serviceHost.Close();
            }
            catch (CommunicationException e)
            {
                Console.WriteLine(e.Message);
            }
            catch (TimeoutException e)
            {
                Console.WriteLine(e.Message);
            }

            if (serviceHost.State != CommunicationState.Closed)
            {
                Console.WriteLine("Aborting the service...");
                serviceHost.Abort();
            }
        }
    }
}

См. также

• Обнаружение WCF
• Практическое руководство. Реализация прокси-сервера обнаружения
• Практическое руководство. Реализация клиентского приложения, которое для поиска служб использует прокси-сервер обнаружения