客户端关闭时，NetworkStream 在 Read() 上引发异常

Question

我创建的应用程序出现了一些问题。一般情况（以下描述与问题不是1-1相关的）：我有一个WCF客户端-服务器应用程序，用于在多个站点收集数据。客户端检索本地数据（一些文件等），将其发送到数据中心的服务器，该服务器对其进行处理。客户端从本地主机获取其大部分数据，但其中一些是从 LAN 上的不同服务器检索的。这是我的问题开始的地方。我必须创建一个将数据发送到指定客户端的第三个应用程序。在这篇文章的提醒中，我将客户端和服务器称为同一 LAN 上的应用程序（而不是上面数据中心中的服务器）

我尝试使用命名管道，它在同一主机上的进程间非常出色，但服务器到服务器的速度非常慢。 （如果有人知道为什么会这样，请不要犹豫告诉我。一些测试高达 1000 毫秒，发送和接收仅几个字节）

所以我开始使用 TcpClient 类。测试显示响应比 NP 等效项快得多，因此我决定使用此选项。

现在，当客户端和服务器都按应有的方式启动和结束时，一切都很好。当服务器启动，客户端已经连接，服务器正在等待它的 stream.Read() 方法，然后客户端应用程序退出时，问题就出现了：

Unable to read data from the transport connection: De externe host heeft een verbinding verbroken.（第二部分翻译：一个现有的连接被远程主机强行关闭。）

目前我用 Try-Catch 语句包装了整个部分，在 IoException 上重新启动了整个部分。这确实有效，但是当我阅读了几篇关于“异常应该是异常的东西！”的帖子时，感觉不太好。

所以最后的问题是：如何避免这个异常？ （在现实生活中保持服务器和客户端应用程序之间连接的正常方式是什么？）

服务器 TcpListener serverSocket = new TcpListener(System.Net.IPAddress.Any, 8888); TcpClient clientSocket = default(TcpClient);

        while (true)
        {
            serverSocket.Start();
            clientSocket = serverSocket.AcceptTcpClient();

            while ((true))
            {
                try
                {
                    NetworkStream networkStream = clientSocket.GetStream();
                    byte[] bytesFrom = new byte[10025];
                    networkStream.Read(bytesFrom, 0, (int)clientSocket.ReceiveBufferSize);//THIS THROWS THE EXCEPTION WHEN A CLIENT QUITS
                    string dataFromClient = System.Text.Encoding.ASCII.GetString(bytesFrom);
                    dataFromClient = dataFromClient.Substring(0, dataFromClient.IndexOf("$"));
                    Console.WriteLine(" >> Data from client - " + dataFromClient);
                    string serverResponse = "Server response " + DateTime.Now.ToString("HH:mm:ss,fff");
                    Byte[] sendBytes = Encoding.ASCII.GetBytes(serverResponse);

                    int len = sendBytes.Length;
                    networkStream.WriteByte((byte)(len / 256));
                    networkStream.WriteByte((byte)(len & 255));

                    networkStream.Write(sendBytes, 0, sendBytes.Length);
                    networkStream.Flush();
                }
                catch (System.IO.IOException ex)
                {
                    Console.WriteLine(ex.ToString());
                    break;
                }

            }
            clientSocket.Close();
            serverSocket.Stop();
        }
    }

客户

System.Net.Sockets.TcpClient clientSocket = new System.Net.Sockets.TcpClient();


    private void button2_Click(object sender, EventArgs e)
    {
        NetworkStream serverStream = clientSocket.GetStream();
        byte[] outStream = System.Text.Encoding.ASCII.GetBytes("Message from Client$");
        serverStream.Write(outStream, 0, outStream.Length);
        serverStream.Flush();
        int len = serverStream.ReadByte() * 256;
        len += serverStream.ReadByte();

        byte[] inStream = new byte[len];
        serverStream.Read(inStream, 0, len);
        string returndata = System.Text.Encoding.ASCII.GetString(inStream);
        msg("Data from Server : " + returndata);
    }

    private void button1_Click_1(object sender, EventArgs e)
    {
        clientSocket.Connect("127.0.0.1", 8888);
    }

Answer 1

我对@9​​87654321@ API 的理解是，您应该在完成发送后调用Shutdown(Write)。然后，读取直到流返回 0。这意味着对方也调用了Shutdown。

只有在您关闭写入（使用Shutdown）并收到零长度读取之后，通信才真正在线上完成。现在 Dispose Socket 现在已经不存在了。

这样，只有在发生网络错误或错误时才会出现异常。在这种情况下，您可能应该丢弃当前的“事务”并重新启动它。

Answer 2

这个错误有几个原因，但最常见的是你写了一个已经被另一端关闭的连接。换句话说，一个应用程序协议错误：你写的东西是在它永远不会被使用的情况下写的。

如果您编写了两端，另一种有点遥远的可能性是您将客户端编码为由于某种原因中止关闭。基本上你不应该那样做。