2

我有一个通过 TCP 与设备通信的类。我发送命令，然后stream.Read(reply, 0, 1)在 TcpClient 的 GetStream() 上发出。我读出每个字节，然后将读取的字节组合成一个字符串，并将该字符串与终止字符串进行比较，让我知道何时停止读取。

设备软件存在一些缺陷，因此并不总是发送终止字符串。我想以适当的方式处理这个问题，并使用一段时间来确定是否应该停止读取。

如果我将 设置stream.ReadTimeout为 以外的其他-1值，则超过此超时时套接字将关闭，这是我不希望的。

如果我stream.BeginRead(..)与 a 一起使用，stream.ReadTimeout = -1那么我会在一段时间后吸干线程池。

可以构建什么智能解决方案来解决这个问题？

4

2 回答 2

2

你可以检查stream.DataAvailable()

如果 stram 中有可用数据：读取它，将读取的字节组合成一个字符串，并将该字符串与终止字符串进行比较。

如果没有终止字符串，则设置超时（您可以使用线程）并等待任何传入数据，如果没有新的传入数据将 ReadTimeout 设置为 1，否则读取新数据。

于 2012-06-13T11:51:07.527 回答
2

我设法使用stream.DataAvailable.

它是这样的：

do
{
    try
    {
        if (socket.Poll(socketTimeout, SelectMode.SelectRead))
        {
            socket.Receive(reply, 0, 1, SocketFlags.None);
        }
        else
        {
            throw new SocketException((int)SocketError.TimedOut);
        }
        replyString.Append(Encoding.ASCII.GetString(reply, 0, reply.Length));
        // Termination string logic...
    }
    catch (SocketException e)
    {
        // Check on e.SocketErrorCode if necessary.
        break;
    }

} while (!terminationReached);

在哪里socket = _tcpClient.Client;

编辑：
socket.Receive也会在超时时关闭套接字，socket.Poll但不会。 改为使用socket.Receive(..)而不是stream.Read(..).

于 2012-06-13T12:14:44.487 回答