17

我有一个带有多种方法的 WCF 服务。我想记录来自客户端的原始请求，无论它是如何发送的。一种方法接受数据作为查询字符串（严格用于遗留支持），我可以使用以下方式记录：

OperationContext.Current.IncomingMessageHeaders.To.AbsoluteUri

在这种情况下就足够了，但其他方法允许客户端使用由 svcutil.exe 生成的代理类将数据作为 XML 发送。在这种情况下，我在 s:Body 中找到了我想要的数据：

OperationContext.Current.RequestContext.RequestMessage

不幸的是，无论我尝试什么，我都无法在读取之前创建消息的缓冲副本。这是一个例子：

public CascadeResponse SendCustomer(Customer c)
    {
        Message msg = OperationContext.Current.RequestContext.RequestMessage.CreateBufferedCopy(Int32.MaxValue).CreateMessage();
        LogMessage(msg);
        // Now that the request is logged, get on with the rest
    }

但是，在 SendCustomer 的第一行，我收到以下错误：

此消息无法支持该操作，因为它已被读取。

这就是我创建缓冲副本的目的，确定吗？我猜我在这里做错了。

编辑：

好的，所以方法现在是这样的：

public CascadeResponse SendCustomer(Message requestMessage)
    {
        Message msg = OperationContext.Current.RequestContext.RequestMessage.CreateBufferedCopy(Int32.MaxValue).CreateMessage();
        LogMessage(msg);
        // Now that the request is logged, get on with the rest        
        Customer c = msg.GetBody<Customer>();
        string clientKey = "1111"; // This should be the clientKey string passed to the function along with the customer 
        return SendLead(c, clientKey);
    }

我的问题是我不知道如何将 Customer 和 ClientKey 作为单独的实体发送。我可以使 clientKey 成为 Customer 的属性（或创建一个专门用于传入数据并包含 Customer 和 ClientKey 作为属性的自定义对象），但如果可能的话，我想避免这种情况，因为这是对遗留系统的升级已经这样工作了。

我也无法使用 svcUtil.exe 创建我的代理类 - 我假设具有上述方法签名意味着我的服务将不再宣传正确的签名来发送请求？不确定这是否足够清楚 - 如果我唯一的输入法接受 Message 对象，我的客户怎么知道要发送 Customer 和 ClientKey？

4

4 回答 4

25

我找到了一个其他人可能也会觉得有用的解决方案。创建 MessageInspector 允许您将代码附加到“AfterReceiveRequest”和“BeforeSendReply”事件，如下所示：

public class MessageInspector : IDispatchMessageInspector
{
    public object AfterReceiveRequest(ref Message request, IClientChannel channel, InstanceContext instanceContext)
    {
        MessageBuffer buffer = request.CreateBufferedCopy(Int32.MaxValue);
        request = buffer.CreateMessage();
        LogMessage("Received:\n{0}", buffer.CreateMessage().ToString());
        return null;
    }

    public void BeforeSendReply(ref Message reply, object correlationState)
    {
        MessageBuffer buffer = reply.CreateBufferedCopy(Int32.MaxValue);
        reply = buffer.CreateMessage();
        LogMessage("Sending:\n{0}", buffer.CreateMessage().ToString());
    }
}

这里有设置 wcf 消息检查器的完整教程。我会说，当您将行为扩展添加到 app.config/web.config 时，请小心检查您的完全限定程序集名称。

希望其他人觉得这很有用。

于 2012-04-23T16:11:12.717 回答
3

为了实现上述目标，您需要将方法更改为如下所示：

public CascadeResponse SendCustomer(Message requestMessage)
    {
        Message msg = OperationContext.Current.RequestContext.RequestMessage.CreateBufferedCopy(Int32.MaxValue).CreateMessage();
        LogMessage(msg);
        // Now that the request is logged, get on with the rest        
        Customer c = msg.GetBody<Customer>();
    }

有关使用消息类的更多信息

于 2012-04-20T15:36:03.457 回答
3

我认为您可以使用 ...ToString()方法，它会在内部重写消息：

string soap = OperationContext.Current.RequestContext.RequestMessage.ToString();

查看ToString()方法内部... ;)

于 2013-11-15T20:30:14.447 回答
0

在 VS2015 上一个 WCF 服务项目，你可以右键单击 web.config 来编辑 WCF 配置。从这里您可以启用诊断以记录原始消息。

于 2016-05-17T14:48:38.323 回答