我对这里发生的事情感到非常困惑。我一直在设置断点，但我似乎无法理解。基本上，我有一个客户端和一个服务器。我希望客户端发送两个单独的数据字符串。通过设置断点，我注意到我的客户实际上确实用适当的数据填充了两个字符串。但是，服务器永远不会看到第二个字符串。为什么会发生这种情况，我该如何解决？任何帮助都将不胜感激!下面是我的代码:

服务器:

    private static void HandleClientComm(object client)
    {
        /** creating a list which contains DatabaseFile objects **/
        List<DatabaseFile> theDatabase = new List<DatabaseFile>();

        TcpClient tcpClient = (TcpClient)client;
        NetworkStream clientStream = tcpClient.GetStream();

        StringBuilder response = new StringBuilder();
        byte[] message = new byte[4096];
        int bytesRead;

        do
        {
            bytesRead = 0;

            try
            {
                /*do
                {
                    bytesRead = clientStream.Read(message, 0, message.Length);
                    response.Append(Encoding.ASCII.GetString(message, 0, bytesRead));
                } while (clientStream.DataAvailable);*/

当我将此注释代码更改为 bytesRead = clientStream.Read(message, 0, 4096); 时，我收到如下 IOException 错误:无法将数据写入传输连接:现有连接被远程主机强行关闭。因此，我将其更改为 do while 循环。我如何绕过此 IOException 并接受第二个字符串？

                ASCIIEncoding encoder = new ASCIIEncoding();
                String file = encoder.GetString(message, 0, bytesRead);
                Menu.Insert(theDatabase, file); 
            }
            catch (Exception)
            {
                // A socket error has occured
                break;
            }

            if (bytesRead == 0)
            {
                // The client has disconnected from the server
                break;
            }
        } while (clientStream.DataAvailable);

        // Release connections
        clientStream.Close();
        tcpClient.Close();
    }

客户:

    static void Main(string[] args)
    {
        TcpClient client = new TcpClient();

        IPEndPoint serverEndPoint = new IPEndPoint(IPAddress.Parse("127.0.0.1"), 8888);

        client.Connect(serverEndPoint);

        NetworkStream clientStream = client.GetStream();
        NetworkStream clientStream2 = client.GetStream();

        ASCIIEncoding encoder = new ASCIIEncoding();
        ASCIIEncoding encoder2 = new ASCIIEncoding();
        String text = System.IO.File.ReadAllText("FirstNames.txt");
        String text2 = System.IO.File.ReadAllText("LastNames.txt");

        byte[] buffer = encoder.GetBytes(text);

        Console.ReadLine(); 
        clientStream.Write(buffer, 0, buffer.Length);
        clientStream.Flush();
        Console.ReadLine();

        byte[] buffer2 = encoder2.GetBytes(text2);

        clientStream2.Write(buffer2, 0, buffer2.Length);
        clientStream2.Flush();
        Console.ReadLine(); 
    }
}

最佳答案

客户端和服务器之间的通信是这样的(注意步骤的顺序只是为了说明目的，实际运行时的顺序可能会有所不同):

1. 客户端:client.Connect(serverEndPoint)
   服务器:HandleClientComm(newClient)

2. 客户端:clientStream.Write(buffer, 0, buffer.Length)
   服务器:bytesRead = clientStream.Read(message, 0, message.Length)
   请注意，Read 不能保证阅读整条消息。只返回到目前为止已收到的部分是完全可以的

3. 客户端:Console.ReadLine()
   服务器:while (clientStream.DataAvailable)
   流中没有数据 - 客户端尚未发送任何数据。即使没有 ReadLine 也可能会发生这种情况 - 在客户端再次发送数据之前有一个时间窗口

4. 服务器:tcpClient.Close()

5. 客户端:clientStream2.Write(buffer2, 0, buffer2.Length)
   您可以在此处获取异常，也可以不获取异常 - 取决于服务器是否已经关闭连接，在任何情况下服务器都不再读取。

您需要定义您自己的消息协议(protocol)，服务器和客户端都将遵守。例如，您可以让客户端在发送完成后关闭连接:

客户:

using (var client = new TcpClient("localhost", 8888))
using (var clientStream = client.GetStream())
{
    var buffer = Encoding.ASCII.GetBytes( File.ReadAllText("FirstNames.txt") );
    clientStream.Write(buffer, 0, buffer.Length);

    buffer = Encoding.ASCII.GetBytes( File.ReadAllText("LastNames.txt") );
    clientStream.Write(buffer, 0, buffer.Length);
}

服务器:

using (var tcpClient = (TcpClient)client)
using (var clientStream = tcpClient.GetStream())
{
    // Store everything that the client sends.
    // This will work if the client closes the connection gracefully
    // after sending everything

    var receivedData = new MemoryStream();
    clientStream.CopyTo(receivedData);

    var rawBytes = receivedData.ToArray();
    var file = Encoding.ASCII.GetString(rawBytes, 0, rawBytes.Length);

    Menu.Insert(theDatabase, file);
}

协议(protocol)很简单，可能足以满足您的情况。但是，它存在一些应该在生产代码中解决的问题(例如，如果客户端发送过多数据、耗尽服务器内存会怎样、如果客户端在不关闭连接的情况下停止发送会怎样等等)

关于C# 客户端/服务器问题，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/7523281/