Gestione dei messaggi non elaborabili

Articolo
02/27/2011

Per messaggio non elaborabile si intende un messaggio che ha superato il numero massimo di tentativi di recapito all'applicazione. Questa situazione può insorgere quando un'applicazione basata sulla coda non è in grado di elaborare un messaggio a causa di errori. Per far fronte a richieste di affidabilità, un'applicazione in coda riceve messaggi nell'ambito di una transazione. Se la transazione nella quale è stato ricevuto un messaggio in coda viene interrotta, il messaggio resta nella coda, quindi viene eseguito un nuovo tentativo nell'ambito di una nuova transazione. Se il problema che ha determinato l'interruzione della transazione non viene risolto, l'applicazione ricevente può rimanere bloccata in una successione continua di ricezioni e interruzioni dello stesso messaggio fino al raggiungimento del numero massimo di tentativi di recapito. Ne consegue l'impossibilità di elaborare il messaggio.

Un messaggio può diventare non elaborabile per varie ragioni. Le cause più comuni sono specifiche dell'applicazione. Ad esempio, se un'applicazione legge un messaggio da una coda ed esegue alcune operazioni di elaborazione del database, è possibile che non riesca a ottenere un blocco per il database, causando l'interruzione della transazione. A causa dell'interruzione della transazione del database, il messaggio rimane nella coda e l'applicazione è costretta a rileggerlo una seconda volta e ad eseguire un altro tentativo di acquisire un blocco sul database. I messaggi, inoltre, possono diventare non elaborabili se contengono informazioni non valide. Un ordine di acquisto, ad esempio, potrebbe contenere un numero cliente non valido. In questi casi è possibile che l'applicazione interrompa a ragione la transazione determinando la trasformazione del messaggio in messaggio non elaborabile.

In rari casi è possibile che i messaggi non vengano inviati all'applicazione. Il livello di Windows Communication Foundation (WCF) può rilevare l'esistenza di un problema relativo al messaggio, ad esempio il messaggio dispone del frame errato, le credenziali allegate non sono valide oppure presenta un'intestazione Action non valida. In questi casi l'applicazione non riceve mai il messaggio ma quest'ultimo, pur diventando non elaborabile, può essere elaborato manualmente.

Gestione di messaggi non elaborabili

In WCF la gestione dei messaggi non elaborabili mette a disposizione dell'applicazione ricevente un meccanismo per gestire messaggi che non possono essere inviati all'applicazione o messaggi inviati all'applicazione che però non possono essere elaborati per motivi specifici dell'applicazione. La gestione dei messaggi non elaborabili è configurata in base alle proprietà seguenti in ogni associazione in coda disponibile:

ReceiveRetryCount. Valore integer che indica il numero massimo di tentativi di recapito di un messaggio dalla coda dell'applicazione all'applicazione. Il valore predefinito è 5. È sufficiente nei casi in cui un tentativo immediato corregge il problema, ad esempio con un deadlock temporaneo su un database.
MaxRetryCycles. Valore integer che indica il numero massimo di cicli di ripetizione. Un ciclo di ripetizione consiste nel trasferimento di un messaggio dalla coda dell'applicazione alla coda secondaria dei tentativi e, dopo un intervallo di tempo configurabile, dalla coda secondaria dei tentativi alla coda dell'applicazione per tentare di nuovo il recapito. Il valore predefinito è 2. In Windows Vista i tentativi vengono ripetuti un numero massimo di (ReceiveRetryCount +1) * (MaxRetryCycles + 1) volte. MaxRetryCycles viene ignorato in Windows Server 2003 e Windows XP.
RetryCycleDelay. Intervallo di tempo tra cicli di ripetizione. Il valore predefinito è 30 minuti. MaxRetryCycles e RetryCycleDelay forniscono insieme un meccanismo per affrontare il problema laddove un tentativo eseguito dopo un certo tempo lo risolve. È ad esempio in grado di gestire un set di righe bloccate in un commit di transazioni in sospeso di SQL Server.
ReceiveErrorHandling. Enumerazione che indica l'azione da intraprendere per un messaggio non recapitato dopo il numero massimo di tentativi. I valori possono essere Errore, Rilascia, Rifiuta e Sposta. L'opzione predefinita è Errore.
Errore. Viene inviato un errore al listener che ha determinato l'errore di ServiceHost. È necessario che il messaggio venga rimosso dalla coda dell'applicazione da un meccanismo esterno perché l'applicazione possa continuare a elaborare i messaggi in coda.
Rilascia. Il messaggio non elaborabile viene eliminato e non verrà mai recapitato all'applicazione. Se a questo punto la proprietà TimeToLive del messaggio è scaduta, è possibile che il messaggio venga visualizzato nella coda dei messaggi non recapitabili del mittente. In caso contrario, il messaggio non viene visualizzato mai. L'opzione indica che l'utente non ha specificato l'operazione da eseguire in caso di perdita del messaggio.
Rifiuta. Opzione disponibile solo in Windows Vista. Viene indicato a MSMQ di inviare al gestore code mittente un acknowledgement negativo che indichi che l'applicazione non è in grado di ricevere il messaggio. Il messaggio viene inserito nella coda di messaggi non recapitabili del gestore code mittente.
Sposta. Opzione disponibile solo in Windows Vista. Il messaggio non elaborabile viene spostato in una coda di messaggi non elaborabili per l'elaborazione successiva da parte di un'applicazione di gestione apposita. La coda di messaggi non elaborabili è una coda secondaria della coda dell'applicazione. Un'applicazione di gestione di messaggi non elaborabili può essere un servizio WCF che legge i messaggi dalla coda non elaborabile. La coda non elaborabile è una coda secondaria della coda dell'applicazione e può essere indicata come net.msmq://<nome computer>/CodaApplicazione;poison, dove nomecomputer è il nome del computer in cui si trova la coda e CodaApplicazione è il nome della coda specifica dell'applicazione.

Di seguito è indicato il numero massimo di tentativi di recapito possibili per un messaggio:

((ReceiveRetryCount+1) * (MaxRetryCycles + 1)) in Windows Vista.
(ReceiveRetryCount + 1) in Windows Server 2003 e Windows XP.

Nota:
Non vengono eseguiti altri tentativi per i messaggi recapitati correttamente.

Per tenere traccia del numero dei tentativi di lettura di un messaggio, in Windows Vista vengono gestite una proprietà del messaggio durevole che conta il numero di interruzioni e una proprietà del numero di spostamenti che conta gli spostamenti del messaggio tra la coda dell'applicazione e le code secondarie. Queste proprietà vengono utilizzate nel canale di WCF per calcolare il numero di tentativi di ricezione e il numero dei cicli di ripetizione. In Windows Server 2003 e Windows XP il numero delle interruzioni viene conservato in memoria dal canale WCF e viene azzerato se nell'applicazione si verifica un errore. Il canale WCF, inoltre, è in grado di mantenere in memoria un numero massimo di 256 interruzioni di messaggi in qualsiasi momento. Se viene letto il 257° messaggio, il messaggio più vecchio viene eliminato dal conteggio.

Le proprietà del numero di interruzioni e del numero di spostamenti sono a disposizione dell'operazione del servizio mediante il contesto dell'operazione. Nell'esempio di codice seguente viene spiegato come accedervi.

MsmqMessageProperty mqProp = OperationContext.Current.IncomingMessageProperties[MsmqMessageProperty.Name] as MsmqMessageProperty;
Console.WriteLine("Abort count: {0} ", mqProp.AbortCount);
Console.WriteLine("Move count: {0} ", mqProp.MoveCount);
// code to submit purchase order ...

WCF fornisce due associazioni in coda standard:

NetMsmqBinding. Associazione di .NET Framework idonea per l'esecuzione di comunicazioni basate sulla coda con altri endpoint WCF.
MsmqIntegrationBinding. Associazione idonea per la comunicazione con applicazioni di accodamento messaggi esistenti.

Nota:
È possibile modificare le proprietà di queste associazioni in base ai requisiti del servizio WCF. L'intero meccanismo di gestione dei messaggi non elaborabili è locale nell'applicazione ricevente. A meno che l'applicazione ricevente non venga arrestata e non venga inviato un acknowledgment negativo al mittente, il processo è invisibile all'applicazione mittente. In questo caso il messaggio viene spostato nella coda dei messaggi non recapitabili del mittente.

È possibile modificare le proprietà di queste associazioni in base ai requisiti del servizio WCF. L'intero meccanismo di gestione dei messaggi non elaborabili è locale nell'applicazione ricevente. A meno che l'applicazione ricevente non venga arrestata e non venga inviato un acknowledgment negativo al mittente, il processo è invisibile all'applicazione mittente. In questo caso il messaggio viene spostato nella coda dei messaggi non recapitabili del mittente.

Procedura consigliata: gestione di MsmqPoisonMessageException

Quando il servizio stabilisce che un messaggio non è elaborabile, il trasporto in coda genera un'eccezione MsmqPoisonMessageException contenente il LookupId del messaggio non elaborabile.

Un'applicazione ricevente può implementare l'interfaccia IErrorHandler per gestire qualsiasi errore che l'applicazione richieda. Per ulteriori informazioni, vedere Estensione del controllo sulla gestione e sulla segnalazione degli errori.

L'applicazione potrebbe richiedere una forma di gestione automatica dei messaggi non elaborabili per spostare tali messaggi in una coda apposita affinché il servizio possa accedere al resto dei messaggi presenti nella coda. L'unico scenario in cui viene utilizzato il meccanismo di gestione degli errori per rimanere in attesa delle eccezioni di messaggi non elaborabili si verifica quanto la proprietà ReceiveErrorHandling è impostata su Fault. Nell'esempio di messaggio non elaborabile per Accodamento messaggi 3.0 viene illustrato questo comportamento. Di seguito vengono descritti i passaggi necessari per gestire i messaggi non elaborabili, comprese le procedure consigliate:

Assicurarsi che le impostazioni dei messaggi non elaborabili rispettino i requisiti dell'applicazione. Quando si modificano le impostazioni, verificare di aver compreso le differenze tra Windows Vista, Windows Server 2003 e Windows XP per quanto riguarda le funzionalità di Accodamento messaggi.

Se necessario, implementare IErrorHandler per gestire gli errori di messaggi non elaborabili. Poiché l'impostazione di ReceiveErrorHandling su Fault richiede un meccanismo manuale per rimuovere dalla coda il messaggio non elaborabile o per correggere un problema collegato esterno, l'utilizzo tipico consiste nell'implementare IErrorHandler quando ReceiveErrorHandling è impostato su Fault, come illustrato nel codice seguente.

class PoisonErrorHandler : IErrorHandler
{
    public void ProvideFault(Exception error, MessageVersion version, ref Message fault)
    {
        // No-op -We are not interested in this. This is only useful if you want to send back a fault on the wirenot applicable for queues [one-way].
    }

    public bool HandleError(Exception error)
    {
        if (error != null && error.GetType() == typeof(MsmqPoisonMessageException))
        {
            Console.WriteLine(" Poisoned message -message look up id = {0}", ((MsmqPoisonMessageException)error).MessageLookupId);
            return true;
        }

        return false;
    }
}

Creare un attributo PoisonBehaviorAttribute che possa essere utilizzato dal comportamento del servizio. Il comportamento installa IErrorHandler nel dispatcher. Vedere l'esempio di codice seguente.

public class PoisonErrorBehaviorAttribute : Attribute, IServiceBehavior
{
    Type errorHandlerType;

    public PoisonErrorBehaviorAttribute(Type errorHandlerType)
    {
        this.errorHandlerType = errorHandlerType;
    }

    void IServiceBehavior.Validate(ServiceDescription description, ServiceHostBase serviceHostBase)
    {
    }

    void IServiceBehavior.AddBindingParameters(ServiceDescription description, ServiceHostBase serviceHostBase, System.Collections.ObjectModel.Collection<ServiceEndpoint> endpoints, BindingParameterCollection parameters)
    {
    }

    void IServiceBehavior.ApplyDispatchBehavior(ServiceDescription description, ServiceHostBase serviceHostBase)
    {
        IErrorHandler errorHandler;

        try
        {
            errorHandler = (IErrorHandler)Activator.CreateInstance(errorHandlerType);
        }
        catch (MissingMethodException e)
        {
            throw new ArgumentException("The errorHandlerType specified in the PoisonErrorBehaviorAttribute constructor must have a public empty constructor", e);
        }
        catch (InvalidCastException e)
        {
            throw new ArgumentException("The errorHandlerType specified in the PoisonErrorBehaviorAttribute constructor must implement System.ServiceModel.Dispatcher.IErrorHandler", e);
        }

        foreach (ChannelDispatcherBase channelDispatcherBase in serviceHostBase.ChannelDispatchers)
        {
            ChannelDispatcher channelDispatcher = channelDispatcherBase as ChannelDispatcher;
            channelDispatcher.ErrorHandlers.Add(errorHandler);
        }
    }
}

Assicurarsi che il servizio sia annotato con l'attributo del comportamento non elaborabile.

<configuration>
  <appSettings>
    <!-- use appSetting to configure MSMQ queue name -->
    <add key="queueName" value=".\private$\ServiceModelSamplesPoison" />
    <add key="baseAddress" value="https://localhost:8000/orderProcessor/poisonSample"/>
  </appSettings>
  <system.serviceModel>
    <services>
      <service 
              name="Microsoft.ServiceModel.Samples.OrderProcessorService">
        <!-- Define NetMsmqEndpoint -->
        <endpoint address="net.msmq://localhost/private/ServiceModelSamplesPoison"
                  binding="netMsmqBinding"
                  bindingConfiguration="PoisonBinding" 
                  contract="Microsoft.ServiceModel.Samples.IOrderProcessor" />
      </service>
    </services>

    <bindings>
      <netMsmqBinding>
        <binding name="PoisonBinding" 
                 receiveRetryCount="0"
                 maxRetryCycles="1"
                 retryCycleDelay="00:00:05"                      
                 receiveErrorHandling="Fault"
                        />
      </netMsmqBinding>
    </bindings>
  </system.serviceModel>
</configuration>

Inoltre, se ReceiveErrorHandling è impostato su Fault, in ServiceHost si verificherà un errore in presenza di un messaggio non elaborabile. È possibile associare l'evento di errore e arrestare il servizio, adottare misure correttive e riavviare. Ad esempio, è possibile notare LookupId in MsmqPoisonMessageException propagato in IErrorHandler e quando si verifica un errore nell'host del servizio, è possibile utilizzare l'API System.Messaging per ricevere il messaggio dalla coda tramite LookupId, rimuovere il messaggio dalla coda e archiviarlo in un archivio esterno o in un'altra coda. È quindi possibile riavviare il ServiceHost per riprendere l'elaborazione normale. In Poison Message Handling in MSMQ 3.0 viene illustrato questo comportamento.

Timeout della transazione e messaggi non elaborabili

È possibile che si verifichi una classe di errori tra il canale del trasporto in coda e il codice utente. Gli errori possono essere rilevati da livelli intermedi, ad esempio il livello di sicurezza del messaggio o la logica di invio del servizio. Ad esempio, un certificato X.509 mancante rilevato nel livello di sicurezza SOAP e un'azione mancante sono casi in cui il messaggio viene inviato all'applicazione. In queste situazioni, il messaggio viene eliminato dal modello del servizio. Poiché il messaggio viene letto in una transazione per la quale non può essere fornito alcun risultato, la transazione alla fine scade, viene interrotta e il messaggio viene nuovamente inserito nella coda. In altre parole, per una certa classe di errori la transazione non viene interrotta immediatamente ma quando scade. È possibile modificare il timeout della transazione per un servizio utilizzando ServiceBehaviorAttribute.

Per modificare il timeout della transazione a livello di computer, modificare il file machine.config e impostare il timeout appropriato della transazione. È importante notare che, in funzione del timeout impostato nella transazione, la transazione verrà infine interrotta e inserita nuovamente nella coda e il relativo conteggio delle interruzioni verrà incrementato. Il messaggio diventerà non elaborabile e verranno eseguite le azioni di eliminazione appropriate in base alle impostazioni dell'utente.

Sessioni e messaggi non elaborabili

Una sessione subisce le stesse procedure di ripetizione e gestione di messaggi non elaborabili di un messaggio singolo. Le proprietà elencate in precedenza per i messaggi non elaborabili sono applicabili all'intera sessione. Ciò significa che l'intera sessione verrà ripetuta e verrà inserita in una coda finale di messaggi non elaborabili o nella coda di messaggi non recapitabili del mittente se il messaggio verrà rifiutato.

Batch e messaggi non elaborabili

Se un messaggio diventa non elaborabile e fa parte di un batch, viene eseguito il rollback dell'intero batch e il canale riprende a leggere i messaggi uno alla volta. Per ulteriori informazioni su sui batch, vedere Raggruppamento di messaggi in una transazione.

Gestione di messaggi non elaborabili per messaggi di una coda non elaborabile

La gestione di messaggi non elaborabili non termina quando un messaggio viene inserito nella coda di messaggi non elaborabili. I messaggi presenti nella coda di messaggi non elaborabili devono comunque essere letti e gestiti. È possibile utilizzare un sottoinsieme di impostazioni della gestione di messaggi non elaborabili durante la lettura di messaggi dalla coda secondaria non elaborabile finale. Le impostazioni applicabili sono ReceiveRetryCount e ReceiveErrorHandling. È possibile impostare ReceiveErrorHandling su Rilascia, Rifiuta o Errore. MaxRetryCycles viene ignorato e viene generata un'eccezione se ReceiveErrorHandling è impostato su Sposta.

Differenze tra Windows Vista, Windows Server 2003 e Windows XP

Come notato più indietro, non tutte le impostazioni della gestione di messaggi non elaborabili sono valide per Windows Server 2003 e Windows XP. Le differenze principali seguenti tra Windows Server 2003, Windows XP e Windows Vista relative ad Accodamento messaggi riguardano la gestione di messaggi non elaborabili:

Accodamento messaggi in Windows Vista supporta le code secondarie, che in Windows Server 2003 e Windows XP non sono supportate. Le code secondarie vengono utilizzate nella gestione dei messaggi non elaborabili. Le code di tentativi e la coda non elaborabile sono code secondarie della coda dell'applicazione creata in base alle impostazioni di gestione dei messaggi non elaborabili. MaxRetryCycles stabilisce il numero delle code secondarie dei tentativi che verranno create. Di conseguenza, in caso di esecuzione in Windows Server 2003 o Windows XP, MaxRetryCycles viene ignorato e ReceiveErrorHandling.Move non è consentito.
Accodamento messaggi in Windows Vista supporta il riconoscimento negativo, diversamente da quanto avviene in Windows Server 2003 e Windows XP. Un negative acknowledgment dal gestore delle code ricevente determina l'inserimento, da parte del gestore delle code mittente, del messaggio respinto nella coda dei messaggi non recapitabili. Per questa ragione ReceiveErrorHandling.Reject non è consentito con Windows Server 2003 e Windows XP.
Accodamento messaggi in Windows Vista supporta una proprietà del messaggio che conta il numero di volte che viene tentato di recapitare il messaggio. Questa proprietà del numero di interruzioni non è disponibile in Windows Server 2003 e Windows XP. Poiché in WCF il conteggio delle interruzioni viene conservato in memoria, è possibile che questa proprietà non contenga un valore accurato quando lo stesso messaggio viene letto da più di un servizio WCF in un farm.

Vedere anche

Concetti

Panoramica delle code
Differenze nelle funzionalità di accodamento in Windows Vista, Windows Server 2003 e Windows XP
Specifica e gestione di errori in contratti e servizi

Condividi tramite