WCF-消息拦截 也可错误拦截

WCF-消息拦截 也可异常拦截

?

说明：命名空间为：WcfServiceInterpector

1：新建继承自IDispatchMessageInspector的ServiceInterpector类

?

1 public class ServiceInterpector : IDispatchMessageInspector 2     { 3  4         #region IDispatchMessageInspector 成员 5  6         public object AfterReceiveRequest(ref System.ServiceModel.Channels.Message request, System.ServiceModel.IClientChannel channel, System.ServiceModel.InstanceContext instanceContext) 7         { 8             ICSS.Plover.Log.LogRecorder.WriteInfo(new LogMessage("请求服务地址:" + request.Headers.To.AbsoluteUri + " 调用方法地址:" + request.Headers.Action)); 9             return "success";10         }11 12         public void BeforeSendReply(ref System.ServiceModel.Channels.Message reply, object correlationState)13         {14 15         }16 17         #endregion18     }

?

2：新建继承自BehaviorExtensionElement, IServiceBehavior的MyServiceBehavior类

1 public class MyServiceBehavior : BehaviorExtensionElement, IServiceBehavior 2     { 3  4         public override Type BehaviorType 5         { 6             get { return typeof(MyServiceBehavior); } 7         } 8         protected override object CreateBehavior() 9         {10             return new MyServiceBehavior();11         }12         #region IServiceBehavior Members13         public void AddBindingParameters(ServiceDescription serviceDescription, System.ServiceModel.ServiceHostBase serviceHostBase, System.Collections.ObjectModel.Collection<ServiceEndpoint> endpoints, System.ServiceModel.Channels.BindingParameterCollection bindingParameters)14         {15         }16         public void ApplyDispatchBehavior(ServiceDescription serviceDescription, System.ServiceModel.ServiceHostBase serviceHostBase)17         {18             foreach (ChannelDispatcher chDisp in serviceHostBase.ChannelDispatchers)19             {20                 foreach (EndpointDispatcher epDisp in chDisp.Endpoints)21                 {22                     epDisp.DispatchRuntime.MessageInspectors.Add(new ServiceInterpector());23                 }24             }25         }26         public void Validate(ServiceDescription serviceDescription, System.ServiceModel.ServiceHostBase serviceHostBase)27         {28         }29         #endregion30 31     }

?3：配置文件中添加配置

(1)添加扩展  <system.serviceModel><extensions>       <behaviorExtensions>      <add name="Test" type="WcfServiceInterpector.MyServiceBehavior, WcfServiceInterpector, Version=1.0.0.0, Culture=neutral,              PublicKeyToken=null" />        </behaviorExtensions>   </extensions>  </system.serviceModel>说明：type="类完整名称, (程序集名称), Version=1.0.0.0, Culture=neutral,  PublicKeyToken=null" />（2）使用扩展<serviceBehaviors>       <behavior name="DefaultBehavior">         <serviceMetadata httpGetEnabled="true" httpGetUrl="" />         <serviceDebug includeExceptionDetailInFaults="true" />         <serviceThrottling maxConcurrentCalls="200" maxConcurrentInstances="200" maxConcurrentSessions="200" />                <dataContractSerializer maxItemsInObjectGraph="2147483647" />         <Test/>      <!--上文中扩展定义的名称-->     </behavior>       </serviceBehaviors>

?

?