TCP网络流处理

Question

我通过各种TCP客户端各自的TCP套接字异步地服务它们。目前，我有三个任务同时运行：

1. 使用NetworkStream等待来自await StreamReader.ReadAsync()的数据
2. 使用NetworkStream将数据写入await StreamWriter.WriteAsync()
3. 定期发送看门狗消息

现在，当我这样说的时候：

var stream = new NetworkStream(_socket);

// reading task

using (var reader = new StreamReader(stream)) {
    // ...read...
}

底层NetworkStream在读取完成后最终被销毁，因为StreamReader在Dispose()上关闭了它。

最简单的方法是不关闭StreamReader，但是AFAIK --这是一个非常糟糕的主意。那么，如何在保持套接字连接打开的同时处理异步读写呢？

Answer 1

从.NET 4.5开始，如果查看StreamReader和StreamWriter的构造函数重载，就会有一个(目前只有一个)构造函数接受bool leaveOpen参数。使用这个重载并传递true -这样它就不会感觉到底层流的所有权了。

如果这在框架版本中不可用，那么您必须创建一个NonClosingStream : Stream，它使用pass实现来装饰流，除了Close()和Dispose()之外，这应该是无操作的(好吧，他们可以将null分配给表示包装流的字段，但仅此而已)。

Answer 2

由于StreamReader总是根据自己的处理方式处理底层流(这就是为什么实际上是 IDisposable)，所以在不再需要网络流之前，您确实不需要关闭它。

所以，这种情况是很好的：

var stream = new NetworkStream(_socket);
var reader = new StreamReader(stream);

当你完成的时候，你会关闭他们两个，对吗？

reader.Dispose();
stream.Dispose();