WCF 提供了很多可扩展点,其中之一是名为 MessageInspector 的功能。您可以创建自定义消息检查器以在将请求反序列化为 C# 对象之前接收请求。并使用原始请求数据尽你所能。
为了实现它,您需要实现System.ServiceModel.Dispatcher.IDispatchMessageInspector 接口,如下所示:
public class IncomingMessageLogger : IDispatchMessageInspector
{
const string MessageLogFolder = @"c:\temp\";
static int messageLogFileIndex = 0;
public object AfterReceiveRequest(ref Message request, IClientChannel channel, InstanceContext instanceContext)
{
string messageFileName = string.Format("{0}Log{1:000}_Incoming.txt", MessageLogFolder, Interlocked.Increment(ref messageLogFileIndex));
Uri requestUri = request.Headers.To;
HttpRequestMessageProperty httpReq = (HttpRequestMessageProperty)request.Properties[HttpRequestMessageProperty.Name];
// Decode the message from request and do whatever you want to do.
string jsonMessage = this.MessageToString(ref request);
return requestUri;
}
public void BeforeSendReply(ref Message reply, object correlationState)
{
}
}
这是完整的code snippet gist。 Actual source.
现在您需要将此消息检查器添加到端点行为。要实现这一点,您将实现System.ServiceModel.Description.IEndpointBehavior 接口,如下所示:
public class InsepctMessageBehavior : IEndpointBehavior
{
public void AddBindingParameters(ServiceEndpoint endpoint, BindingParameterCollection bindingParameters)
{
}
public void ApplyClientBehavior(ServiceEndpoint endpoint, ClientRuntime clientRuntime)
{
}
public void ApplyDispatchBehavior(ServiceEndpoint endpoint, EndpointDispatcher endpointDispatcher)
{
endpointDispatcher.DispatchRuntime.MessageInspectors.Add(new IncomingMessageLogger());
}
public void Validate(ServiceEndpoint endpoint)
{
}
}
现在,如果您使用自托管,即以编程方式托管您的服务,您可以直接将此新实现的行为附加到您的服务端点。例如
endpoint.Behaviors.Add(new IncomingMessageLogger());
但是,如果您在 IIS 中托管了 WCF Rest 服务,那么您将通过配置注入新的行为。为了实现这一点,您必须创建一个从BehaviorExtensionElement 派生的附加类:
public class InspectMessageBehaviorExtension : BehaviorExtensionElement
{
public override Type BehaviorType
{
get { return typeof(InsepctMessageBehavior); }
}
protected override object CreateBehavior()
{
return new InsepctMessageBehavior();
}
}
现在在你的配置中首先注册system.servicemodel标签下的行为:
<extensions>
<behaviorExtensions>
<add name="inspectMessageBehavior"
type="WcfRestAuthentication.MessageInspector.InspectMessageBehaviorExtension, WcfRestAuthentication"/>
</behaviorExtensions>
</extensions>
现在将此行为添加到端点行为中:
<endpointBehaviors>
<behavior name="defaultWebHttpBehavior">
<inspectMessageBehavior/>
<webHttp defaultOutgoingResponseFormat="Json"/>
</behavior>
</endpointBehaviors>
在您的端点中设置属性behaviorConfiguration="defaultWebHttpBehavior"。
就是这样,您的服务现在将在反序列化之前捕获所有消息。