如何停止从 NetworkStream 读取？

Question

我正在尝试从 NetworkStream 读取数据。我写下一段代码：

Imports System.Net
Imports System.Net.Sockets

Public Class Form1
    Dim tcpclnt1 As New TcpClient
    Dim streamTcp1 As NetworkStream
    Dim DataBuffer(1024) As Byte    'Buffer for reading
    Dim numberOfBytes As Integer
    ' event for reading data from stream
    Dim evtDataArrival As New AsyncCallback(AddressOf DataProcessing) 

    Private Sub Btn_Connect5000_Click(sender As Object, e As EventArgs)_
            Handles Btn_Connect5000.Click
        ' Connecting to server
        tcpclnt1 = New TcpClient   
        tcpclnt1.Connect("192.168.1.177", 5000)
        streamTcp1 = tcpclnt1.GetStream()   'Create stream for current tcpClient
        ' HERE WE START TO READ
        streamTcp1.BeginRead(DataBuffer, 0, DataBuffer.Length, evtDataArrival, Nothing) 

    End Sub

    Public Sub DataProcessing(ByVal dr As IAsyncResult)
        numberOfBytes = streamTcp1.EndRead(dr) 'END READ
        ' ...HERE SOME ROUTINE FOR PRINT DATA TO TEXTBOXES...
        'START NEW READING 
        streamTcp1.BeginRead(DataBuffer, 0, DataBuffer.Length, evtDataArrival, Nothing)
    End Sub

    Private Sub Btn_Disconnect5000_Click(sender As Object, e As EventArgs)_
            Handles Btn_Disconnect5000.Click
        ' Disconnect from port 5000. Close TcpClient
        streamTcp1.Dispose()
        streamTcp1.EndRead(Nothing) 'And here mistake appears !!!
        streamTcp1.Close()
        tcpclnt1.Close()
    End Sub
End Class

问题：我创建了新客户端和新流。据我了解，通过使用BeginRead，它开始在新线程中读取数据。所以为了实时数据，我在DataProcessing函数的末尾开始新的BeginRead。但是我在尝试断开连接时遇到了问题（查看Btn_Disconnect5000_Click 函数）：我尝试关闭流和客户端，但它仍然尝试在DataProcessing 方法中读取并告诉我：

无法访问已处置的对象

（感谢 djv 的正确翻译！）。

所以我想我需要先停止线程但不知道如何做到这一点：我尝试了Dispose() 方法，先尝试关闭流但仍然不能。我也尝试手动调用EndRead 方法，但无法理解我必须分配给它作为参数（参数）的内容。

Answer 1

只需关闭套接字而不调用EndRead。

正如微软文档所说，在您调用EndRead 时，您正在阻止套接字读取操作：

此方法阻塞，直到 I/O 操作完成。

另外，您在 EndRead 之前调用方法 Dispose，这释放了 Stream 使用的所有资源，这就是您出现该异常的原因。

考虑关闭套接字，这将释放套接字正在使用的所有资源，就像这样：

Private Sub Btn_Disconnect5000_Click(sender As Object, e As EventArgs)_
    tcpclnt1.Close()
End Sub

升级：考虑捕获方法DataProcessing 中的EndRead 异常。在您关闭套接字的那一刻，System.ObjectDisposedException 将被引发并且异常消息是无法访问已处置的对象。。发生这种情况是因为您在 EndRead 中阻塞了套接字，并且在调用 tcpclnt1.Close() 的那一刻，它被解除阻塞并释放套接字的所有资源（已释放）并引发异常。

所以你的DataProcessing 应该是这样的：

Public Sub DataProcessing(ByVal dr As IAsyncResult)
    Try
        numberOfBytes = streamTcp1.EndRead(dr) 'END READ
        ' ...HERE SOME ROUTINE FOR PRINT DATA TO TEXTBOXES...
        'START NEW READING 
        streamTcp1.BeginRead(DataBuffer, 0, DataBuffer.Length, evtDataArrival, Nothing)
    Catch ex As Exception
        System.Console.WriteLine(ex.Message)
    End Try

End Sub

Answer 2

EndRead 实际上并没有停止异步读取。它获取读取的字节数，结束当前读取操作并抛出操作期间可能发生的任何异常。因此调用它不会阻止进一步的异步操作发生。

我建议你在回调中插入一个空检查，而不是退出方法并阻止BeginRead被更多地调用。

Public Sub DataProcessing(ByVal dr As IAsyncResult)
    If streamTcp1 Is Nothing Then _
        Return 'Stream is disposed, stop any further reading.

    numberOfBytes = streamTcp1.EndRead(dr)

正如 the_lotus 所说，您可能还需要添加异常处理，因为如果您不够幸运，streamTcp1 可能会在通过 null 检查后被丢弃。

您应该在回调中检查流的原因是，正如我们所讨论的，在“关闭”TCP 连接后，它会进入CLOSE_WAIT、TIME_WAIT 或FIN_* 状态之一，以便操作系统可以仍然将延迟/重新传输的数据包映射到它。

NetworkStream.BeginRead() 最终调用WSARecv 在本机端注册一个异步操作，因此它不知道您的套接字是否被释放，因为它只关心连接是否处于活动状态（CLOSE_WAIT 和@ 987654332@ 连接仍被视为对操作系统处于活动状态）。即使套接字/流被释放，这也可能导致回调被调用。