如何:启用流处理

Windows Communication Foundation (WCF) 可以使用缓冲传输或流传输来发送消息。在默认的缓冲传输模式中,只有在一条消息全部传递完之后,接收方才能读取该消息。在流传输模式中,不必等到消息全部传递完,接收方便可以开始处理该消息。当传递的信息很长且可以依次处理时,流模式非常有用。当消息太长以至于无法全部缓冲时,流模式也非常有用。

若要启用流处理,请适当地定义 OperationContract 并在传输级别上启用流处理。

对数据进行流处理

  1. 若要对数据进行流处理,服务的 OperationContract 必须满足两个要求:

    1. 保留要进行流处理的数据的参数必须是方法中的唯一参数。例如,如果要对输入消息进行流处理,则该操作必须正好具有一个输入参数。同样,如果要对输出消息进行流处理,则该操作必须正好具有一个输出参数或一个返回值。
    2. 参数和返回值的类型中至少有一个必须是 Stream, MessageIXmlSerializable

    下面是流处理数据的协定的示例。

    GetStream 操作接收一些缓冲输入数据作为经过缓冲的 string,并返回经过流处理的 Stream。相反,UploadStream 接收一个经过流处理的 Stream,并返回一个经过缓冲的 boolEchoStream 接收并返回 Stream,是一个其输入和输出消息都经过流处理的操作的示例。最后,GetReversedStream 不接收输入,将返回经过流处理的 Stream

  2. 必须在绑定上启用流处理。设置 TransferMode 属性,可以采用下面的值之一:

    1. Buffered,
    2. Streamed,此值在两个方向上启用流通信。
    3. StreamedRequest,此值仅启用请求流处理。
    4. StreamedResponse,此值仅启用响应流处理。

    BasicHttpBinding 公开绑定上的 TransferMode 属性,与 NetTcpBindingNetNamedPipeBinding 一样。还可以在传输绑定元素上设置 TransferMode 属性,并且在自定义绑定中使用。

    下面的示例演示如何通过代码和通过更改配置文件来设置 TransferMode。两个示例都将 maxReceivedMessageSize 属性设置为 64 MB,这是可以接收的最大消息大小。默认的 maxReceivedMessageSize 是 64 KB,对于流处理方案而言,此值通常太低。根据应用程序期望接收的消息的最大大小适当地设置此配额设置。还请注意,maxBufferSize 可控制缓冲的最大大小,应适当地进行设置。

    1. 下面示例中的配置段演示如何将 basicHttpBinding 和自定义 HTTP 绑定上的 TransferMode 属性设置为流处理。
    2. 下面的代码段演示如何将 basicHttpBinding 和自定义 HTTP 绑定上的 TransferMode 属性设置为流处理。
    3. 下面的代码段演示如何将自定义 TCP 绑定上的 TransferMode 属性设置为流处理。
  3. GetStreamUploadStreamEchoStream 操作都可以处理直接从文件发送数据或将接收的数据直接保存到文件的情况。下面的代码适用于 GetStream

编写自定义流

  1. 若要在发送或接收数据流的每个块区时对其进行特殊处理,可从 Stream 派生一个自定义流类。与自定义流的示例一样,下面的代码包含 GetReversedStream 方法和 ReverseStream 类。

    GetReversedStream 创建并返回一个新的 ReverseStream 实例。当系统从 ReverseStream 对象中读取时,发生实际处理。ReverseStream.Read 方法从基础文件中读取字节块区,反转字节,然后返回反转的字节。此方法不会反转整个文件内容;一次只能反转一个字节块区。本示例演示在从流中读取内容或将内容写入到流中时如何执行流处理。

另请参见

概念

大型数据和流

其他资源

Service Contract: Stream