Intercettore dei messaggi personalizzati

In questo esempio viene illustrato l'utilizzo del modello di estensibilità del canale. In particolare, viene illustrato come implementare un elemento di associazione personalizzato che crea channel factory e listener del canale per intercettare tutti i messaggi in ingresso e in uscita in un particolare punto nello stack di runtime. L'esempio include anche un client e un server che illustrano l'utilizzo di queste factory personalizzate.

In questo esempio sia il client che il servizio sono programmi console (.exe). Il client e il servizio fanno entrambi uso di una libreria comune (.dll) che contiene l'elemento di associazione personalizzato e gli oggetti di runtime associati.

L'esempio descrive la procedura consigliata per la creazione di un canale su più livelli personalizzato in Windows Communication Foundation (WCF), utilizzando il framework del canale e le procedure consigliate di WCF che seguono. I passaggi per creare un canale su più livelli personalizzato sono i seguenti.

1. Decidere quali forme del canale saranno supportate dalla channel factory e dal listener del canale.
2. Creare una channel factory e un listener di canale che supportano le forme del canale.
3. Inserire un elemento di associazione che aggiunge il canale su più livelli personalizzato a uno stack di canali. Per ulteriori informazioni, vedere Adding a Binding Element.
4. Aggiungere una sezione di estensione degli elementi di associazione per esporre il nuovo elemento di associazione al sistema di configurazione.

Forme del canale

Per scrivere un canale su più livelli personalizzato, è necessario innanzitutto stabilire quali forme sono necessarie per il canale. Per il controllo messaggi, si supporta qualsiasi forma supportata dal livello sottostante (ad esempio, se il livello sottostante può compilare IOutputChannel e IDuplexSessionChannel, si espongono anche IOutputChannel e IDuplexSessionChannel).

Channel Factory e Listener Factory

Il passaggio succcessivo per scrivere un canale su più livelli personalizzato consiste nel creare un'implementazione di IChannelFactory per i canali client e diIChannelListener per i canali del servizio.

Queste classi prendono una factory interna e un listener e delegano tutto tranne le chiamate OnCreateChannel e OnAcceptChannel alla factory interna e al listener.

    class InterceptingChannelFactory<TChannel> : ChannelFactoryBase<TChannel>
    { ... }
    class InterceptingChannelListener<TChannel> : ListenerFactoryBase<TChannel>
    { ... }

Aggiunta di un elemento di associazione.

L'esempio definisce un elemento di associazione personalizzato: InterceptingBindingElement. InterceptingBindingElement prende ChannelMessageInterceptor come input, e utilizza tale ChannelMessageInterceptor per manipolare i messaggi che vi passano attraverso. Si tratta della sola classe che deve essere pubblica. La factory, il listener e i canali possono tutti essere implementazioni interne delle interfacce di runtime pubbliche.

public class InterceptingBindingElement : BindingElement

Aggiunta del supporto di configurazione

Per integrare la configurazione di associazione la libreria definisce un gestore della sezione di configurazione come sezione di estensione dell'elemento di associazione. I file di configurazione del client e del server devono registrare l'estensione dell'elemento di associazione con il sistema di configurazione. Implementatori che vogliono esporre l'elemento di associazione al sistema di configurazione possono derivare da questa classe.

public abstract class InterceptingElement : BindingElementExtensionElement { ... }

Aggiunta di criteri

Per integrarsi con il sistema dei criteri, InterceptingBindingElement implementa IPolicyExportExtension per segnalare che si deve partecipare alla generazione di criteri. Per supportare i criteri di importazione su un client generato, l'utente può iscrivere una classe derivata di InterceptingBindingElementImporter() ed eseguire l'override di CreateMessageInterceptor per generare la classe ChannelMessageInterceptor attivata dal criterio.

Esempio: Controllo messaggi eliminabili

Inclusa nell'esempio vi è un'implementazione di esempio di ChannelMessageInspector che elimina i messaggi.

    class DroppingServerElement : InterceptingElement
    {
        protected override ChannelMessageInterceptor CreateMessageInterceptor()
        {
            return new DroppingServerInterceptor();
        }
    }

È possibile accedervi tramite configurazione come segue:

<configuration>
    ...
    <system.serviceModel>
        ...
        <extensions>
            <bindingElementExtensions>
                <add name="droppingInterceptor" 
                   type=
          "Microsoft.ServiceModel.Samples.DroppingServerElement, library"/>
            </bindingElementExtensions>
        </extensions>
    </system.serviceModel>
</configuration>

Il client e il server utilizzano entrambi questa sezione di configurazione appena creata per inserire le factory personalizzate nel livello più basso degli stack dei canali di runtime (sopra il livello del trasporto).

<customBinding>
  <binding name="sampleBinding">
    <droppingInterceptor/>
    <httpTransport/>
  </binding>
</customBinding>

Il client utilizza la libreria MessageInterceptor per aggiungere un'intestazione personalizzata ai messaggi, anche a quelli numerati. Il servizio d'altro canto utilizza la libreria MessageInterceptor per eliminare qualsiasi messaggio che non ha questa intestazione speciale.

Dopo l'esecuzione del servizio e del client, l'output del client dovrebbe essere il seguente.

Reporting the next 10 wind speed
100 kph
Server dropped a message.
90 kph
80 kph
Server dropped a message.
70 kph
60 kph
Server dropped a message.
50 kph
40 kph
Server dropped a message.
30 kph
20 kph
Server dropped a message.
10 kph
Press ENTER to shut down client

Il client riporta 10 diverse velocità del vento al servizio, ma contrassegna solo la metà di esse con un'intestazione speciale.

Nel servizio, si dovrebbe vedere l'output seguente.

Press ENTER to exit.
Dangerous wind detected! Reported speed (90) is greater than 64 kph.
Dangerous wind detected! Reported speed (70) is greater than 64 kph.
5 wind speed reports have been received.

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 la soluzione, seguire le istruzioni in Generazione degli esempi Windows Communication Foundation.

3. 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.

4. Eseguire prima Service.exe quindi Client.exe e controllare l'output di entrambe le finestre della console.

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