WCF 和流式处理请求和响应

Question

在 WCF 中，我不能将服务 写入 到客户端接收的流中，这对吗？

WCF 支持流式处理请求、响应或两者。 我想支持数据生成器（在流式请求的情况下为客户端，或在流式响应的情况下为服务器）可以在流上写入的场景。这支持吗？

类比是来自 ASP.NET 请求的 Response.OutputStream。在 ASPNET 中，任何页面都可以在输出流上调用 Write，并且内容被客户端接收。我可以在 WCF 服务中执行类似的操作吗 - 在客户端接收到的流上调用 Write？

让我用一个 WCF 插图来解释。 WCF 中流式处理的最简单示例是服务将 FileStream 返回给客户端。这是一个流式响应。实现这个的服务器代码是这样的：

[ServiceContract]
public interface IStreamService
{
    [OperationContract]
    Stream GetData(string fileName);
}
public class StreamService : IStreamService
{
    public Stream GetData(string filename)
    {
        return new FileStream(filename, FileMode.Open)
    }
}

而客户端代码是这样的：

StreamDemo.StreamServiceClient client = 
    new WcfStreamDemoClient.StreamDemo.StreamServiceClient();
Stream str = client.GetData(@"c:\path\on\server\myfile.dat");
do {
  b = str.ReadByte(); //read next byte from stream
  ...
} while (b != -1);

（示例取自http://blog.joachim.at/?p=33）

清楚，对吧？服务器将 Stream 返回给客户端，客户端在其上调用 Read。

客户端是否可以提供一个 Stream，而服务器可以在其上调用 Write？
换句话说，它不是一个拉模型——客户端从服务器拉数据——它是一个推模型，客户端提供“接收器”流并且服务器写入它。服务器端代码可能类似于：

[ServiceContract]
public interface IStreamWriterService
{
    [OperationContract]
    void SendData(Stream clientProvidedWritableStream);
}
public class DataService : IStreamWriterService
{
    public void GetData(Stream s)
    {
        do {
          byte[] chunk = GetNextChunk();
          s.Write(chunk,0, chunk.Length);
        } while (chunk.Length > 0); 
    }
}

这在 WCF 中是否可行，如果可以，如何实现？绑定、接口等需要哪些配置设置？术语是什么？

也许它会起作用？ （没试过）

谢谢。

Answer 1

我相当确定没有任何 WCF 绑定组合可以让您字面上写入客户端的流。应该有似乎是合乎逻辑的，因为在表面之下的某个地方肯定会有NetworkStream，但是一旦你开始添加加密和所有有趣的东西，WCF 就必须知道如何包装这个流来打开它进入“真实”的信息，我认为它不会。

但是，I-need-to-return-a-stream-but-component-X-wants-to-write-to-one 场景很常见，我有一个包罗万象的解决方案对于这种情况，即创建一个双向流并产生一个工作线程来写入它。做到这一点的最简单和最安全的方法（我的意思是，涉及编写最少代码并因此最不可能出错的方法）是使用匿名管道。

这是一个返回 AnonymousPipeClientStream 的方法示例，该方法可用于 WCF 消息、MVC 结果等 - 任何您想要反转方向的地方：

static Stream GetPipedStream(Action<Stream> writeAction)
{
    AnonymousPipeServerStream pipeServer = new AnonymousPipeServerStream();
    ThreadPool.QueueUserWorkItem(s =>
    {
        using (pipeServer)
        {
            writeAction(pipeServer);
            pipeServer.WaitForPipeDrain();
        }
    });
    return new AnonymousPipeClientStream(PipeDirection.In, pipeServer.ClientSafePipeHandle);
}

这个例子的用法是：

static Stream GetTestStream()
{
    string data = "The quick brown fox jumps over the lazy dog.";
    return GetPipedStream(s =>
    {
        StreamWriter writer = new StreamWriter(s);
        writer.AutoFlush = true;
        for (int i = 0; i < 50; i++)
        {
            Thread.Sleep(50);
            writer.WriteLine(data);
        }
    });
}

关于这种方法只有两个注意事项：

1. 如果writeAction 执行任何处理流的操作，它将失败（这就是为什么测试方法实际上并未处理StreamWriter - 因为这会处理底层流）；

2. 如果writeAction 实际上没有写入任何数据，它可能会失败，因为WaitForPipeDrain 将立即返回并创建竞争条件。 （如果这是一个问题，您可以稍微防御性地编写代码来避免这种情况，但对于罕见的边缘情况，它会使事情复杂化很多。）

希望对您的具体情况有所帮助。

Answer 2

WCF 流式传输有两种方式 - 您的客户端可以在流中上传内容，但您的 WCF 服务也可以在流中向下发送内容。您绝对可以编写一个服务，根据文件名或某些 ID 或其他内容流回大文件 - 绝对如此。

如果你想从服务发回数据，你需要在你的服务方法的返回值中这样做，它需要是Stream类型 - 你不能（据我所知）“供应”要写入的流 - WCF 服务将创建响应流并将其发送回。

您是否查看过有关 WCF 流的 MSDN Streaming Message Transfer 或 David Wood's blog post 或 Kjell-Sverre's blog post？它们都很好地显示了您需要的配置设置（基本上将绑定配置中的TransferMode 设置为Streamed、StreamedRequest 或StreamedResponse）。