WCF + REST：请求数据在哪里？

Question

我目前正在开发 WCF RESTful 服务。在 POST 数据的验证中，如果请求 XML 不符合我们的业务规则，我将抛出异常。

目标是如果收到的请求被视为无效，则向相应的工作人员发送电子邮件。但是，除了传入的请求标头、方法和 URI 之外，我还想发送已发布的 XML。

我一直无法找到访问这些数据的方法。在我有机会访问请求正文/数据之前，WCF 实际上是否已销毁它，或者我是否丢失了某些内容？

感谢您的帮助，因为我对为什么无法访问请求数据感到困惑。

Answer 1

下面介绍了如何在不进行反射的情况下执行此操作：

using (var reader = OperationContext.Current.RequestContext.RequestMessage.GetReaderAtBodyContents ()) {
    if (reader.Read ())
        return new string (Encoding.ASCII.GetChars (reader.ReadContentAsBase64 ()));
                return result;
    }
}

如果读取器是 HttpStreamXmlDictionaryReader（就像我的情况一样），则类的方法 ReadContentAsBase64(byte[] buffer, int index, int count) 只需将这些参数传递给 Stream.Read 方法即可。

一旦我有了 byte[]，我就会通过 ASCII 编码将字节转换为字符串。为了正确实施，您可以使用内容类型和内容类型。根据 HTTP 规范对消息标头进行编码。

Answer 2

您可以在 WCF 服务的自定义 HttpModule 中捕获 HttpApplication.Request.InputStrea，读取流并再次在自定义 HttpModule 的事件处理程序中将其位置设置为 0。然后将其存储在会话中并在实际的OperationContract中进一步访问它。

例如：

public class CustomModule : IHttpModule
{
    public void Dispose()
    {

    }

    public void Init(HttpApplication context)
    {
        context.AcquireRequestState +=context_AcquireRequestState;
    }

    void context_AcquireRequestState(object sender, EventArgs e)
    {
        HttpApplication application = sender as HttpApplication;
        Stream str = application.Request.InputStream;
        StreamReader sr = new StreamReader(str);
        string req = sr.ReadToEnd();
        str.Position = 0;
        application.Session["CurrentRequest"] = req;
    }
 }

Answer 3

不幸的是，这不受支持——我们有类似的需求，并通过反思调用内部成员来做到这一点。我们只是在错误处理程序中使用它（这样我们就可以转储原始请求），但它工作正常。我不会推荐它用于您不拥有和操作的系统（例如，不要将此代码发送给客户），因为它可以随时通过服务包或其他方式进行更改。

public static string GetRequestBody()
{
    OperationContext oc = OperationContext.Current;

    if (oc == null)
        throw new Exception("No ambient OperationContext.");

    MessageEncoder encoder = oc.IncomingMessageProperties.Encoder;
    string contentType = encoder.ContentType;
    Match match = re.Match(contentType);

    if (!match.Success)
        throw new Exception("Failed to extract character set from request content type: " + contentType);

    string characterSet = match.Groups[1].Value;

    object bufferedMessage = operationContextType.InvokeMember("request",
        BindingFlags.Instance | BindingFlags.NonPublic | BindingFlags.GetField,
        null, oc, null);

    //TypeUtility.AssertType(bufferedMessageType, bufferedMessage);

    object messageData = bufferedMessageType.InvokeMember("MessageData",
        BindingFlags.Instance | BindingFlags.NonPublic | BindingFlags.GetProperty,
        null, bufferedMessage, null);

    //TypeUtility.AssertType(jsonBufferedMessageDataType, messageData);

    object buffer = jsonBufferedMessageDataType.InvokeMember("Buffer",
        BindingFlags.Instance | BindingFlags.Public | BindingFlags.GetProperty,
        null, messageData, null);

    ArraySegment<byte> arrayBuffer = (ArraySegment<byte>)buffer;

    Encoding encoding = Encoding.GetEncoding(characterSet);

    string requestMessage = encoding.GetString(arrayBuffer.Array, arrayBuffer.Offset, arrayBuffer.Count);

    return requestMessage;
}

Answer 4

因此，如果您声明的合同类似于：（

[WebInvoke(Method = "POST", UriTemplate = "create", ResponseFormat=WebMessageFormat.Json)]
 int CreateItem(Stream streamOfData);

您可以使用 XML 代替）
StreamOfData 应该是 HTTP POST 的主体。您可以使用类似的方法反序列化它：

 StreamReader reader = new StreamReader(streamId);
 String res = reader.ReadToEnd();
 NameValueCollection coll = HttpUtility.ParseQueryString(res);

至少对我们来说它是这样工作的。您可能想要使用不同的方法将字符串放入 XMLDocument 或其他内容中。这适用于我们的 JSON 帖子。可能不是最优雅的解决方案，但它确实有效。

我希望这有帮助。

格伦

Answer 5

试试这个，

OperationContext.Current.RequestContext.RequestMessage