向服务器发送多条消息？ C#

Question

我有一个快速而肮脏的问题。就目前情况而言，我有两个客户端和一个服务器正在运行。我可以毫无问题地从客户端向服务器传送消息。当我想从客户端读取两条消息而不是一条消息时，我的问题就出现了。

我收到的错误是：IOException 未处理。无法从传输连接读取数据：现有连接被远程主机强制关闭。

这是我在服务器端的代码：

private static void HandleClientComm(object client) { /** 创建一个包含 DatabaseFile 对象的列表 **/ 列出数据库 = new List();

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

        byte[] message = new byte[4096];
        int bytesRead;

        do
        {
            bytesRead = 0;

            try
            {
                // Blocks until a client sends a message                    
                bytesRead = clientStream.Read(message, 0, 4096);
            }
            catch (Exception)
            {
                // A socket error has occured
                break;
            }

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

            // Message has successfully been received
            ASCIIEncoding encoder = new ASCIIEncoding();

            Console.WriteLine("To: " + tcpClient.Client.LocalEndPoint);
            Console.WriteLine("From: " + tcpClient.Client.RemoteEndPoint);
            Console.WriteLine(encoder.GetString(message, 0, bytesRead));


            if (encoder.GetString(message, 0, bytesRead) == "OptionOneInsert")
            {
                byte[] message2 = new byte[4096];
                int bytesRead2 = 0;

                **bytesRead2 = clientStream.Read(message, 0, 4096);** //ERROR occurs here!

                Console.WriteLine("Attempting to go inside insert)");
                Menu.Insert(theDatabase, bytesRead2); 
            }

这是我的客户端代码：

        ASCIIEncoding encoder = new ASCIIEncoding();
        byte[] buffer = encoder.GetBytes("OptionOneInsert");

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

        NetworkStream clientStream2 = client.GetStream();
        String text = System.IO.File.ReadAllText("FirstNames.txt");
        clientStream2.Write(buffer, 0, buffer.Length);
        clientStream2.Flush();
        ASCIIEncoding encoder2 = new ASCIIEncoding();

        byte[] buffer2 = encoder2.GetBytes(text);
        Console.WriteLine("buffer is filled with content"); 
        Console.ReadLine();

当客户端发送消息“optionOne”时，服务器会很好地接收它。只有当我尝试发送名为“text”的字符串时，才会出现问题！

任何帮助将不胜感激 - 我不太熟悉套接字，因此我现在一直在努力尝试理解这一点

Answer 1

这里有一个大问题 - 没有任何内容可以指定一条消息的结束和另一条消息的开始。服务器很可能会一次性收到两条消息，或者先收到一半消息，然后再收到另一半。

避免这种情况的最简单方法是在每条消息中添加字节数作为前缀，例如采用固定的四字节格式。因此，要发送消息，您需要：

• 将其从字符串编码为字节（最好使用 UTF-8 而不是 ASCII，除非您确定永远不需要任何非 ASCII 文本）
• 写出字节数组的长度作为四字节值
• 写出内容

在服务器上：

• 读取四个字节（必要时循环 - 不能保证您甚至会一起读取这四个字节，尽管您几乎肯定会这样做）
• 转换四个字节转换成一个整数
• 分配一个字节数组该大小
• 循环，从“当前位置”读取到缓冲区末尾，直到填满缓冲区
• 将缓冲区转换为字符串

另一种选择是简单地使用 BinaryReader 和 BinaryWriter - ReadString 和 WriteString 使用长度前缀，诚然，形式略有不同。

您可以使用的另一种选择是使用分隔符（例如回车符），但这意味着如果您需要在要传输的文本中包含分隔符，则需要添加转义符。