C# Tcp 正在丢失数据包？

Question

我编写了一个 C# 聊天软件，它使用了一个新的（至少对我而言）系统，我称之为请求系统。我不知道以前是否已经创建过，但现在我认为它是我的创作：P

无论如何，这个系统是这样工作的：

1. soc收到信号
2. 检查信号
3. 如果刚刚收到的数据是数字2，客户端软件就知道服务器要发送聊天消息了。如果数字是3，则客户端知道服务器即将发送成员列表，依此类推。

问题是这样的：当我在 VS2012 中逐步执行时，它工作正常，聊天工作正常。当我在调试模式下使用它或只是在我的桌面上运行它时，似乎缺少数据，这不应该是因为代码运行良好......

客户端收发消息代码示例：

    public void RecieveSystem()
    {
        while (true)
        {
            byte[] req = new byte[1];
            soc.Receive(req);
            int requestID = int.Parse(Encoding.UTF8.GetString(req));
            if (requestID == 3)
            {
                byte[] textSize = new byte[5];
                soc.Receive(textSize);
                byte[] text = new byte[int.Parse(Encoding.UTF8.GetString(textSize))];
                soc.Receive(text);
                Dispatcher.Invoke(() => { ChatBox.Text += Encoding.UTF8.GetString(text) + "\r\n"; });
            }
        }
    }

    public void OutSystem(string inputText)
    {
        byte[] req = Encoding.UTF8.GetBytes("3");
        soc.Send(req);
        byte[] textSize = Encoding.UTF8.GetBytes(Encoding.UTF8.GetByteCount(inputText).ToString());
        soc.Send(textSize);
        byte[] text = Encoding.UTF8.GetBytes(inputText);
        soc.Send(text);
        Thread.CurrentThread.Abort();
    }

在服务器上：

    public void UpdateChat(string text)
    {
        byte[] req = Encoding.UTF8.GetBytes("3");
        foreach (User user in onlineUsers)
            user.UserSocket.Send(req);
        byte[] textSize = Encoding.UTF8.GetBytes(Encoding.UTF8.GetByteCount(text).ToString());
        foreach (User user in onlineUsers)
            user.UserSocket.Send(textSize);
        byte[] data = Encoding.UTF8.GetBytes(text);
        foreach (User user in onlineUsers)
            user.UserSocket.Send(data);
    }
           public void RequestSystem(Socket soc)
        {
~~~
                    }
                    else if (request == 3)
                    {
                        byte[] dataSize = new byte[5];
                        soc.Receive(dataSize);
                        byte[] data = new byte[int.Parse(Encoding.UTF8.GetString(dataSize))];
                        soc.Receive(data);
                        UpdateChat(Encoding.UTF8.GetString(data));
                    }
                }
                catch
                {
                    if (!soc.Connected)
                    {
                        Dispatcher.Invoke(() => { OnlineMembers.Items.Remove(decodedName + " - " + soc.RemoteEndPoint); Status.Text += soc.RemoteEndPoint + " Has disconnected"; });
                        onlineUsers.Remove(user);
                        Thread.CurrentThread.Abort();
                    }
                }
            }
        }

可能是什么问题？

Answer 1

您假设每次Send 调用都会收到一个数据包。那不是面向流的——那是面向数据包的。您正在发送我怀疑已合并为一个数据包的多条数据，然后您将在一个 Receive 调用中将它们全部获取。 （即使涉及多个数据包，单个Receive 调用仍然可以接收所有数据。）

如果您使用的是 TCP/IP，您应该以更加面向流的方式进行思考。我还鼓励您更改协议的设计，这至少可以说很奇怪。在每条消息之前使用长度前缀很好，但是当两台计算机之间的二进制连接非常好时，为什么还要将其编码为文本呢？

我建议您查看BinaryReader 和BinaryWriter：使用TcpClient 和TcpListener 而不是Socket（或至少使用NetworkStream），并使用读取器/写入器对使其更容易读取和写入数据片段（有效负载或原语，如消息长度）。 （BinaryWriter.Write(string) 甚至为您执行长度前缀，这让事情变得容易多了。）