2

我创建的应用程序有一些问题。一般情况（以下描述与问题不是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 = 默认（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);
    }
4

2 回答 2

0

此错误有多种原因，但最常见的是您写入的连接已被另一端关闭。换句话说，一个应用程序协议错误：你在一个永远无法使用的情况下写了一些东西。

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

于 2013-01-27T23:17:02.933 回答
0

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

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

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

于 2013-01-28T14:30:06.367 回答