我正在编写一个基本的 TCP/IP 服务器来接收来自现有客户端的消息。目前，我能够接收单缓冲区和多缓冲区消息。当客户端发送一组多条消息时，问题就来了。它不是将每条消息作为单个通信发送，而是希望流打开并且集合中的所有消息在流再次关闭之前一个接一个地发送。我在下面的编辑代码段中对此进行了编码:

private void AcceptMessage(IAsyncResult ar)
{
    String receivedMessage = "";

    //  Only run if the server is listening. Otherwise, an exception will be thrown.
    if (isListening)
    {
       ASCIIEncoding encoder = new ASCIIEncoding();
       try
       {
           TcpListener listener = (TcpListener)ar.AsyncState;
           using (TcpClient client = listener.EndAcceptTcpClient(ar))
           using (NetworkStream stream = client.GetStream())
           {
               int bytesRead;
               int totalBytes = 0;
               stream.ReadTimeout = ReadTimeout;
               do
               {
                   byte[] receivedBytes = new byte[BufferSize];
                   StringBuilder message = new StringBuilder();
                   bytesRead = 0;
                   do
                   {
                       try
                       {
                           if (stream.CanRead)
                           bytesRead = stream.Read(receivedBytes, 0, BufferSize);
                       }
                       catch (...Exception Handling...)

                       if (bytesRead == 0)
                           break;

                       message.Append(encoder.GetString(receivedBytes, 0, bytesRead));
                       totalBytes += bytesRead;
                   } while (bytesRead == BufferSize);     //  Allow for multiple buffers in a single message
                   byte[] ack = encoder.GetBytes(GetAck(message.ToString(), ackNak, status, statusMessage));
                   stream.Write(ack, 0, ack.Length);
                   ...Message Processing...
               } while (stream.DataAvailable);         //  Allow for multiple messages                        
           }
       }
       catch (...Error Handling...)
       finally { ...Cleanup...}
   }
}

问题出在第二个 while (stream.DataAvailable); 检查发生时，DataAvailable 在发送一组消息时显示 false，但是如果我在下一行打断，它将显示真实。换句话说，它是在数据可用之前检查数据是否可用。我可以通过在检查是否有更多消息之前添加一秒延迟来解决此问题，但在 100 例中的​​ 99 例中，这将是不必要的延迟。由于客户端一次只能发送一条消息(或一组消息)，因此在繁忙时间可能会增加大量接收消息的时间。

是否有更好的方法来确定是否有更多待处理的消息(无需客户端修改)？谢谢!

编辑

我更改了代码以包含建议。我添加了超时，并将第一次检查从 stream.DataAvailable 更改为 bytesRead == BufferSize。我无权访问客户端软件，因此无法添加 EOM 传输。我也不能保证多条消息是在单个流中发送还是在多个单独的流中发送。我仍然没有弄清楚如何判断是否有更多消息待处理。我不能让流保持打开状态，因为那样会阻止下一次传输。

我将 Elgonzo 标记为答案，因为他帮助解决了我问题的大部分问题。它仍然没有回答如何判断是否有待处理的消息，这可能是不可能的，但我的经理决定一旦连接打开，我们应该将其作为专用连接保持打开状态。这是可行的，因为我们的监听器仅通过具有一致流量的内部安全网络与单个设备通信。如果在一定时间内没有事件，我们将添加超时以断开连接。

最佳答案

数据是否可用以及数据在服务器端传入的速度(和周期性)不仅取决于客户端的时间/行为，还取决于网络/互联网的速度和延迟因素之间的联系(这本身取决于许多未知因素)。

因此，您不能在外层 while 循环中使用 stream.DataAvailable 来检查是否有更多数据进入。您可能必须在 NetworkStream 上设置 ReadTimeout 才能知道客户端何时完成/断开连接。

此外，最好在客户端即将结束其连接时实现由客户端发送的特定信号/消息，而不仅仅是依赖超时。这将帮助您解决不清楚问题的原因是服务器还是客户端中的错误，或者问题是否由网络连接问题引起的问题。

这个问题的答案中的实现细节(虽然应用场景不同，做法是一样的):Reading from closed NetworkStream doesn't cause any exception

此外，即使是你的内部 while 循环也可能在糟糕/缓慢的网络连接上失败，并且可能让你从客户端接收到部分消息，只是因为 stream.DataAvailable 在下一个数据包之前可能会暂时为假(继续当前消息)将收到...

关于c# - NetworkStream.DataAvailable 更新缓慢，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/20527137/