Accodamento messaggi in Windows Communication Foundation

Questo esempio illustra come un'applicazione di Accodamento messaggi (MSMQ) può inviare un messaggio MSMQ a un Windows Communication Foundation (WCF) servizio. Il servizio è un'applicazione console indipendente per consentire di osservare il servizio che riceve messaggi in coda.

Il contratto di servizio è IOrderProcessorche definisce un servizio unidirezionale adatto per l'utilizzo con le code. Un messaggio MSMQ non ha un'intestazione Action, pertanto non è possibile eseguire automaticamente il mapping di messaggi MSMQ diversi ai contratti dell'operazione. Pertanto, può essere presente un solo contratto dell'operazione. Se si vuole definire più di un contratto dell'operazione per il servizio, l'applicazione deve fornire informazioni come quale intestazione nel messaggio MSMQ (ad esempio, l'etichetta o correlationID) può essere utilizzata per decidere quale contratto dell'operazione inviare. Questo aspetto viene illustrato in Demux personalizzato.

Il messaggio MSMQ non contiene informazioni come su quali intestazioni è stato eseguito il mapping ai diversi parametri del contratto dell'operazione. Il parametro è di tipo MsmqMessage(MsmqMessage<T>) che contiene il messaggio MSMQ sottostante. Il tipo "T" nella classe MsmqMessage(MsmqMessage<T>) rappresenta i dati serializzati nel corpo del messaggio MSMQ. In questo esempio, il tipo PurchaseOrder è serializzato nel corpo del messaggio MSMQ.

Nell'esempio di codice seguente viene mostrato il contratto di servizio del servizio di elaborazione degli ordini.

// Define a service contract.
[ServiceContract(Namespace = "http://Microsoft.ServiceModel.Samples")]
[ServiceKnownType(typeof(PurchaseOrder))]
public interface IOrderProcessor
{
    [OperationContract(IsOneWay = true, Action = "*")]
    void SubmitPurchaseOrder(MsmqMessage<PurchaseOrder> msg);
}

Il servizio è indipendente. Quando si utilizza il trasporto MSMQ, la coda utilizzata deve essere creata in anticipo. Questa operazione può essere eseguita manualmente o mediante il codice. In questo esempio, il servizio verifica l'esistenza della coda e la crea se necessario. Il nome della coda viene letto dal file di configurazione.

public static void Main()
{
    // Get the MSMQ queue name from the application settings in 
    // configuration.
    string queueName = ConfigurationManager.AppSettings["queueName"];
    // Create the MSMQ queue if necessary.
    if (!MessageQueue.Exists(queueName))
        MessageQueue.Create(queueName, true);
    …
}

Il servizio crea e apre una classe ServiceHost per OrderProcessorService, come mostra il codice di esempio seguente.

using (ServiceHost serviceHost = new ServiceHost(typeof(OrderProcessorService)))
{
    serviceHost.Open();
    Console.WriteLine("The service is ready.");
    Console.WriteLine("Press <ENTER> to terminate service.");
    Console.ReadLine();
    serviceHost.Close();
}

Il nome della coda MSMQ viene specificato in una sezione appSettings del file di configurazione, come mostra la configurazione di esempio seguente.

<appSettings>
    <add key="orderQueueName" value=".\private$\Orders" />
</appSettings>

L'applicazione client è un'applicazione MSMQ che utilizza il metodo Send per inviare un messaggio durevole e transazionale alla coda, come mostra il codice di esempio seguente.

//Connect to the queue.
MessageQueue orderQueue = new MessageQueue(ConfigurationManager.AppSettings["orderQueueName"]);

// Create the purchase order.
PurchaseOrder po = new PurchaseOrder();
po.CustomerId = "somecustomer.com";
po.PONumber = Guid.NewGuid().ToString();

PurchaseOrderLineItem lineItem1 = new PurchaseOrderLineItem();
lineItem1.ProductId = "Blue Widget";
lineItem1.Quantity = 54;
lineItem1.UnitCost = 29.99F;

PurchaseOrderLineItem lineItem2 = new PurchaseOrderLineItem();
lineItem2.ProductId = "Red Widget";
lineItem2.Quantity = 890;
lineItem2.UnitCost = 45.89F;

po.orderLineItems = new PurchaseOrderLineItem[2];
po.orderLineItems[0] = lineItem1;
po.orderLineItems[1] = lineItem2;

// Submit the purchase order.
Message msg = new Message();
msg.Body = po;
//Create a transaction scope.
using (TransactionScope scope = new TransactionScope(TransactionScopeOption.Required))
{
    
    orderQueue.Send(msg, MessageQueueTransactionType.Automatic);
    // Complete the transaction.
    scope.Complete();
   
}
Console.WriteLine("Placed the order:{0}", po);
Console.WriteLine("Press <ENTER> to terminate client.");
Console.ReadLine();

Quando si esegue l'esempio, le attività del client e del servizio vengono visualizzate nelle finestre della console del servizio e del client. È possibile osservare il servizio che riceve i messaggi dal client. Premere INVIO in tutte le finestre della console per arrestare il servizio e il client. Notare che essendo utilizzato l'accodamento, non è necessario che client e servizio siano in esecuzione contemporaneamente. Ad esempio è possibile eseguire il client, arrestarlo e quindi avviare il servizio e riceve comunque i messaggi.

Per impostare, compilare ed eseguire l'esempio

1. Assicurarsi di avere eseguito Procedura di installazione singola per gli esempi di Windows Communication Foundation.

2. Per generare l'edizione in C# o Visual Basic .NET della soluzione, seguire le istruzioni in Generazione degli esempi Windows Communication Foundation.

3. Per eseguire l'esempio su un solo computer, seguire le istruzioni in Esecuzione degli esempi di Windows Communication Foundation.

Per eseguire l'esempio tra più computer

1. Copiare i file del programma servizio dalla cartella \service\bin\, nella cartella specifica della lingua, al computer del servizio.

2. Copiare i file del programma client dalla cartella \client\bin\, nella cartella specifica della lingua, al computer client.

3. Nel file Client.exe.config, modificare l'orderQueueName per specificare il nome del computer del servizio anziché " ".

4. Sul computer del servizio, eseguire Service.exe da un prompt dei comandi.

5. Sul computer client, avviare Client.exe da un prompt dei comandi.

Vedere anche

Altre risorse

Queues in Windows Communication Foundation
How To: Exchange Messages with WCF Endpoints and MSMQ applications
Accodamento messaggi

Send comments about this topic to Microsoft.
© 2007 Microsoft Corporation. All rights reserved.