使用 Message 类

Message 类是 Windows Communication Foundation (WCF) 的基础。 客户端与服务之间的所有通信最终都会产生要进行发送和接收的 Message 实例。

您通常不会与 Message 类直接进行交互。 相反，你需要使用 WCF 服务模型构造（如数据协定、消息协定和操作协定）来描述传入消息和传出消息。 但是，在某些高级方案中，可以直接使用 Message 类进行编程。 例如，在以下情况下可能需要使用 Message 类：

• 需要一种替代方式来创建传出的消息内容（例如，从磁盘上的文件直接创建消息），而不是序列化 .NET Framework 对象。

• 需要一种替代方式来使用传入的消息内容（例如，需要将 XSLT 转换应用于原始 XML 内容），而不是反序列化为 .NET Framework 对象。

• 无论消息内容怎样都需要使用常规方式来处理消息（例如，在生成路由器、负载平衡器或发布-订阅系统时对消息进行路由或转发）。

在使用 Message 类之前，请先通过数据传输体系结构概述熟悉 WCF 数据传输体系结构。

Message 是一种通用的数据容器，但其设计严格遵循 SOAP 协议中消息的设计方式。 就像 SOAP 中一样，消息同时具有消息正文和标头。 消息正文包含实际负载数据，而标头包含其他已命名的数据容器。 用于读取和写入消息正文与标头的规则是不同的，例如，标头总是在内存中进行缓冲，并且可以按任意顺序访问任意次，而正文仅能读取一次且可以进行流式处理。 通常，使用 SOAP 时，消息正文被映射到 SOAP 正文，而消息头被映射到 SOAP 标头。

在操作中使用 Message 类

可以将 Message 类用作操作的输入参数和/或操作的返回值。 只要在操作中的任何位置使用了 Message，就必须遵从以下限制：

• 操作不能具有任何 out 或 ref 参数。

• 不能有一个以上的 input 参数。 如果该参数存在，其类型必须为 Message 或消息协定。

• 返回类型必须为 void、Message 或消息协定类型。

下面的代码示例包含一个有效的操作协定。

[ServiceContract]
public interface IMyService
{
    [OperationContract]
    Message GetData();

    [OperationContract]
    void PutData(Message m);
}

<ServiceContract()> _
Public Interface IMyService
    <OperationContract()> _
    Function GetData() As Message

    <OperationContract()> _
    Sub PutData(ByVal m As Message)
End Interface

创建基本消息

Message 类提供了静态 CreateMessage 工厂方法，可以使用这些方法创建基本消息。

所有 CreateMessage 重载都采用一个类型为 MessageVersion 的版本参数，该参数指示要用于消息的 SOAP 和 WS-Addressing 版本。 如果要使用与传入消息相同的协议版本，则可以使用 IncomingMessageVersion 实例（从 OperationContext 属性获取）上的 Current 属性。 大多数 CreateMessage 重载还具有一个字符串参数，该参数指示要用于消息的 SOAP 操作。 可以将版本设置为 None 以禁用 SOAP 信封生成；消息仅包含正文。

从对象创建消息

仅采用一个版本和一个操作作为参数的最基本的 CreateMessage 重载可创建一条正文为空的消息。 另一种重载采用一个附加的 Object 参数；此重载所创建的消息的正文是给定对象的序列化表示。 请使用具有默认设置的 DataContractSerializer 进行序列化。 如果要使用其他序列化程序，或者希望对 DataContractSerializer 进行不同配置，请使用也采用一个 CreateMessage 参数的 XmlObjectSerializer 重载。

例如，若要在消息中返回一个对象，可以使用下面的代码。

public class MyService1 : IMyService
{
    public Message GetData()
    {
        Person p = new Person();
        p.name = "John Doe";
        p.age = 42;
        MessageVersion ver = OperationContext.Current.IncomingMessageVersion;
        return Message.CreateMessage(ver, "GetDataResponse", p);
    }

    public void PutData(Message m)
    {
        // Not implemented.
    }
}
[DataContract]
public class Person
{
    [DataMember] public string name;
    [DataMember] public int age;
}

Public Class MyService1
    Implements IMyService

    Public Function GetData() As Message _
     Implements IMyService.GetData
        Dim p As New Person()
        p.name = "John Doe"
        p.age = 42
        Dim ver As MessageVersion = _
          OperationContext.Current.IncomingMessageVersion
        Return Message.CreateMessage(ver, "GetDataResponse", p)

    End Function


    Public Sub PutData(ByVal m As Message) _
    Implements IMyService.PutData
        ' Not implemented.
    End Sub
End Class
<DataContract()> _
Public Class Person
    <DataMember()> _
    Public name As String
    <DataMember()> _
    Public age As Integer
End Class

从 XML 读取器创建消息

有些 CreateMessage 重载采用一个 XmlReader 或一个 XmlDictionaryReader 而不是对象作为正文。 在这种情况下，消息的正文会包含从传递的 XML 读取器中进行读取而产生的 XML。 例如，下面的代码会返回一条消息，该消息的正文内容是从一个 XML 文件中读取的。

public class MyService2 : IMyService
{
    public Message GetData()
    {
        FileStream stream = new FileStream("myfile.xml",FileMode.Open);
        XmlDictionaryReader xdr =
               XmlDictionaryReader.CreateTextReader(stream,
                           new XmlDictionaryReaderQuotas());
        MessageVersion ver =
            OperationContext.Current.IncomingMessageVersion;
        return Message.CreateMessage(ver,"GetDataResponse",xdr);
    }

    public void PutData(Message m)
    {
        // Not implemented.
    }
}

Public Class MyService2
    Implements IMyService

    Public Function GetData() As Message Implements IMyService.GetData
        Dim stream As New FileStream("myfile.xml", FileMode.Open)
        Dim xdr As XmlDictionaryReader = _
        XmlDictionaryReader.CreateTextReader(stream, New XmlDictionaryReaderQuotas())
        Dim ver As MessageVersion = OperationContext.Current.IncomingMessageVersion
        Return Message.CreateMessage(ver, "GetDataResponse", xdr)

    End Function


    Public Sub PutData(ByVal m As Message) Implements IMyService.PutData

    End Sub
End Class

此外，还有一些 CreateMessage 重载采用一个表示整个消息（而不仅仅是正文）的 XmlReader 或 XmlDictionaryReader 作为参数。 这些重载还采用一个整型 maxSizeOfHeaders 参数。 一旦创建了消息，标头就总是在内存中进行缓冲，而此参数用于限制发生的缓冲数量。 如果 XML 来自不受信任的源，那么为了降低发生拒绝服务攻击的可能性，将此参数设置为安全值就变得十分重要。 XML 读取器表示的消息的 SOAP 和 WS-Addressing 版本必须与使用版本参数指示的版本相匹配。

使用 BodyWriter 创建消息

有一种 CreateMessage 重载采用一个 BodyWriter 实例来描述消息的正文。 BodyWriter 是一个抽象类，可以从该类派生以自定义创建消息正文的方式。 您可以创建自己的 BodyWriter 派生类，以便按照自定义方式来描述消息正文。 必须重写采用一个 BodyWriter.OnWriteBodyContents 作为参数的 XmlDictionaryWriter 方法；此方法负责写出正文。

正文编写器可以是缓冲式的，也可以是非缓冲式的（流式）。 缓冲式正文编写器可以任意次写出其内容，而流式正文编写器只能写出其内容一次。 IsBuffered 属性指示正文编写器是否为缓冲式的。 通过调用受保护的 BodyWriter 构造函数（该构造函数采用一个 isBuffered 布尔参数），可以设置正文编写器的这一属性。 正文编写器支持从非缓冲式正文编写器创建缓冲式正文编写器。 可以重写 OnCreateBufferedCopy 方法以自定义此过程。 默认情况下，使用包含由 OnWriteBodyContents 返回的 XML 的内存中缓冲区。 OnCreateBufferedCopy 采用一个 maxBufferSize 整型参数；如果重写此方法，则不得创建大于此最大大小的缓冲区。

BodyWriter 类提供了 WriteBodyContents 和 CreateBufferedCopy 方法，这两个方法实质上分别是 OnWriteBodyContents 和 OnCreateBufferedCopy 方法的瘦包装。 这些方法执行状态检查，以确保访问非缓冲式正文编写器的次数不会超过一次。 仅当基于 Message 创建自定义 BodyWriters 派生类时才直接调用这些方法。

创建错误消息

可以使用某些 CreateMessage 重载创建 SOAP 错误消息。 其中一个最基本的重载采用一个用于描述错误的 MessageFault 对象作为参数。 其他重载是为方便起见而提供的。 第一个这样的重载采用一个 FaultCode 和一个原因字符串作为参数，并使用 MessageFault（该方法使用这些信息）创建一个 MessageFault.CreateFault。 另一个重载采用一个详细信息对象作为参数，并将该对象与错误代码和原因一起传递给 CreateFault。 例如，下面的操作会返回一个错误。

public class MyService3 : IMyService
{
    public Message GetData()
    {
        FaultCode fc = new FaultCode("Receiver");
        MessageVersion ver = OperationContext.Current.IncomingMessageVersion;
            return Message.CreateMessage(ver,fc,"Bad data","GetDataResponse");
    }

    public void PutData(Message m)
    {
        // Not implemented.
    }
}

Public Class MyService3
    Implements IMyService

    Public Function GetData() As Message Implements IMyService.GetData
        Dim fc As New FaultCode("Receiver")
        Dim ver As MessageVersion = OperationContext.Current.IncomingMessageVersion
        Return Message.CreateMessage(ver, fc, "Bad data", "GetDataResponse")

    End Function


    Public Sub PutData(ByVal m As Message) Implements IMyService.PutData

    End Sub
End Class

提取消息正文数据

Message 类支持多种从其正文提取信息的方式。 它们可分为以下几类：

• 将整个消息正文一次性写出到 XML 编写器。 这称为“写入消息”。

• 将 XML 读取器放在消息正文上。 这使您可以在以后根据需要逐段访问消息正文。 这称为“读取消息”。

• 可以将整个消息（包括它的正文）复制到类型为 MessageBuffer 的内存中缓冲区。 这称为“复制消息”。

无论使用哪种访问方式，都只能访问 Message 的正文一次。 消息对象具有 State 属性，该属性最初设置为 Created。 前面列表中描述的三种访问方法分别将状态设置为 Written、Read 和 Copied。 此外，Close 方法可以在不再需要消息正文内容时将状态设置为 Closed。 只有当消息正文处于 Created 状态时，才能对其进行访问，并且在状态已更改后，无法返回到 Created 状态。

写入消息

WriteBodyContents(XmlDictionaryWriter) 方法将给定 Message 实例的正文内容写出到给定 XML 编写器。 WriteBody 方法执行相同的操作，不同之处在于该方法将正文内容封装在适当的包装器元素（如 <soap:body>）中。 最后，WriteMessage 写出整个消息，包括 SOAP 包装信封和标头。 如果禁用 SOAP（Version 为 MessageVersion.None），则所有这三个方法都执行相同的操作：写出消息正文内容。

例如，下面的代码将一个传入消息的正文写出到一个文件中。

public class MyService4 : IMyService
{
    public void PutData(Message m)
    {
        FileStream stream = new FileStream("myfile.xml",FileMode.Create);
        XmlDictionaryWriter xdw =
            XmlDictionaryWriter.CreateTextWriter(stream);
        m.WriteBodyContents(xdw);
        xdw.Flush();
    }

    public Message GetData()
    {
        throw new NotImplementedException();
    }
}

Public Class MyService4
    Implements IMyService

    Public Sub PutData(ByVal m As Message) Implements IMyService.PutData
        Dim stream As New FileStream("myfile.xml", FileMode.Create)
        Dim xdw As XmlDictionaryWriter = XmlDictionaryWriter.CreateTextWriter(stream)
        m.WriteBodyContents(xdw)
        xdw.Flush()

    End Sub


    Public Function GetData() As Message Implements IMyService.GetData
        Throw New NotImplementedException()

    End Function
End Class

另有两个帮助器方法可写出某些 SOAP 开始元素标记。 这些方法不访问消息正文，因而不会更改消息状态。 其中包括：

• WriteStartBody 可写入开始正文元素，如 <soap:Body>。

• WriteStartEnvelope 可写入开始信封元素，如 <soap:Envelope>。

若要写入相应的结束元素标记，请对相应的 XML 编写器调用 WriteEndElement。 直接调用这些方法的情况极少。

读取消息

读取消息正文的主要方式是调用 GetReaderAtBodyContents。 您会取回一个 XmlDictionaryReader 以便用于读取消息正文。 请注意，只要调用了 Message，GetReaderAtBodyContents 就会转换到 Read 状态，而不是在您使用返回的 XML 读取器时发生转换。

使用 GetBody 方法还可以将消息正文作为类型化对象进行访问。 在内部，此方法使用 GetReaderAtBodyContents，因而也会将消息状态转换为 Read 状态（请参见 State 属性）。

最好检查一下 IsEmpty 属性，在这种情况下消息正文为空，且 GetReaderAtBodyContents 会引发 InvalidOperationException。 同样，如果消息为接收到的消息（如答复），也可能需要检查一下 IsFault，该属性指示消息是否包含错误。

GetBody 的最基本的重载使用 DataContractSerializer（配置了默认设置且禁用了 MaxItemsInObjectGraph 配额）将消息正文反序列化为某个类型（由泛型参数指示）的实例。 如果想要使用其他序列化引擎，或是通过非默认方式配置 DataContractSerializer，请使用采用一个 GetBody 作为参数的 XmlObjectSerializer 重载。

例如，下面的代码从包含一个序列化 Person 对象的消息正文中提取数据，然后输出人员的姓名。

    public class MyService5 : IMyService
    {
        public void PutData(Message m)
        {
            Person p = m.GetBody<Person>();
            Console.WriteLine(p.name);
        }

        public Message GetData()
        {
            throw new NotImplementedException();
        }
    }
}
namespace Samples2
{
    [ServiceContract]
    public interface IMyService
    {
        [OperationContract]
        Message GetData();

        [OperationContract]
        void PutData(Message m);
    }

    [DataContract]
    public class Person
    {
        [DataMember] public string name;
        [DataMember] public int age;
    }

    Public Class MyService5
        Implements IMyService

        Public Sub PutData(ByVal m As Message) Implements IMyService.PutData
            Dim p As Person = m.GetBody(Of Person)()
            Console.WriteLine(p.name)

        End Sub


        Public Function GetData() As Message Implements IMyService.GetData
            Throw New NotImplementedException()

        End Function
    End Class
End Namespace
Namespace Samples2
    <ServiceContract()> _
    Public Interface IMyService
        <OperationContract()> _
        Function GetData() As Message

        <OperationContract()> _
        Sub PutData(ByVal m As Message)
    End Interface

    <DataContract()> _
    Public Class Person
        <DataMember()> _
        Public name As String
        <DataMember()> _
        Public age As Integer
    End Class

将消息复制到缓冲区中

有时需要不只一次地访问消息正文，例如，作为发行者-订户系统的一部分而将同一消息转发给多个目标。 在这种情况下，需要在内存中缓冲整个消息（包括正文）。 可以通过调用 CreateBufferedCopy(Int32) 达到此目的。 此方法采用一个表示最大缓冲区大小的整型参数，且创建一个不大于此大小的缓冲区。 如果消息来自不受信任的源，则将此参数设置为安全值是十分重要的。

缓冲区作为一个 MessageBuffer 实例返回。 可以通过几种方式访问缓冲区中的数据。 主要方式是调用 CreateMessage 以便从缓冲区创建 Message 实例。

访问缓冲区中的数据的另一种方式是实现 IXPathNavigable 接口（MessageBuffer 类实现了该接口以直接访问基础 XML）。 使用某些 CreateNavigator 重载可以创建由节点配额（用于限制可访问的 XML 节点数）保护的 System.Xml.XPath 导航器。 这有助于防止通过占用大量处理时间而实施的拒绝服务攻击。 默认情况下禁用此配额。 某些 CreateNavigator 重载使您可以使用 XmlSpace 枚举来指定应如何处理 XML 中的空白（默认设置为 XmlSpace.None）。

访问消息缓冲区内容的最后一种方式是使用 WriteMessage 将缓冲区的内容写出到流中。

下面的示例演示使用 MessageBuffer 的过程：将一个传入消息转发给多个接收方，然后将其记录到一个文件中。 如果不进行缓冲，这将是不可能的，因为消息正文只能被访问一次。

[ServiceContract]
public class ForwardingService
{
    private List<IOutputChannel> forwardingAddresses;

    [OperationContract]
    public void ForwardMessage (Message m)
    {
        //Copy the message to a buffer.
        MessageBuffer mb = m.CreateBufferedCopy(65536);

        //Forward to multiple recipients.
        foreach (IOutputChannel channel in forwardingAddresses)
        {
            Message copy = mb.CreateMessage();
            channel.Send(copy);
        }

        //Log to a file.
        FileStream stream = new FileStream("log.xml",FileMode.Append);
        mb.WriteMessage(stream);
        stream.Flush();
    }
}

<ServiceContract()> _
Public Class ForwardingService
    Private forwardingAddresses As List(Of IOutputChannel)

    <OperationContract()> _
    Public Sub ForwardMessage(ByVal m As Message)
        'Copy the message to a buffer.
        Dim mb As MessageBuffer = m.CreateBufferedCopy(65536)

        'Forward to multiple recipients.
        Dim channel As IOutputChannel
        For Each channel In forwardingAddresses
            Dim copy As Message = mb.CreateMessage()
            channel.Send(copy)
        Next channel

        'Log to a file.
        Dim stream As New FileStream("log.xml", FileMode.Append)
        mb.WriteMessage(stream)
        stream.Flush()

    End Sub
End Class

MessageBuffer 类还有其他值得注意的成员。 当不再需要缓冲区内容时，可以调用 Close 方法来释放资源。 BufferSize 属性返回已分配的缓冲区的大小。 MessageContentType 属性返回消息的 MIME 内容类型。

访问消息正文以进行调试

出于调试目的，您可以调用 ToString 方法以获取消息的字符串表示。 如果消息由文本编码器进行编码，则此表示通常与该消息在网络上的表示方式相匹配，只不过 XML 会以更好的格式表示以方便人们阅读。 一个例外的情况是消息正文。 正文只能被读取一次，且 ToString 不会更改消息状态。 因此，ToString 方法可能无法访问正文，并可能用占位符（如“…”或三个点）替换消息正文。 因此，如果消息的正文内容很重要，则不要使用 ToString 来记录消息。

访问其他消息部分

该类提供了各种属性，以便访问除正文内容之外的其他与消息有关的信息。 但是，一旦关闭了消息，将无法调用这些属性：

• Headers 属性表示消息头。 请参见本主题稍后关于“使用标头”的部分。

• Properties 属性表示消息属性，这些属性是附加到消息的命名数据段，且通常不会在发送消息时发出。 请参见本主题稍后关于“使用属性”的部分。

• Version 属性指示与消息相关联的 SOAP 和 WS-Addressing 版本；如果禁用了 SOAP，则该属性为 None。

• IsFault 属性在消息为 SOAP 错误消息时返回 true。

• IsEmpty 属性在消息为空时返回 true。

可以使用 GetBodyAttribute(String, String) 方法访问正文包装元素（如 <soap:Body>）上由特定名称和命名空间标识的特定属性。 如果未找到这样一个属性，则返回 null。 仅当 Message 处于 Created 状态时（即尚未访问消息正文时），才能调用此方法。

使用标头

Message 可以包含任意数量的已命名 XML 片断，这些片断称为“标头”。 每个片断通常都映射到一个 SOAP 标头。 可以通过类型为 Headers 的 MessageHeaders 属性来访问标头。 MessageHeaders 是一个 MessageHeaderInfo 对象集合，可以通过其 IEnumerable 接口或其索引器来访问各个标头。 例如，下面的代码列出了某个 Message 中的所有标头的名称。

public class MyService6 : IMyService
{
    public void PutData(Message m)
    {
        foreach (MessageHeaderInfo mhi in m.Headers)
        {
            Console.WriteLine(mhi.Name);
        }
    }

    public Message GetData()
    {
        throw new NotImplementedException();
    }
}

Public Class MyService6
    Implements IMyService

    Public Sub PutData(ByVal m As Message) Implements IMyService.PutData
        Dim mhi As MessageHeaderInfo
        For Each mhi In m.Headers
            Console.WriteLine(mhi.Name)
        Next mhi

    End Sub


    Public Function GetData() As Message Implements IMyService.GetData
        Throw New NotImplementedException()

    End Function
End Class

添加、删除、查找标头

可以使用 Add 方法在所有现有标头的末尾添加新的标头。 可以使用 Insert 方法在特定索引处插入标头。 现有标头会发生位移，以便为插入的项腾出位置。 标头按照其索引进行排序，并且第一个可用索引为 0。 您可以使用各种 CopyHeadersFrom 方法重载添加其他 Message 或 MessageHeaders 实例的标头。 某些重载复制单个标头，而其他重载则复制所有标头。 Clear 方法可以删除所有标头。 RemoveAt 方法可以删除位于特定索引处的标头（并且位移该标头之后的所有标头）。 RemoveAll 方法可以删除具有特定名称和命名空间的所有标头。

使用 FindHeader 方法检索特定标头。 此方法采用要查找的标头的名称和命名空间作为参数，并返回该标头的索引。 如果该标头出现了多次，则引发异常。 如果未找到该标头，则返回 –1。

在 SOAP 标头模型中，标头可以具有一个 Actor 值，该值指定标头的预期接收方。 最基本的 FindHeader 重载仅搜索准备发送给消息的最终接收方的标头。 但是，使用另一个重载可以指定搜索中包括哪些 Actor 值。 有关详细信息，请参阅 SOAP 规范。

提供了 CopyTo(MessageHeaderInfo[], Int32) 方法，以便将标头从 MessageHeaders 集合复制到 MessageHeaderInfo 对象数组。

若要访问标头中的 XML 数据，可以调用 GetReaderAtHeader，并为特定标头索引返回一个 XML 读取器。 如果您希望将标头内容反序列化为对象，请使用 GetHeader<T>(Int32) 或其他重载之一。 最基本的重载使用以默认方式配置的 DataContractSerializer 来反序列化标头。 如果您希望使用其他序列化程序或 DataContractSerializer 的其他配置，请使用采用一个 XmlObjectSerializer 作为参数的重载之一。 还有一些重载采用标头名称、命名空间作为参数，还可能采用一个 Actor 值列表而不是一个索引作为参数；这种重载是 FindHeader 和 GetHeader 的组合。

使用属性

一个 Message 实例可以包含任意多个具有任意类型的命名对象。 此集合可以通过类型为 Properties 的 MessageProperties 属性访问。 此集合实现了 IDictionary<TKey,TValue> 接口，并充当从 String 到 Object 的映射。 通常，属性值不会直接映射到网络上消息的任何部分，而是向 WCF 通道堆栈中的各个通道或 CopyTo(MessageHeaderInfo[], Int32) 服务框架提供各种消息处理提示。 有关示例，请参阅数据传输体系结构概述。

从 Message 类继承

如果使用 CreateMessage 创建的内置消息类型不能满足您的要求，请创建一个从 Message 类派生的类。

定义消息正文内容

用于访问消息正文中的数据的技术主要有三种：写入、读取消息正文以及将其复制到缓冲区。 这些操作最终分别导致对 OnWriteBodyContents 的派生类调用 OnGetReaderAtBodyContents、OnCreateBufferedCopy 和 Message 方法。 Message 基类保证对于每个 Message 实例仅调用这些方法中的一个，并保证每个方法的调用不会超过一次。 该基类还确保不会对已关闭的消息调用这些方法。 在您的实现中，无需跟踪消息状态。

OnWriteBodyContents 是一个抽象方法，必须加以实现。 定义消息正文内容的最基本的方式是使用此方法执行写入操作。 例如，下面的消息包含 100,000 个介于 1 到 20 之间的随机数。

public class RandomMessage : Message
{
    override protected  void  OnWriteBodyContents(XmlDictionaryWriter writer)
    {
        Random r = new Random();
        for (int i = 0; i <100000; i++)
        {
            writer.WriteStartElement("number");
            writer.WriteValue(r.Next(1,20));
            writer.WriteEndElement();
        }
    }
    //code omitted…

Public Class RandomMessage
    Inherits Message

    Protected Overrides Sub OnWriteBodyContents( _
            ByVal writer As XmlDictionaryWriter)
        Dim r As New Random()
        Dim i As Integer
        For i = 0 To 99999
            writer.WriteStartElement("number")
            writer.WriteValue(r.Next(1, 20))
            writer.WriteEndElement()
        Next i

    End Sub
    ' Code omitted.

OnGetReaderAtBodyContents() 和 OnCreateBufferedCopy 方法具有适用于大多数情况的默认实现。 这些默认实现调用 OnWriteBodyContents，对结果进行缓冲，并且使用得到的缓冲区。 但是，在某些情况下，这可能还无法满足需要。 在前面的示例中，读取消息会导致 100,000 个 XML 元素被缓冲，这可能并不是理想的结果。 您可能希望重写 OnGetReaderAtBodyContents() 以返回能够提供随机数的自定义 XmlDictionaryReader 派生类。 然后，你可以重写 OnWriteBodyContents 以使用 OnGetReaderAtBodyContents() 方法返回的读取器，如下面的示例所示。

    public override MessageHeaders Headers
    {
        get { throw new Exception("The method or operation is not implemented."); }
    }

    public override MessageProperties Properties
    {
        get { throw new Exception("The method or operation is not implemented."); }
    }

    public override MessageVersion Version
    {
        get { throw new Exception("The method or operation is not implemented."); }
    }
}

public class RandomMessage2 : Message
{
    override protected XmlDictionaryReader OnGetReaderAtBodyContents()
    {
    return new RandomNumbersXmlReader();
    }

    override protected void OnWriteBodyContents(XmlDictionaryWriter writer)
    {
        XmlDictionaryReader xdr = OnGetReaderAtBodyContents();
        writer.WriteNode(xdr, true);
    }
    public override MessageHeaders Headers
    {
        get { throw new Exception("The method or operation is not implemented."); }
    }

    public override MessageProperties Properties
    {
        get { throw new Exception("The method or operation is not implemented."); }
    }

    public override MessageVersion Version
    {
        get { throw new Exception("The method or operation is not implemented."); }
    }
}

public class RandomNumbersXmlReader : XmlDictionaryReader
{
    //code to serve up 100000 random numbers in XML form omitted…

    Public Overrides ReadOnly Property Headers() As MessageHeaders
        Get
            Throw New Exception("The method or operation is not implemented.")
        End Get
    End Property

    Public Overrides ReadOnly Property Properties() As MessageProperties
        Get
            Throw New Exception("The method or operation is not implemented.")
        End Get
    End Property

    Public Overrides ReadOnly Property Version() As MessageVersion
        Get
            Throw New Exception("The method or operation is not implemented.")
        End Get
    End Property
End Class

Public Class RandomMessage2
    Inherits Message

    Protected Overrides Function OnGetReaderAtBodyContents() As XmlDictionaryReader
        Return New RandomNumbersXmlReader()

    End Function


    Protected Overrides Sub OnWriteBodyContents(ByVal writer As XmlDictionaryWriter)
        Dim xdr As XmlDictionaryReader = OnGetReaderAtBodyContents()
        writer.WriteNode(xdr, True)

    End Sub

    Public Overrides ReadOnly Property Headers() As MessageHeaders
        Get
            Throw New Exception("The method or operation is not implemented.")
        End Get
    End Property

    Public Overrides ReadOnly Property Properties() As MessageProperties
        Get
            Throw New Exception("The method or operation is not implemented.")
        End Get
    End Property

    Public Overrides ReadOnly Property Version() As MessageVersion
        Get
            Throw New Exception("The method or operation is not implemented.")
        End Get
    End Property
End Class

Public Class RandomNumbersXmlReader
    Inherits XmlDictionaryReader
    'code to serve up 100000 random numbers in XML form omitted

与此类似，您可能希望重写 OnCreateBufferedCopy 以返回您自己的 MessageBuffer 派生类。

除了提供消息正文内容以外，您的消息派生类还必须重写 Version、Headers 和 Properties 属性。

请注意，如果您创建消息的副本，则该副本将使用原始消息中的消息头。

其他可以重写的成员

可以重写 OnWriteStartEnvelope、OnWriteStartHeaders 和 OnWriteStartBody 方法以指定如何写出 SOAP 信封、SOAP 标头和 SOAP 正文元素开始标记。它们通常对应于 <soap:Envelope>、<soap:Header> 和 <soap:Body>。 如果 Version 属性返回 None，则这些方法通常不应该写出任何内容。

注意

OnGetReaderAtBodyContents 的默认实现在调用 OnWriteStartEnvelope 以及缓冲结果之前调用 OnWriteStartBody 和 OnWriteBodyContents。 标头不会写出。

重写 OnWriteMessage 方法可更改从消息的各个片段构造整个消息的方式。 OnWriteMessage 方法是从 WriteMessage 以及默认 OnCreateBufferedCopy 实现中调用的。 请注意，重写 WriteMessage 不是最佳做法。 更好的做法是重写适当的 On 方法（例如，OnWriteStartEnvelope、OnWriteStartHeaders 和 OnWriteBodyContents）。

重写 OnBodyToString 可以重写在调试期间表示消息正文的方式。 默认方式是将消息正文表示为三个点（“…”）。 请注意，当消息处于除 Closed 之外的任何状态时，可以多次调用此方法。 此方法的实现在任何情况下都不应产生必须仅执行一次的操作（如从只进的流中读取）。

重写 OnGetBodyAttribute 方法可以对 SOAP 正文元素上的属性进行访问。 此方法可以调用任意次，但 Message 基类型保证仅当消息处于 Created 状态时才调用此方法。 在实现中不需要检查状态。 默认实现始终返回 null，这指示正文元素上不存在任何属性。

如果 Message 对象必须在不再需要消息正文时执行任何特殊的清理操作，则可以重写 OnClose。 默认实现不执行任何操作。

IsEmpty 和 IsFault 属性可以重写。 默认情况下，这两个属性都返回 false。