wcf读取message内容

private string MessageToString(ref Message message) 
{ 
    WebContentFormat messageFormat = this.GetMessageContentFormat(message); 
    MemoryStream ms = new MemoryStream(); 
    XmlDictionaryWriter writer = null; 
    switch (messageFormat) 
    { 
        case WebContentFormat.Default: 
        case WebContentFormat.Xml: 
            writer = XmlDictionaryWriter.CreateTextWriter(ms); 
            break; 
        case WebContentFormat.Json: 
            writer = JsonReaderWriterFactory.CreateJsonWriter(ms); 
            break; 
        case WebContentFormat.Raw: 
            return this.ReadRawBody(ref message); 
    } 
  
    message.WriteMessage(writer); 
    writer.Flush(); 
    string messageBody = Encoding.UTF8.GetString(ms.ToArray()); 
  
    ms.Position = 0; 
    // 这里需要将message重新写入
    XmlDictionaryReader reader; 
    if (messageFormat == WebContentFormat.Json) 
    { 
        reader = JsonReaderWriterFactory.CreateJsonReader(ms, XmlDictionaryReaderQuotas.Max); 
    } 
    else 
    { 
        reader = XmlDictionaryReader.CreateTextReader(ms, XmlDictionaryReaderQuotas.Max); 
    } 
  
    Message newMessage = Message.CreateMessage(reader, int.MaxValue, message.Version); 
    newMessage.Properties.CopyProperties(message.Properties); 
    message = newMessage; 
  
    return messageBody; 
}

   private WebContentFormat GetMessageContentFormat(Message message) 
{ 
    WebContentFormat format = WebContentFormat.Default; 
    if (message.Properties.ContainsKey(WebBodyFormatMessageProperty.Name)) 
    { 
        WebBodyFormatMessageProperty bodyFormat; 
        bodyFormat = (WebBodyFormatMessageProperty)message.Properties[WebBodyFormatMessageProperty.Name]; 
        format = bodyFormat.Format; 
    } 
  
    return format; 
}

   private string ReadRawBody(ref Message message) 
{ 
    XmlDictionaryReader bodyReader = message.GetReaderAtBodyContents(); 
    bodyReader.ReadStartElement("Binary"); 
    byte[] bodyBytes = bodyReader.ReadContentAsBase64(); 
    string messageBody = Encoding.UTF8.GetString(bodyBytes); 
  
    // Now to recreate the message 
    MemoryStream ms = new MemoryStream(); 
    XmlDictionaryWriter writer = XmlDictionaryWriter.CreateBinaryWriter(ms); 
    writer.WriteStartElement("Binary"); 
    writer.WriteBase64(bodyBytes, 0, bodyBytes.Length); 
    writer.WriteEndElement(); 
    writer.Flush(); 
    ms.Position = 0; 
    XmlDictionaryReader reader = XmlDictionaryReader.CreateBinaryReader(ms, XmlDictionaryReaderQuotas.Max); 
    Message newMessage = Message.CreateMessage(reader, int.MaxValue, message.Version); 
    newMessage.Properties.CopyProperties(message.Properties); 
    message = newMessage; 
  
    return messageBody; 
}