Intercetador de mensagens personalizado

Artigo
03/12/2024

O exemplo MessageInterceptor demonstra o uso do modelo de extensibilidade de canal. Em particular, ele mostra como implementar um elemento de vinculação personalizado que cria fábricas de canais e ouvintes de canal para intercetar todas as mensagens de entrada e saída em um ponto específico na pilha de tempo de execução. O exemplo também inclui um cliente e um servidor que demonstram o uso dessas fábricas personalizadas.

Neste exemplo, o cliente e o serviço são programas de console (.exe). O cliente e o serviço usam uma biblioteca comum (.dll) que contém o elemento de vinculação personalizado e seus objetos de tempo de execução associados.

Nota

O procedimento de configuração e as instruções de compilação para este exemplo estão localizados no final deste tópico.

O exemplo descreve o procedimento recomendado para criar um canal em camadas personalizado no Windows Communication Foundation (WCF), usando a estrutura de canal e seguindo as práticas recomendadas do WCF. As etapas para criar um canal em camadas personalizado são as seguintes:

Decida qual dos canais molda sua fábrica de canais e o ouvinte do canal suportará.
Crie uma fábrica de canais e um ouvinte de canais que suportem as formas do seu canal.
Adicione um elemento de vinculação que adiciona o canal em camadas personalizado a uma pilha de canais.
Adicione uma seção de extensão de elemento de vinculação para expor o novo elemento de vinculação ao sistema de configuração.

Formas de canal

A primeira etapa para escrever um canal em camadas personalizado é decidir quais formas são necessárias para o canal. Para o nosso inspetor de mensagens, suportamos qualquer forma que a camada abaixo de nós suporta (por exemplo, se a camada abaixo de nós pode construir IOutputChannel e IDuplexSessionChannel, então também expomos IOutputChannel e IDuplexSessionChannel).

Fábrica de canais e fábrica de ouvintes

O próximo passo para escrever um canal em camadas personalizado é criar uma implementação de para canais de cliente e de para canais de IChannelFactory IChannelListener serviço.

Essas aulas tomam uma fábrica interna e ouvinte, e delegam tudo, exceto o OnCreateChannel e OnAcceptChannel chama para a fábrica interna e ouvinte.

class InterceptingChannelFactory<TChannel> : ChannelFactoryBase<TChannel>
{
    //...
}

class InterceptingChannelListener<TChannel> : ListenerFactoryBase<TChannel>
{
    //...
}

Adicionando um elemento de vinculação

O exemplo define um elemento de vinculação personalizado: InterceptingBindingElement. InterceptingBindingElement toma um ChannelMessageInterceptor como entrada e usa isso ChannelMessageInterceptor para manipular mensagens que passam por ele. Esta é a única classe que deve ser pública. A fábrica, o ouvinte e os canais podem ser implementações internas das interfaces públicas de tempo de execução.

public class InterceptingBindingElement : BindingElement
{
}

Adicionando suporte à configuração

Para integrar com a configuração de ligação, a biblioteca define um manipulador de seção de configuração como uma seção de extensão de elemento de ligação. Os arquivos de configuração do cliente e do servidor devem registrar a extensão do elemento de ligação com o sistema de configuração. Os implementadores que desejam expor seu elemento de ligação ao sistema de configuração podem derivar dessa classe.

public abstract class InterceptingElement : BindingElementExtensionElement
{
    //...
}

Adicionando política

Para integrar com o nosso sistema de políticas, InterceptingBindingElement implementa IPolicyExportExtension para sinalizar que devemos participar na geração de política. Para dar suporte à importação de política em um cliente gerado, o usuário pode registrar uma classe derivada e substituir CreateMessageInterceptor() para gerar sua classe habilitada InterceptingBindingElementImporter para ChannelMessageInterceptor política.

Exemplo: Inspetor de Mensagens Droppable

Incluído no exemplo está um exemplo de implementação de ChannelMessageInspector que descarta mensagens.

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

Você pode acessá-lo a partir da configuração da seguinte maneira:

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

O cliente e o servidor usam essa seção de configuração recém-criada para inserir as fábricas personalizadas no nível mais baixo de suas pilhas de canais de tempo de execução (acima do nível de transporte).

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

O cliente usa a MessageInterceptor biblioteca para adicionar um cabeçalho personalizado a mensagens com números pares. O serviço, por outro lado, usa MessageInterceptor a biblioteca para soltar quaisquer mensagens que não tenham esse cabeçalho especial.

Você deve ver a seguinte saída do cliente depois de executar o serviço e, em seguida, o cliente.

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

O cliente relata 10 velocidades de vento diferentes para o serviço, mas apenas marca metade delas com o cabeçalho especial.

No serviço, você deve ver a seguinte saída:

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.

Para configurar, compilar e executar o exemplo

Instale o ASP.NET 4.0 usando o seguinte comando.

%windir%\Microsoft.NET\Framework\v4.0.XXXXX\aspnet_regiis.exe /i /enable

Certifique-se de ter executado o procedimento de instalação única para os exemplos do Windows Communication Foundation.
Para criar a solução, siga as instruções em Criando os exemplos do Windows Communication Foundation.
Para executar o exemplo em uma configuração de máquina única ou cruzada, siga as instruções em Executando os exemplos do Windows Communication Foundation.
Execute Service.exe primeiro, em seguida, execute Client.exe e observe ambas as janelas do console para a saída.

Partilhar via