传递流的最佳方法是什么

Question

我尝试将流作为参数传递，但我不确定哪种方式是“最好的”，所以想听听您对我的代码示例的意见/建议

我个人更喜欢选项 3，但我从未在其他任何地方看到过这种方式。

选项 1 适用于小流（和已知大小的流）

选项 2_1 和 2_2 总是会让“处理人”怀疑谁有责任处置/关闭。

public interface ISomeStreamHandler
{
    // Option 1
    void HandleStream(byte[] streamBytes);

    // Option 2
    void HandleStream(Stream stream);

    // Option 3
    void HandleStream(Func<Stream> openStream);
}

public interface IStreamProducer
{
    Stream GetStream();
}

public class SomeTestClass
{
    private readonly ISomeStreamHandler _streamHandler;
    private readonly IStreamProducer _streamProducer;

    public SomeTestClass(ISomeStreamHandler streamHandler, IStreamProducer streamProducer)
    {
        _streamHandler = streamHandler;
        _streamProducer = streamProducer;
    }

    public void DoOption1()
    {
        var buffer = new byte[16 * 1024];
        using (var input = _streamProducer.GetStream())
        {
            using (var ms = new MemoryStream())
            {
                int read;
                while ((read = input.Read(buffer, 0, buffer.Length)) > 0) 
                {
                    ms.Write(buffer, 0, read);
                }
                _streamHandler.HandleStream(ms.ToArray());
            }
        }
    }

    public void DoOption2_1()
    {
        _streamHandler.HandleStream(_streamProducer.GetStream());
    }

    public void DoOption2_2()
    {
        using (var stream = _streamProducer.GetStream())
        {
            _streamHandler.HandleStream(stream);    
        }
    }

    public void DoOption3()
    {
        _streamHandler.HandleStream(_streamProducer.GetStream);
    }
}

Answer 1

您可能没有意识到这一点，但您正在尝试实现 管道设计模式。作为起点，请考虑查看：

• MSDN: Pipelines
• Steve's Blog: Pipeline Design Pattern
• （其他好的参考资料？？）

关于您的实施，我建议您使用选项 #2：

public interface IStreamHandler
{
    void Process(Stream stream);
}

关于对象的生命周期，我认为：

• 实现应该在处理调用Dispose的方式上保持一致
• 如果 IStreamHandler 不调用 Dispose，您的解决方案将更加灵活（现在您可以像在 Unix 管道中一样将处理程序链接在一起）

第三方解决方案

构建管道解决方案可能很有趣，但同样值得注意的是，市场上有现有产品：

• Yahoo: Pipes
• Microsoft: BizTalk
• IBM: Cast Iron
• StackOverflow: Alternatives to Yahoo Pipes

附加说明

存在与您提出的选项 2 相关的设计问题：

void Process(Stream stream);

在Unix Pipes 中，您可以通过获取一个程序的输出并将其作为另一个程序的输入，将多个应用程序链接在一起。如果您要使用选项 2 构建类似的解决方案，如果您使用多个处理程序并且您的数据 Stream 仅转发（即 stream.CanSeek=False），则会遇到问题。

Answer 2

选项 2_2 是处理一次性资源的标准方式。

您的SomeTestClass 实例向生产者请求一个流 - 然后SomeTestClass 拥有一个流并负责清理。

选项 3 和 2_1 依赖不同的对象来清理 SomeTestClass 拥有的资源 - 可能无法满足此预期。

选项 1 只是将流的内容复制到另一个流 - 我认为这样做没有任何好处。