8

我在我的应用程序中实现了一个IClientMessageInspector“拦截”传出 Web 服务调用。BeforeSendRequest是否可以从and内部找出正在调用哪个操作AfterReceiveReply？

这里有一个类似的问题，How do i get the invoked operation name within a WCF Message Inspector，这是针对服务器端（接收请求的一方）的。我试图做类似的事情，例如

    public object BeforeSendRequest(ref Message request, IClientChannel channel)
    {
        var v = OperationContext.Current.OutgoingMessageProperties["HttpOperationName"];
        return null;
    }

    public void AfterReceiveReply(ref Message reply, object correlationState)
    {
        var v = OperationContext.Current.OutgoingMessageProperties["HttpOperationName"];
    }

但是在传出请求期间，似乎 OperationContext.Current 为空，所以我不能使用它。知道如何得到它吗？知道如何干净地做到这一点（相反，比如解析 SOAP xml）？

4

2 回答 2

5

从您询问如何使用IParameterInspector完成此操作的评论中。操作名称是 Before/AfterCall 方法的一部分。

只是为了添加我对使用哪个检查员的评论。来自Carlos Figueira 的博客：

本系列上一篇文章中描述的消息检查器允许您完全控制通过 WCF 堆栈的消息。它们非常强大，但是您必须知道如何处理 Message 对象，这不是最理想的编程方式。如果 WCF 中的服务模型通过允许我们根据强类型操作定义我们的服务（即使用良好的原始类型和用户定义的类型）来隐藏所有消息传递框架，那么应该有一种拦截请求/响应的方法毕竟从传入消息中提取这些参数（或在将它们打包到传出消息中之前）的处理已完成。IParameterInspector 就是这样——在每次调用之前和之后，检查器都有机会检查操作输入、输出和返回值，

这是一个完整的命令行程序，演示：

using System;
using System.ServiceModel;
using System.ServiceModel.Channels;
using System.ServiceModel.Description;
using System.ServiceModel.Dispatcher;

namespace WCFClientInspector
{
    public class OperationLogger : IParameterInspector
    {
        public void AfterCall(string operationName, object[] outputs, object returnValue, object correlationState)
        {
            Console.WriteLine("Completed operation:" + operationName);
        }

        public object BeforeCall(string operationName, object[] inputs)
        {
            Console.WriteLine("Calling operation:" + operationName);
            return null;
        }
    }

    public class OperationLoggerEndpointBehavior : IEndpointBehavior
    {
        public void AddBindingParameters(ServiceEndpoint endpoint, BindingParameterCollection bindingParameters)
        {
        }

        public void ApplyClientBehavior(ServiceEndpoint endpoint, ClientRuntime clientRuntime)
        {
            foreach (ClientOperation operation in clientRuntime.ClientOperations)
            {
                operation.ClientParameterInspectors.Add(new OperationLogger());
            }
        }

        public void ApplyDispatchBehavior(ServiceEndpoint endpoint, EndpointDispatcher endpointDispatcher)
        {
        }

        public void Validate(ServiceEndpoint endpoint)
        {
        }
    }


    [ServiceContract]
    public interface ISimple
    {
        [OperationContract]
        void DoSomthing(string s);
    }

    public class SimpleService : ISimple
    {
        public void DoSomthing(string s)
        {
            Console.WriteLine("Called:" + s);
        }
    }

    public static class AttributesAndContext
    {
        static void Main(string[] args)
        {
            ServiceHost simpleHost = new ServiceHost(typeof(SimpleService), new Uri("http://localhost/Simple"));
            simpleHost.Open();

            ChannelFactory<ISimple> factory = new ChannelFactory<ISimple>(simpleHost.Description.Endpoints[0]);
            factory.Endpoint.EndpointBehaviors.Add(new OperationLoggerEndpointBehavior());
            ISimple proxy = factory.CreateChannel();

            proxy.DoSomthing("hi");

            Console.WriteLine("Press ENTER to close the host.");
            Console.ReadLine();

            ((ICommunicationObject)proxy).Shutdown();

            simpleHost.Shutdown();
        }
    }

    public static class Extensions
    {
        static public void Shutdown(this ICommunicationObject obj)
        {
            try
            {
                obj.Close();
            }
            catch (Exception ex)
            {
                Console.WriteLine("Shutdown exception: {0}", ex.Message);
                obj.Abort();
            }
        }
    }
}

它应该给出输出：

  Calling operation:DoSomthing 
  Called:hi 
  Completed operation:DoSomthing
  Press ENTER to close the host.
于 2013-04-16T20:15:30.523 回答
3

reply.Headers.Action和怎么样request.Headers.Action。当然，其余的与所链接的问题一样棘手。所以完整的代码将是：

var action = reply.Headers.Action.Substring(reply.Headers.Action.LastIndexOf("/", StringComparison.OrdinalIgnoreCase) + 1);

或者

var action = request.Headers.Action.Substring(request.Headers.Action.LastIndexOf("/", StringComparison.OrdinalIgnoreCase) + 1);
于 2013-04-16T06:33:11.080 回答