我可以分别使用 IClientMessageInspector、IDispatchMessageInspector 在客户端和服务器端检查 WCF 消息。但是在双工通信中,不清楚如何在从服务器到客户端的回调中做到这一点(关于该主题的文档也很少)。
关于如何实现此功能的任何想法?
我可以分别使用 IClientMessageInspector、IDispatchMessageInspector 在客户端和服务器端检查 WCF 消息。但是在双工通信中,不清楚如何在从服务器到客户端的回调中做到这一点(关于该主题的文档也很少)。
关于如何实现此功能的任何想法?
最后我得到了解决方案。
在进行回调的双工通信场景中,服务器成为客户端,反之亦然。
因此,在服务器端实现 IServiceBehavior 时,使用每个 EndpointDispatcher 的 DispatchRuntime 的 CallbackClientRuntime 属性注入消息检查器。
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>