在WCF回调方向检查消息?

8
我可以使用IClientMessageInspector和IDispatchMessageInspector在客户端和服务器端检查WCF消息。但是在双工通信中,不清楚如何在服务器到客户端回调中执行此操作(也没有太多有关该主题的文档)。
有关如何实现此功能的任何想法?

我也遇到了同样的问题。 - Anuraj
1个回答

7

我终于找到了解决方法。

在双工通信场景中,当回调被触发时,服务器会变成客户端,反之亦然。

因此,在服务器端实现IServiceBehavior时,使用DispatchRuntime的CallbackClientRuntime属性向每个EndpointDispatcher注入消息检查器。

public void ApplyDispatchBehavior(ServiceDescription serviceDescription, System.ServiceModel.ServiceHostBase serviceHostBase)
{
    foreach (ChannelDispatcher item in serviceHostBase.ChannelDispatchers)
    {
        foreach (EndpointDispatcher epd in item.Endpoints)
        {
            //injecting an inspector in normal call
            epd.DispatchRuntime.MessageInspectors.Add(new MessageSizerInspector());

            //injecting an inspector in callback
            epd.DispatchRuntime.CallbackClientRuntime.MessageInspectors.Add(new MessageSizerInspector());
        }
    }
}

在客户端实现 IEndpointBehavior 时,可以使用 CallbackDispatchRuntime 注入消息检查器。
public void ApplyClientBehavior(ServiceEndpoint endpoint, System.ServiceModel.Dispatcher.ClientRuntime clientRuntime)
{
    //injecting an inspector in normal call
    clientRuntime.MessageInspectors.Add(new MessageSizerInspector());

    //injecting an inspector in callback
    clientRuntime.CallbackDispatchRuntime.MessageInspectors.Add(new MessageSizerInspector());       
}

然后像往常一样应用扩展程序。

在我的情况下,我创建了一个类,类似于以下伪代码:

public class MessageSizer : Attribute, IServiceBehavior, IEndpointBehavior
{
    .....
}

然后我将这个属性应用于服务器端检查的服务实现,并在app.config中添加了一个behaviorExtensions来设置客户端消息检查的端点。

<system.serviceModel>
    ...........
    <client>
      <endpoint address="net.tcp://localhost/MinerDual.svc"
            binding="netTcpBinding" bindingConfiguration="wsDualMinerNetTcp"
            contract="WebApplication.IMinerDual" name="NetTcpMinerDual" 
            behaviorConfiguration="Default" />
    </client>
  <behaviors>
    <endpointBehaviors >
      <behavior name="Default">
        <messageSizer/>
      </behavior>
    </endpointBehaviors>
  </behaviors>
  <extensions>
    <behaviorExtensions>
      <add name="messageSizer"
           type="WCFExtensions.MessageSizerElement, WCFExtensions, 
           Version=1.0.0.0, Culture=neutral, PublicKeyToken=null"/>
    </behaviorExtensions>
  </extensions>
</system.serviceModel>

网页内容由stack overflow 提供, 点击上面的
可以查看英文原文,
原文链接