Attivazione MSMQ
In questo esempio viene illustrato come ospitare le applicazioni del servizio di attivazione dei processi di Windows (WAS) lette da una coda di messaggi. Questo esempio utilizza l'associazione netMsmqBinding ed è basato sull'esempio Comunicazione bidirezionale. Il servizio in questo caso è un'applicazione ospitata su Web. Il client è indipendente e genera output sulla console per osservare lo stato degli ordini di acquisto inviati.
Nota
La procedura di installazione e le istruzioni di compilazione per questo esempio si trovano alla fine dell'argomento.
Il servizio di attivazione dei processi di Windows (WAS), il nuovo meccanismo di attivazione del processo per Windows Server 2008, fornisce funzionalità simili a IIS che in precedenza erano disponibili solo per applicazioni basate su HTTP ad applicazioni che utilizzano protocolli non HTTP. Windows Communication Foundation (WCF) utilizza l'interfaccia dell'adattatore listener per comunicare le richieste di attivazione ricevute su protocolli non HTTP supportati da WCF, ad esempio TCP, Named Pipe e MSMQ. La funzionalità per ricevere richieste su protocolli non HTTP viene ospitata dai servizi Windows gestiti in esecuzione su SMSvcHost.exe.
Il servizio di adattatore listener Net.Msmq (NetMsmqActivator) attiva le applicazioni in coda in base ai messaggi nella coda.
Il client invia ordini di acquisto al servizio dall'ambito di una transazione. Il servizio riceve gli ordini in una transazione e li elabora. Il servizio richiama il client con lo stato dell'ordine. Per facilitare la comunicazione bidirezionale il client e il servizio utilizzano entrambi code per accodare gli ordini di acquisto e lo stato degli ordini.
Il contratto di servizio IOrderProcessor definisce operazioni del servizio unidirezionale che utilizzano l'accodamento. L'operazione del servizio utilizza l'endpoint di risposta per inviare gli stati degli ordini al client. L'indirizzo dell'endpoint di risposta è l'URI della coda utilizzato per restituire lo stato dell'ordine al client. L'applicazione di elaborazione degli ordini implementa questo contratto.
[ServiceContract(Namespace="http://Microsoft.ServiceModel.Samples")]
public interface IOrderProcessor
{
[OperationContract(IsOneWay = true)]
void SubmitPurchaseOrder(PurchaseOrder po,
string reportOrderStatusTo);
}
Il contratto di risposta a cui inviare lo stato dell'ordine è specificato dal client. Il client implementa il contratto dello stato dell'ordine. Il servizio utilizza il client generato di questo contratto per restituire lo stato dell'ordine al client.
[ServiceContract]
public interface IOrderStatus
{
[OperationContract(IsOneWay = true)]
void OrderStatus(string poNumber, string status);
}
L'operazione del servizio elabora l'ordine di acquisto inviato. OperationBehaviorAttribute viene applicato all'operazione del servizio per specificare l'inserimento automatico nell'elenco nella transazione utilizzata per ricevere il messaggio dalla coda e il completamento automatico della transazione al completamento dell'operazione del servizio. La classe Orders incapsula la funzionalità di elaborazione degli ordini. In questo caso, aggiunge l'ordine di acquisto a un dizionario. La transazione che l'operazione del servizio ha inserito nell'elenco è disponibile per le operazioni nella classe Orders.
L'operazione del servizio, oltre a elaborare l'ordine di acquisto inviato, risponde al client in merito allo stato dell'ordine.
public class OrderProcessorService : IOrderProcessor
{
[OperationBehavior(TransactionScopeRequired = true, TransactionAutoComplete = true)]
public void SubmitPurchaseOrder(PurchaseOrder po, string reportOrderStatusTo)
{
Orders.Add(po);
Console.WriteLine("Processing {0} ", po);
Console.WriteLine("Sending back order status information");
NetMsmqBinding msmqCallbackBinding = new NetMsmqBinding();
msmqCallbackBinding.Security.Mode = NetMsmqSecurityMode.None;
OrderStatusClient client = new OrderStatusClient(msmqCallbackBinding, new EndpointAddress(reportOrderStatusTo));
// please note that the same transaction that is used to dequeue purchase order is used
// to send back order status
using (TransactionScope scope = new TransactionScope(TransactionScopeOption.Required))
{
client.OrderStatus(po.PONumber, po.Status);
scope.Complete();
}
}
L'associazione client da utilizzare viene specificata mediante un file di configurazione.
Il nome della coda MSMQ è specificato in una sezione appSettings del file di configurazione. L'endpoint per il servizio è definito nella sezione System.serviceModel del file di configurazione.
Nota
Il nome della coda MSMQ e l'indirizzo endpoint utilizzano convenzioni di indirizzamento leggermente diverse. Nel nome della coda MSMQ viene utilizzato un punto (.) per il computer locale e il separatore barra rovesciata nel percorso. Nell'indirizzo endpoint di WCF viene specificato uno schema net.msmq:, viene utilizzato "localhost" per il computer locale e vengono utilizzate le barre nel percorso. Per leggere da una coda ospitata sul computer remoto, sostituire "." e "localhost" con il nome del computer remoto.
Viene utilizzato un file .svc con il nome della classe per ospitare il codice del servizio in WAS.
Il file Service.svc stesso contiene una direttiva per creare OrderProcessorService.
<%@ServiceHost language="c#" Debug="true" Service="Microsoft.ServiceModel.Samples.OrderProcessorService"%>
Il file Service.svc contiene inoltre una direttiva assembly per garantire che System.Transactions.dll venga caricato.
<%@Assembly name="System.Transactions, Version=2.0.0.0, Culture=neutral, PublicKeyToken=b77a5c561934e089"%>
Il client crea un ambito della transazione. La comunicazione con il servizio avviene all'interno dell'ambito della transazione, la quale viene trattata come unità atomica nella quale tutti i messaggi hanno esito positivo o negativo. Il commit della transazione viene eseguito chiamando Complete nell'ambito della transazione.
using (ServiceHost serviceHost = new ServiceHost(typeof(OrderStatusService)))
{
// Open the ServiceHostBase to create listeners and start listening
// for order status messages.
serviceHost.Open();
// Create a proxy with given client endpoint configuration
OrderProcessorClient client = new OrderProcessorClient();
// 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;
//Create a transaction scope.
using (TransactionScope scope = new
TransactionScope(TransactionScopeOption.Required))
{
// Make a queued call to submit the purchase order
client.SubmitPurchaseOrder(po,
"net.msmq://localhost/private/ServiceModelSamples/OrderStatus");
// Complete the transaction.
scope.Complete();
}
//Closing the client gracefully closes the connection and cleans up
//resources
client.Close();
Console.WriteLine();
Console.WriteLine("Press <ENTER> to terminate client.");
Console.ReadLine();
// Close the ServiceHostBase to shutdown the service.
serviceHost.Close();
}
Il codice client implementa il contratto IOrderStatus per ricevere lo stato dell'ordine dal servizio. In questo caso, stampa lo stato dell'ordine.
[ServiceBehavior]
public class OrderStatusService : IOrderStatus
{
[OperationBehavior(TransactionAutoComplete = true,
TransactionScopeRequired = true)]
public void OrderStatus(string poNumber, string status)
{
Console.WriteLine("Status of order {0}:{1} ",
poNumber , status);
}
}
La coda dello stato degli ordini viene creata nel metodo Main. La configurazione del client comprende la configurazione del servizio di stato degli ordini per ospitare il servizio di stato degli ordini, come illustrato nella configurazione di esempio seguente.
<appSettings>
<!-- use appSetting to configure MSMQ queue name -->
<add key="targetQueueName" value=".\private$\ServiceModelSamples/service.svc" />
<add key="responseQueueName" value=".\private$\ServiceModelSamples/OrderStatus" />
</appSettings>
<system.serviceModel>
<services>
<service
name="Microsoft.ServiceModel.Samples.OrderStatusService">
<!-- Define NetMsmqEndpoint -->
<endpoint address="net.msmq://localhost/private/ServiceModelSamples/OrderStatus"
binding="netMsmqBinding"
contract="Microsoft.ServiceModel.Samples.IOrderStatus" />
</service>
</services>
<client>
<!-- Define NetMsmqEndpoint -->
<endpoint name="OrderProcessorEndpoint"
address="net.msmq://localhost/private/ServiceModelSamples/service.svc"
binding="netMsmqBinding"
contract="Microsoft.ServiceModel.Samples.IOrderProcessor" />
</client>
</system.serviceModel>
Quando si esegue l'esempio, le attività del client e del servizio vengono visualizzate nelle finestre della console del server e del client. È possibile osservare che il server riceve i messaggi dal client. Premere INVIO in tutte le finestre della console per arrestare il server e il client.
Il client visualizza le informazioni sullo stato dell'ordine inviate dal server.
Press <ENTER> to terminate client.
Status of order 70cf9d63-3dfa-4e69-81c2-23aa4478ebed :Pending
Per impostare, compilare ed eseguire l'esempio
Assicurarsi di aver eseguito la Procedura di installazione singola per gli esempi di Windows Communication Foundation. È inoltre necessario installare i componenti di attivazione non HTTP di WCF:
- Fare clic sul pulsante Start e scegliere Pannello di controllo.
- Selezionare Programmi, quindi Programmi e funzionalità oppure nella visualizzazione classica selezionare Programmi e funzionalità.
- Fare clic su Attiva o disattiva le funzionalità Windows.
- Sotto Riepilogo funzionalità, fare clic su Aggiungi funzionalità.
- Espandere il nodo Microsoft .NET Framework 3.0 e selezionare la funzionalità Attivazione non HTTP di Windows Communication Foundation.
Per compilare l'edizione in C# o Visual Basic .NET della soluzione, seguire le istruzioni in Generazione degli esempi Windows Communication Foundation.
Eseguire il client lanciando client.exe da una finestra di comando. In questo modo viene creata la coda e gli viene inviato un messaggio. Lasciare il client in esecuzione per vedere cosa succede quando il servizio legge il messaggio
Il servizio di attivazione MSMQ viene eseguito come impostazione predefinita come Servizio di rete. Pertanto, la coda utilizzata per attivare l'applicazione deve disporre delle autorizzazioni di ricezione e di lettura per il Servizio di rete. Queste autorizzazioni possono essere aggiunte utilizzando il sistema di accodamento messaggi MMC:
- Fare clic sul pulsante Start e fare clic su Esegui, quindi digitare Compmgmt.msc e premere INVIO.
- In Servizi e applicazioni, espandere Accodamento messaggi.
- Fare clic su Code private.
- Fare clic con il pulsante destro del mouse sulla coda (servicemodelsamples/Service.svc) e scegliere Proprietà.
- Nella scheda Protezione fare clic su Aggiungi e attivare le autorizzazioni di ricezione e lettura Servizio di rete.
Configurare il servizio di attivazione dei processi di Windows (WAS) per supportare l'attivazione MSMQ.
- Eseguire Inetmgr.exe.
- Per consentire al sito Web predefinito di comunicare sul protocollo net.msmq è necessario aggiungere una nuova associazione di sito. A tale scopo, eseguire file di comando AddMsmqSiteBinding.cmd situato nella directory degli esempi.
Se in precedenza non è stato fatto, assicurarsi che il servizio di attivazione MSMQ sia attivato. Dal menu Start, selezionareEsegui, quindi digitare Services.msc. Cercare Adattatore listener Net.Msmq nell'elenco di servizi. Fare clic con il pulsante destro del mouse e selezionare Proprietà. Impostare il Tipo di avvio su Automatico, fare clic su Applica e fare clic sul pulsante Start. È necessario eseguire questo passaggio solo la prima volta che si utilizza il servizio di adattatore listener Net.Msmq.
Per eseguire l'esempio su una configurazione con un solo computer o tra computer diversi, seguire le istruzioni in Esecuzione degli esempi di Windows Communication Foundation. Modificare inoltre il codice sul client che invia l'ordine di acquisto per riflettere il nome del computer nell'URI della coda durante l'invio di ordini di acquisto. Utilizzare il codice seguente:
client.SubmitPurchaseOrder(po, "net.msmq://localhost/private/ServiceModelSamples/OrderStatus");
Per impostazione predefinita con il trasporto dell'associazione netMsmqBinding è attivata la protezione. Il tipo di protezione del trasporto è determinato da due proprietà, MsmqAuthenticationMode e MsmqProtectionLevel. Per impostazione predefinita, la modalità di autenticazione è impostata su Windows e il livello di protezione è impostato su Sign. Affinché MSMQ fornisca la funzionalità di autenticazione e firma, deve appartenere a un dominio. Se si esegue questo esempio in un computer che non appartiene a un dominio, si riceverà l'errore seguente: "Il certificato interno del servizio di accodamento messaggi non esiste".
Per eseguire l'esempio in un computer appartenente a un gruppo di lavoro
Se il computer non appartiene a un dominio, disattivare la protezione del trasporto impostando la modalità di autenticazione e il livello di protezione su None, come illustrato nell'esempio di configurazione seguente.
<bindings> <netMsmqBinding> <binding configurationName="TransactedBinding"> <security mode="None"/> </binding> </netMsmqBinding> </bindings>Modificare la configurazione sul server e sul client prima di eseguire l'esempio.
Nota
L'impostazione di security mode su None è equivalente all'impostazione di MsmqAuthenticationMode, MsmqProtectionLevel e della protezione Message su None.
Per abilitare l'attivazione su un computer che fa parte di un gruppo di lavoro, il servizio di attivazione e il processo di lavoro devono essere eseguiti con un account utente specifico (deve essere lo stesso per entrambi) e la coda deve essere dotata di ACL per l'account utente specifico.
Per modificare l'identità con la quale viene eseguito il processo di lavoro:
- Eseguire Inetmgr.exe.
- In Pool di applicazioni, fare clic con il pulsante destro del mouse suAppPool (in genere DefaultAppPool) e scegliere Impostazioni predefinite pool di applicazioni.
- Modificare le proprietà dell'identità per utilizzare l'account utente specifico.
Per modificare l'identità con la quale viene eseguito il servizio di attivazione:
- Eseguire Services.msc.
- Fare clic con il pulsante destro del mouse su Adattatore listener Net.Msmq e scegliere Proprietà.
Modificare l'account nella scheda Accesso.
In un gruppo di lavoro, è inoltre necessario che il servizio venga eseguito utilizzando un token di accesso senza restrizioni. Per eseguire questa operazione, eseguire il seguente comando:
sc sidtype netmsmqactivator unrestricted
Send comments about this topic to Microsoft.
© 2007 Microsoft Corporation. All rights reserved.