Procedure: Een detecteerbare service implementeren die wordt geregistreerd bij de detectieproxy

Artikel
06/08/2024

Dit onderwerp is de tweede van vier onderwerpen waarin wordt besproken hoe u een detectieproxy implementeert. In het vorige onderwerp: Een detectieproxy implementeren, hebt u een detectieproxy geïmplementeerd. In dit onderwerp maakt u een WCF-service waarmee aankondigingsberichten (Hello en Bye) worden verzonden naar de detectieproxy, waardoor deze zich registreert en de registratie ervan ongedaan maakt bij de detectieproxy.

Het servicecontract definiëren

Voeg een nieuw consoletoepassingsproject toe aan de oplossing met de DiscoveryProxyExample naam Service.
Voeg verwijzingen toe aan de volgende assembly's:
1. System.ServiceModel
2. System.ServiceModel.Discovery
Voeg een nieuwe klasse toe aan het project met de naam CalculatorService.

Voeg de volgende using instructies toe.

using System;
using System.ServiceModel;

Definieer binnen CalculatorService.cs het servicecontract.

// 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);
}

Implementeer ook binnen CalculatorService.cs het servicecontract.

// 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;
    }
}

De service hosten

Open het Program.cs-bestand dat is gegenereerd toen u het project maakte.

Voeg de volgende using instructies toe.

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

Voeg in de Main() methode de volgende code toe:

// 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();
}

U hebt de implementatie van een detecteerbare service voltooid. Ga door naar instructies: een clienttoepassing implementeren die gebruikmaakt van de detectieproxy om een service te zoeken.

Opmerking

Dit is de volledige lijst van de code die in dit onderwerp wordt gebruikt.

// 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();
            }
        }
    }
}

Delen via

Procedure: Een detecteerbare service implementeren die wordt geregistreerd bij de detectieproxy

Het servicecontract definiëren

De service hosten

Opmerking

Zie ook

Aanvullende resources