如何通过tcp/ip协议发送包的长度

Question

我正在为我的一个学校项目这样做。我正在尝试设计一个多线程服务器，它接受客户端使用数据库（添加、删除记录等）。当我将客户端连接到服务器时，我想接收数据库中的所有学生。

我访问服务器端的数据库并将信息存储在 ArrayList 中，我试图通过网络发送它。我对 XMLserializing 没有任何了解，所以我尝试将 arrayList 中的每个字符串发送到客户端。当我从服务器发送数据时，我有时会同时收到所有数据，有时则不会，所以我的第一个猜测是我必须将发送的数据分成一定长度的包。我不知道如何在包的开头添加长度。难道不是同一件事吗？也许我得到了正确的长度，也许我没有。

这是我的代码；我还没有尝试发送每个包裹的长度，因为我不知道如何发送。我尝试从服务器发送数组列表的长度，并从网络流中读取多次，但它不起作用（我在一个包中接收所有数据）。

服务器端：

private void HandleClient(object client)
    {
        try
        {
            ClientNo++;

            TcpClient tcpClient = (TcpClient)client;
            NetworkStream clientStream = tcpClient.GetStream();
            byte[] bytes = new byte[4096];
            int i;
            // Robot r = new Robot();
            Protocol p = new Protocol();
            ArrayList ListaStudentiResponse = p.ExecuteQueryOnStudents("select * from studenti");
            byte[] Length = new byte[4];
            Length = System.Text.Encoding.ASCII.GetBytes(ListaStudentiResponse.Count.ToString());
            clientStream.Write(Length, 0, Length.Length);
            foreach ( String s in ListaStudentiResponse)
            {

                byte[] data = System.Text.Encoding.ASCII.GetBytes(s);
                clientStream.Write(data, 0, data.Length);

            }


            tcpClient.Close();
            ClientNo--;
        }
        catch (Exception ex)
        {
            Console.WriteLine(ex.Message);
        }

    }

客户端：

private void connectToServerToolStripMenuItem_Click(object sender, EventArgs e)
    {
        tcpclient = new TcpClient();

        NetworkStream netStream;
        try
        {
            tcpclient.Connect("localhost", 8181);
            netStream = tcpclient.GetStream();
            Byte[] bytes = new Byte[10000];
            int readBytes = netStream.Read(bytes, 0, bytes.Length);
             int Length  =Int32.Parse(Encoding.ASCII.GetString(bytes, 0, readBytes));
             MessageBox.Show(Length.ToString());
             int i = 0;
             while (i < Length)
             {
                i++;
                Byte[] b = new Byte[10000];
                readBytes = netStream.Read(bytes, 0, bytes.Length);
                String response = Encoding.ASCII.GetString(b, 0, readBytes);
                MessageBox.Show(response);


             }

        }
        catch (Exception ex)
        {
            MessageBox.Show(ex.Message);
        }

    }
}

Answer 1

您可以使用 StateObject 来跟踪数据有多大，然后在 ReadCallback 期间进行测试以查看是否拥有“全部”消息。如果您没有收到所有消息，则可以使用当前的 StateObject 再次调用 BeginRecieve。

这是一个不错的例子：http://www.csharphelp。 com/2007/02/asynchronous-server-socket-using-c/

Answer 2

这就是我一直在使用的：

如何在 SocketAsyncEventArgs 对象上使用缓冲区< /a>

查看已接受的答案。首先，这是使用比异步更高效的调用完成端口。其次，我发现通过查看e.SocketError来找出失败的确切原因非常容易排除故障。

其工作原理是，要发送消息，请在消息中附加标头和标尾。
因此，当它收到消息时，它会检查是否收到预告片。如果未收到预告片，它将继续为该客户端接收消息，并将收到的消息附加到 stringBuilder 对象。收到预告片后，只需调用 stringbuilder.toString() 即可获取全部内容。