wcf读取message内容

 1 private string MessageToString(ref Message message)
 2 {
 3     WebContentFormat messageFormat = this.GetMessageContentFormat(message);
 4     MemoryStream ms = new MemoryStream();
 5     XmlDictionaryWriter writer = null;
 6     switch (messageFormat)
 7     {
 8         case WebContentFormat.Default:
 9         case WebContentFormat.Xml:
10             writer = XmlDictionaryWriter.CreateTextWriter(ms);
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     XmlDictionaryReader reader;
26     if (messageFormat == WebContentFormat.Json)
27     {
28         reader = JsonReaderWriterFactory.CreateJsonReader(ms, XmlDictionaryReaderQuotas.Max);
29     }
30     else
31     {
32         reader = XmlDictionaryReader.CreateTextReader(ms, XmlDictionaryReaderQuotas.Max);
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     XmlDictionaryReader bodyReader = 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     XmlDictionaryWriter writer = XmlDictionaryWriter.CreateBinaryWriter(ms);
65     writer.WriteStartElement("Binary");
66     writer.WriteBase64(bodyBytes, 0, bodyBytes.Length);
67     writer.WriteEndElement();
68     writer.Flush();
69     ms.Position = 0;
70     XmlDictionaryReader reader = XmlDictionaryReader.CreateBinaryReader(ms, XmlDictionaryReaderQuotas.Max);
71     Message newMessage = Message.CreateMessage(reader, int.MaxValue, message.Version);
72     newMessage.Properties.CopyProperties(message.Properties);
73     message = newMessage;
74
75     return messageBody;
76 }