在WCF客户端代理替换未知DataContract的属性值

Question

可能重复：
WCF: Data contract being converted to message contract

我有一个通用的WCF代理，对于那些不熟悉，它是一类具有的方法与下面的OperationContract。

[OperationContract(Action = "*", ReplyAction = "*")] 
void Proxy(Message requestMessage); 

一个最近出现的要求，是我需要更换的消息，并且是类型的IPAddress的所有属性，那些提供的请求消息的ip地址值。

I.e.像，

public void Proxy(Message requestMessage) 
{ 
    try 
    { 
     // Client IP address, not currently used! 
     IPAddress clientIP = IPAddress.Parse((requestMessage 
      .Properties[RemoteEndpointMessageProperty.Name] 
      as RemoteEndpointMessageProperty).Address); 
     var factory = new ChannelFactory<IDmzProxy>("client"); 
     IDmzProxy dmzProxy = factory.CreateChannel(); 
     dmzProxy.Proxy(requestMessage); 
     factory.Close(); 
    } 

    // No leakage of data! Any exceptions still return void! 
    catch (Exception exception) 
    { 
     Log.Fatal(
      "Exception occurred on proxying the request", 
      exception); 
     return; 
    } 
} 

现在的问题是，如何在类ip地址的requestMessage设定的元素，我检索了clientIP？

编辑1件

事情我必须尝试和失败，

requestMessage.GetBodyAttribute("ipAddress", "http://schemas.datacontract.org/2004/07/System.Net") 

编辑2

一种方法似乎是更换消息体的XML。这对我来说似乎有点矫枉过正（那么WCF的重点是什么？）。

它也不是特别容易，因为MessageBody需要通过属性名称而不是元素名称来匹配元素。

<ipAddress xmlns:a="http://schemas.datacontract.org/2004/07/System.Net" xmlns:i="http://www.w3.org/2001/XMLSchema-instance"> 
    <a:m_Address>3772007081</a:m_Address> 
    <a:m_Family>InterNetwork</a:m_Family> 
    <a:m_HashCode>0</a:m_HashCode> 
    <a:m_Numbers xmlns:b="http://schemas.microsoft.com/2003/10/Serialization/Arrays"> 
     <b:unsignedShort>0</b:unsignedShort> 
     <b:unsignedShort>0</b:unsignedShort> 
     <b:unsignedShort>0</b:unsignedShort> 
     <b:unsignedShort>0</b:unsignedShort> 
     <b:unsignedShort>0</b:unsignedShort> 
     <b:unsignedShort>0</b:unsignedShort> 
     <b:unsignedShort>0</b:unsignedShort> 
     <b:unsignedShort>0</b:unsignedShort> 
    </a:m_Numbers> 
    <a:m_ScopeId>0</a:m_ScopeId> 
    </ipAddress> 

编辑3

当然不会重复，这里是东西是粗略的工作，需要一些工作仍然以取代我后的节点，

public void Proxy(Message requestMessage) 
    { 
     try 
     { 
      Log.Info("Received request"); 
      requestMessage = SourceNATMessage(requestMessage); 

      // Check if there is an accepted action we have to catch 
      // If the Accepted Action is set, and the action is not the same 
      // then just return);) 
      if (!String.IsNullOrEmpty(AcceptedAction) && 
       !requestMessage.Headers.Action.EndsWith(AcceptedAction)) 
      { 
       Log.WarnFormat(
        "Invalid request received with the following action {0}\n" + 
        "expected action ending with {1}", 
        requestMessage.Headers.Action, 
        AcceptedAction); 
       return; 
      } 

      // otherwise, let's proxy the request 
      Log.Debug("Proceeding with forwarding the request"); 
      var factory = new ChannelFactory<IDmzProxy>("client"); 
      IDmzProxy dmzProxy = factory.CreateChannel(); 
      dmzProxy.Proxy(requestMessage); 
      factory.Close(); 
     } 

     // No leakage of data! Any exceptions still return void! 
     catch (Exception exception) 
     { 
      Log.Fatal(
       "Exception occurred on proxying the request", 
       exception); 
      return; 
     } 
    } 

    private static Message SourceNATMessage(Message message) 
    { 
     IPAddress clientIp = 
       IPAddress.Parse(
        ((RemoteEndpointMessageProperty) 
        message.Properties[ 
         RemoteEndpointMessageProperty.Name]).Address); 

     Log.DebugFormat("Retrieved client IP address {0}", clientIp); 

     var stringBuilder = new StringBuilder(); 
     XDocument document; 

     using (XmlWriter writer = XmlWriter.Create(stringBuilder)) 
     { 
      message.WriteBody(writer); 
      writer.Flush(); 
      document = XDocument.Parse(stringBuilder.ToString()); 
     } 

     var deserializer = new DataContractSerializer(typeof(IPAddress)); 

     foreach (XElement element in 
      from element in document.DescendantNodes().OfType<XElement>() 
      let aNameSpace = element.GetNamespaceOfPrefix("a") 
      let iNameSpace = element.GetNamespaceOfPrefix("i") 
      where 
       aNameSpace != null && 
       aNameSpace.NamespaceName.Equals(SystemNetNameSpace) && 
       iNameSpace != null && 
       iNameSpace.NamespaceName.Equals(XmlSchemaNameSpace) && 
       deserializer.ReadObject(element.CreateReader(), false) is IPAddress 
      select element) 
     { 
      element.ReplaceWith(new XElement(element.Name, deserializer.WriteObject()); 
     } 

     return Message.CreateMessage(message.Version, 
            message.Headers.Action, 
            document.CreateReader()); 
    } 

编辑4

对于那些感兴趣的工作代码，不能作为问题发布答案重刑已关闭。

private static Message SourceNatMessage(Message message) 
{ 
    IPAddress clientIp = 
      IPAddress.Parse(
       ((RemoteEndpointMessageProperty) 
        message.Properties[ 
         RemoteEndpointMessageProperty.Name]).Address); 

    Log.DebugFormat("Retrieved client IP address {0}", clientIp); 

    var stringBuilder = new StringBuilder(); 
    XDocument document; 

    using (XmlWriter writer = XmlWriter.Create(stringBuilder)) 
    using (XmlDictionaryWriter dictionaryWriter = 
     XmlDictionaryWriter.CreateDictionaryWriter(writer)) 
    { 
     message.WriteBodyContents(dictionaryWriter); 
     dictionaryWriter.Flush(); 
     document = XDocument.Parse(stringBuilder.ToString()); 
    } 

    var deserializer = new DataContractSerializer(typeof(IPAddress)); 
    var clientIpXml = new StringBuilder(); 
    using (var xmlWriter = XmlWriter.Create(clientIpXml)) 
    { 
     deserializer.WriteObject(xmlWriter, clientIp); 
     xmlWriter.Flush(); 
    } 

    var clientElement = XElement.Parse(clientIpXml.ToString()); 

    foreach (XElement element in 
     from element in document.DescendantNodes().OfType<XElement>() 
     let aNameSpace = element.GetNamespaceOfPrefix("a") 
     let iNameSpace = element.GetNamespaceOfPrefix("i") 
     where 
      aNameSpace != null && 
      aNameSpace.NamespaceName.Equals(SystemNetNameSpace) && 
      iNameSpace != null && 
      iNameSpace.NamespaceName.Equals(XmlSchemaNameSpace) && 
      element.NodeType == XmlNodeType.Element 
     select element) 
    { 
     try 
     { 
      deserializer.ReadObject(element.CreateReader(), false); 
      element.ReplaceNodes(clientElement); 
     } 
     catch (SerializationException) { } 
    } 

    Message sourceNatMessage = Message.CreateMessage(message.Version, 
            null, 
            document.CreateReader()); 
    sourceNatMessage.Headers.CopyHeadersFrom(message); 
    sourceNatMessage.Properties.CopyProperties(message.Properties); 

    return sourceNatMessage; 
} 

Answer 1

只需使用自定义寻址标题注释SOAP消息即可。

Answer 2

在正常情况下，您不必这样做。您的留言已包含您正在查找的信息。

OperationContext context = OperationContext.Current; 
MessageProperties messageProperties = context.IncomingMessageProperties; 
RemoteEndpointMessageProperty endpointProperty = messageProperties[RemoteEndpointMessageProperty.Name] as RemoteEndpointMessageProperty; 

，其中客户端IP地址是在endpointProperty.Address财产的港口，是在endpointProperty.Port属性中找到。