如何使用OperationContract反序列化WCF消息

Question

我成功地构建了由 svcutil.exe 从 WSDL 生成的 WCF 客户端。使用生成的客户端代理类，我可以调用外部服务提供商的 Web 服务。我还成功地编写了一个消息检查器，因为我需要将原始 XML 请求和响应作为完整的 SOAP 消息记录到数据库中。

对于紧急情况，我还需要能够“导入”原始 XML 响应。我发现了许多关于使用 XMLSerializer 或基于消息协定反序列化 WCF 消息的提示。

但是如何根据操作契约反序列化原始 XML 响应呢？对于第一个测试，我使用记录的原始响应之一，将其保存到文件中，然后尝试将其反序列化为客户端代理中生成的响应类型。无论如何，我必须成功地从类 ClientOperation 调用 DeserializeReply()。但如何到达那里呢？

我很乐意接受任何帮助，因为我对 WCF 还很陌生...... TIA， 斯特凡

这是我在马克回答后尝试的：

  public static RatingResult DeserializeResponseFromFile(string path)
  {
     var xmlReader = XmlReader.Create(path);
     var message = Message.CreateMessage(xmlReader, int.MaxValue, MessageVersion.Soap11);
     var readerAtBodyContents = message.GetReaderAtBodyContents();
     var dcs = new DataContractSerializer(typeof(RatingResult), "RatingResponse", "http://rating.webservice.xxx.de");

     // Error in line 6 position 7. 'EndElement' 'RatingResponse' from namespace
     // 'http://rating.webservice.xxx.de' is not expected.
     // Expecting element 'commonDataField'.
     var wsResult = (RatingResult)dcs.ReadObject(readerAtBodyContents);

     return wsResult;
  }

这是记录的 XML 响应文件的一部分，我试图将其反序列化为 RatingResponse 类型：

<soapenv:Envelope xmlns:soapenv="..." xmlns:soapenc="..." xmlns:xsd="..." xmlns:xsi="...">
  <soapenv:Header soapenv:encodingStyle="..." />
  <soapenv:Body soapenv:encodingStyle="...">
    <p933:RatingResponse xmlns:p933="http://rating.webservice.xxx.de">
      <RatingReturn href="#id0" />
    </p933:RatingResponse>
    <multiRef id="id0" soapenc:root="0" soapenv:encodingStyle="..." xsi:type="p878:RatingResult" xmlns:p878="http://output.rating.webservice.xxx.de">
      <commonData href="#id1" />
      <acctData href="#id2" />
      <resultData href="#id3" />
    </multiRef>
    <multiRef id="id1" soapenc:root="0" soapenv:encodingStyle="..." xsi:type="p719:RatingCommonData" xmlns:p719="http://input.rating.webservice.xxx.de">
      <requestdate xsi:type="xsd:dateTime">2010-12-24T09:45:09.531Z</requestdate>
      ...

我猜测数据协定序列化程序在反序列化 href 时遇到问题。请注意，我尝试“手动”反序列化的消息是使用我注入的消息检查器捕获的。在 Web 服务的“正常”调用中，该消息可以毫无问题地反序列化。

Answer 1

我不太明白你想问什么、想做什么......基于运营合同？ 操作契约只是您在操作/方法调用上放置的一个属性，用于将其标记为服务方法......操作契约不执行任何远程涉及序列化或反序列化的操作。 ...您的意思是如何使用 WCF 默认序列化程序 DataContractSerializer 反序列化 XML 消息？

假设您确实想了解HOWTO：使用 DataContractSerializer 反序列化 WCF 消息，那么请尝试以下操作：如果您有来自使用默认 WCF DataContractSerializer 的服务调用的响应 XML，您应该能够像这样反序列化它（假设您的 XML 序列化响应位于 xmlResponse 变量中）：

using(MemoryStream memStm = new MemoryStream())
using(StreamWriter stw = new StreamWriter(memStm))
{
   // write your response to the memory stream
   stw.Write(xmlResponse);
   stw.Flush();

   // "reset" memory stream
   memStm.Seek(0, SeekOrigin.Begin);

   // setup DataContractSerializer     
   DataContractSerializer dcs = new DataContractSerializer(typeof(YourDataType));

   // deserialize result XML into an instance of "YourDataType"
   var result = dcs.ReadObject(memStm);
}

Answer 2

对于将来这样做的任何人。我必须手动从 MSMSQ 中读取 WCF 消息，并从 MSMQ/WCF 消息信封中获取请求对象。操作方法如下：

根代码：

var q = new MessageQueue(@".\Private$\VishalQ;poison");

var allMessages = q.GetAllMessages().ToList();
var wcfRequests = allMessages.Select(ConvertToWcfRequest<ObjectChangedRequest>);

我的合同：

[ServiceContract]
public interface IWish
{
    [OperationContract(IsOneWay = true)]
    void ObjectChanged(ObjectChangedRequest request);
}

我的数据合同：

[DataContract(Namespace = "http://x.namespaces.x-x.com/")]
public class ObjectChangedRequest
{
    [DataMember]
    public OperationType OperationType { get; set; }
}

我的消息反序列化代码：

    /// <summary>
    /// Converts a WCF MSMQ message to a WCF request object.
    /// </summary>
    public static T ConvertToWcfRequest<T>(Message msmqMessage)
    {
        var buffer = new byte[msmqMessage.BodyStream.Length];
        msmqMessage.BodyStream.Read(buffer, 0, (int)msmqMessage.BodyStream.Length);

        var envelopeStart = FindEnvelopeStart(buffer);

        using var msmqStream = new MemoryStream(buffer, envelopeStart, buffer.Length - envelopeStart);
        var encodingElement  = new BinaryMessageEncodingBindingElement();
        var wcfMessage       = encodingElement.CreateMessageEncoderFactory().Encoder.ReadMessage(msmqStream, int.MaxValue);
        var document         = new XmlDocument();

        document.Load(wcfMessage.GetReaderAtBodyContents());

        var realRoot        = document.FirstChild.FirstChild;
        using var wcfStream = new MemoryStream();
        using var xmlWriter = XmlWriter.Create(wcfStream);

        realRoot.WriteTo(xmlWriter);
        xmlWriter.Flush();
        wcfStream.Seek(0, SeekOrigin.Begin);

        var wcfSerializer = new DataContractSerializer(typeof(T), realRoot.Name, "http://tempuri.org/"); //No idea why this has to be temp uri and not our namespace...

        return (T)wcfSerializer.ReadObject(wcfStream);
    }

    /// <summary>
    /// Locates the start of a WCF message within a MSMQ message.
    /// </summary>
    private static int FindEnvelopeStart(byte[] stream)
    {
        var position = 0;
        var previousByte = stream[position];

        for (position = 0; position < stream.Length; position++)
        {
            var currentByte = stream[position];

            //Some magic numbers that define the start of the WCF message envelope
            if (currentByte == 0x02 && previousByte == 0x56)
                break;

            previousByte = currentByte;
        }

        return position - 1;
    }