Custom Demux

아티클
09/05/2008

이 샘플에서는 MsmqIntegrationBinding을 사용하는 WCF(Windows Communication Foundation) 서비스가 Message Queuing to Windows Communication Foundation 및 Windows Communication Foundation to Message Queuing 샘플에 설명된 하나의 서비스 작업 사용으로 제한되지 않도록 MSMQ 메시지 헤더를 다양한 서비스 작업에 매핑하는 방법을 보여 줍니다.

이 샘플의 서비스는 자체적으로 호스팅되는 콘솔 응용 프로그램으로서 이를 사용하여 대기 중인 메시지를 받는 서비스를 확인할 수 있습니다.

서비스 계약은 IOrderProcessor이며, 큐에서 사용하는 데 적합한 단방향 서비스를 정의합니다.

[ServiceContract]
[KnownType(typeof(PurchaseOrder))]
[KnownType(typeof(String))]
public interface IOrderProcessor
{
    [OperationContract(IsOneWay = true, Name = "SubmitPurchaseOrder")]
    void SubmitPurchaseOrder(MsmqMessage<PurchaseOrder> msg);

    [OperationContract(IsOneWay = true, Name = "CancelPurchaseOrder")]
    void CancelPurchaseOrder(MsmqMessage<string> ponumber);
}

MSMQ 메시지에는 Action 헤더가 없습니다. 다양한 MSMQ 메시지를 작업 계약에 자동으로 매핑할 수 없습니다. 따라서 작업 계약이 하나만 있을 수 있습니다. 이러한 제한을 해결하기 위해 서비스에서는 IDispatchOperationSelector 인터페이스의 SelectOperation 메서드를 구현합니다. SelectOperation 메서드를 사용하여 서비스는 지정된 메시지 헤더를 특정 서비스 작업에 매핑할 수 있습니다. 이 샘플에서는 메시지의 레이블 헤더를 서비스 작업에 매핑합니다. 작업 계약의 Name 매개 변수는 지정된 메시지 레이블에 대해 디스패치되어야 하는 서비스 작업을 결정합니다. 예를 들어 메시지의 레이블 헤더에 "SubmitPurchaseOrder"가 포함되어 있으면 "SubmitPurchaseOrder" 서비스 작업이 호출됩니다.

public class OperationSelector : IDispatchOperationSelector
{
    public string SelectOperation(ref System.ServiceModel.Channels.Message message)
    {
        MsmqIntegrationMessageProperty property = MsmqIntegrationMessageProperty.Get(message);
        return property.Label;
    }
}

서비스는 다음 샘플 코드와 같이 IContractBehavior 인터페이스의 ApplyDispatchBehavior 메서드를 구현해야 합니다. 이렇게 하면 사용자 지정 OperationSelector가 서비스 프레임워크 디스패치 런타임에 적용됩니다.

void IContractBehavior.ApplyDispatchBehavior(ContractDescription description, ServiceEndpoint endpoint, DispatchRuntime dispatch)
{
    dispatch.OperationSelector = new OperationSelector();
}

메시지는 OperationSelector에 도달하기 전에 디스패처의 ContractFilter를 통과해야 합니다. 기본적으로 서비스에 의해 구현된 계약에서 해당 동작을 찾을 수 없으면 메시지가 거부됩니다. 이러한 문제를 방지하기 위해 다음과 같이 MatchAllMessageFilter를 적용하여 모든 메시지가 ContractFilter를 통과할 수 있도록 하는 MatchAllFilterBehavior라는 IEndpointBehavior를 구현합니다.

public void ApplyDispatchBehavior(ServiceEndpoint serviceEndpoint, EndpointDispatcher endpointDispatcher)
{
    endpointDispatcher.ContractFilter = new MatchAllMessageFilter();
}

서비스에서 메시지를 받으면 레이블 헤더에서 제공하는 정보를 사용하여 적합한 서비스 작업이 디스패치됩니다. 다음 샘플 코드와 같이 메시지 본문은 PurchaseOrder 개체로 deserialize됩니다.

[OperationBehavior(TransactionScopeRequired = true, TransactionAutoComplete = true)]
public void SubmitPurchaseOrder(MsmqMessage<PurchaseOrder> msg)
{
    PurchaseOrder po = (PurchaseOrder)msg.Body;
    Random statusIndexer = new Random();
    po.Status = (OrderStates)statusIndexer.Next(3);
    Console.WriteLine("Processing {0} ", po);
}

서비스는 자체 호스팅됩니다. MSMQ를 사용할 때 사용되는 큐는 미리 만들어야 합니다. 수동으로 또는 코드를 통해 이 작업을 수행할 수 있습니다. 이 샘플의 서비스에는 큐가 있는지 확인하고 없을 경우 큐를 만드는 코드가 포함되어 있습니다. 큐 이름은 구성 파일에서 읽습니다.

public static void Main()
{
    // Get MSMQ queue name from app settings in configuration
    string queueName = ConfigurationManager.AppSettings["orderQueueName"];

    // Create the transacted MSMQ queue if necessary.
    if (!MessageQueue.Exists(queueName))
        MessageQueue.Create(queueName, true);

    // Create a ServiceHost for the CalculatorService type.
    using (ServiceHost serviceHost = new ServiceHost(typeof(OrderProcessorService)))
    {               
        ServiceEndpoint endpoint = serviceHost.Description.Endpoints[0];
        endpoint.Behaviors.Add(new MatchAllFilterBehavior());

        //Open the ServiceHost to create listeners and start listening for messages.
        serviceHost.Open();

        // The service can now be accessed.
        Console.WriteLine("The service is ready.");
        Console.WriteLine("Press <ENTER> to terminate service.");
        Console.ReadLine();

        // Close the ServiceHost to shutdown the service.
        serviceHost.Close();
    }
}

MSMQ 큐 이름은 구성 파일의 appSettings 섹션에 지정됩니다.

참고

큐 이름은 로컬 컴퓨터에 마침표(.)를 사용하고 경로에 백슬래시 구분 기호를 사용합니다. WCF 끝점 주소는 msmq.formatname 체계를 지정하며 로컬 시스템으로 localhost를 사용합니다. 체계를 따르는 주소는 MSMQ 형식 이름 주소 지정 지침에 따라 형식이 올바르게 지정된 큐 주소입니다.

<appSettings>
    <!-- Use appSetting to configure the MSMQ queue name. -->
    <add key="queueName" value=".\private$\Orders" />
</appSettings>

참고

이 샘플을 사용하려면 메시지 큐(영문 페이질 수 있음)를 설치해야 합니다.

서비스를 시작하고 클라이언트를 실행합니다.

다음과 같은 출력이 클라이언트에 표시됩니다.

Placed the order:Purchase Order: 28fc457a-1a56-4fe0-9dde-156965c21ed6
        Customer: somecustomer.com
        OrderDetails
                Order LineItem: 54 of Blue Widget @unit price: $29.99
                Order LineItem: 890 of Red Widget @unit price: $45.89
        Total cost of this order: $42461.56
        Order status: Pending
Cancelled the Order: 28fc457a-1a56-4fe0-9dde-156965c21ed6
Press <ENTER> to terminate client.

서비스에는 다음과 같은 출력이 표시되어야 합니다.

The service is ready.
Press <ENTER> to terminate service.
Processing Purchase Order: 28fc457a-1a56-4fe0-9dde-156965c21ed6
        Customer: somecustomer.com
        OrderDetails
                Order LineItem: 54 of Blue Widget @unit price: $29.99
                Order LineItem: 890 of Red Widget @unit price: $45.89
        Total cost of this order: $42461.56
        Order status: Shipped
Purchase Order 28fc457a-1a56-4fe0-9dde-156965c21ed6 is cancelled

샘플을 설치, 빌드 및 실행하려면

Windows Communication Foundation 샘플의 일회 설치 절차를 수행했는지 확인합니다.
C# 또는 Visual Basic .NET 버전의 솔루션을 빌드하려면 Windows Communication Foundation 샘플 빌드의 지침을 따릅니다.
단일 컴퓨터 또는 다중 컴퓨터 구성에서 샘플을 실행하려면 Windows Communication Foundation 샘플 실행의 지침을 따릅니다.

다중 컴퓨터 구성에서 샘플을 실행하려면

언어별 폴더의 \service\bin\ 폴더에서 서비스 컴퓨터로 서비스 프로그램 파일을 복사합니다.
언어별 폴더의 \client\bin\ 폴더에서 클라이언트 컴퓨터로 클라이언트 프로그램 파일을 복사합니다.
Client.exe.config 파일에서 orderQueueName을 변경하여 "." 대신 서비스 컴퓨터 이름을 지정합니다.
서비스 컴퓨터의 명령 프롬프트에서 Service.exe를 실행합니다.
클라이언트 컴퓨터의 명령 프롬프트에서 Client.exe를 실행합니다.

참고 항목

기타 리소스

Queuing in WCF
메시지 큐(영문 페이지일 수 있음)

다음을 통해 공유

Custom Demux

샘플을 설치, 빌드 및 실행하려면

다중 컴퓨터 구성에서 샘플을 실행하려면

참고 항목

기타 리소스

추가 리소스