wcf读取message内容

 1 private string MessageToString(ref Message message)  2 {  3   WebContentFormat messageFormat = this.GetMessageContentFormat(message);  4   MemoryStream ms = new MemoryStream();  5   null;  6   switch (messageFormat)  7   {  8     case WebContentFormat.Default:  9     case WebContentFormat.10       writer = 11       break; 12     case WebContentFormat.Json: 13       writer = JsonReaderWriterFactory.CreateJsonWriter(ms); 14       break; 15     case WebContentFormat.Raw: 16       return this.ReadRawBody(ref message); 17   } 18  19   message.WriteMessage(writer); 20   writer.Flush(); 21   string messageBody = Encoding.UTF8.GetString(ms.ToArray()); 22  23   ms.Position = 0; 24   // 这里需要将message重新写入25   26   if (messageFormat == WebContentFormat.Json) 27   { 28     reader = JsonReaderWriterFactory.CreateJsonReader(ms, 29   } 30   else 31   { 32     reader = 33   } 34  35   Message newMessage = Message.CreateMessage(reader, int.MaxValue, message.Version); 36   newMessage.Properties.CopyProperties(message.Properties); 37   message = newMessage; 38  39   return messageBody; 40 }41 42  private WebContentFormat GetMessageContentFormat(Message message) 43 { 44   WebContentFormat format = WebContentFormat.Default; 45   if (message.Properties.ContainsKey(WebBodyFormatMessageProperty.Name)) 46   { 47     WebBodyFormatMessageProperty bodyFormat; 48     bodyFormat = (WebBodyFormatMessageProperty)message.Properties[WebBodyFormatMessageProperty.Name]; 49     format = bodyFormat.Format; 50   } 51  52   return format; 53 }54 55  private string ReadRawBody(ref Message message) 56 { 57    message.GetReaderAtBodyContents(); 58   bodyReader.ReadStartElement("Binary"); 59   byte[] bodyBytes = bodyReader.ReadContentAsBase64(); 60   string messageBody = Encoding.UTF8.GetString(bodyBytes); 61  62   // Now to recreate the message 63   MemoryStream ms = new MemoryStream(); 64    65   writer.WriteStartElement("Binary"); 66   writer.WriteBase64(bodyBytes, 0, bodyBytes.Length); 67   writer.WriteEndElement(); 68   writer.Flush(); 69   ms.Position = 0; 70    71   Message newMessage = Message.CreateMessage(reader, int.MaxValue, message.Version); 72   newMessage.Properties.CopyProperties(message.Properties); 73   message = newMessage; 74  75   return messageBody; 76 }

原标题：wcf读取message内容

关键词：wcf