0

我编写了一个监听端口并接收一些数据包的应用程序，根据我的自定义协议，数据包是 49 字节到 1500 字节，我可以从数据包中的数据长度看出。我应该解释和处理 49 字节数据包和更大数据包中的数据的方式是不同的。

问题是，当我收到小于 1374 字节的数据包时，一切正常，但是当数据包长度变长时，我收到以下异常，并且我还丢失了数据的最后 4 个字节（我已经使用 1384 字节数据包进行了测试，我丢失最后 4 个字节）

引发的异常：索引超出范围。必须是非负数且小于集合的大小。参数名称：startIndex

每个 49 字节的数据包有 35 字节的数据，更大的数据包的数据长度是不确定的（因为压缩）。

我发现有时最后 4 个字节位于单独的“字节”和“结果”变量中，这意味着它们被视为新数据包，并且没有附加到它们所属的数据包上。

这是接收数据的代码：

TcpClient Client = obj as TcpClient;
        EndPoint ep = Client.Client.RemoteEndPoint;
        List<Byte> result = new List<byte>();
        result.Capacity = 2000;
        try
        {


            NetworkStream stream = Client.GetStream();
            int i = 49;
            while ((i = stream.Read(bytes, 0,49)) != 0)
            {

                for (int id = 0; id < i; id++)
                {
                    result.Add(bytes[id]);
                }
//reading data length to determine packet length
                byte[] tmp = new byte[2];
                tmp = BitConverter.GetBytes(BitConverter.ToUInt16(result.ToArray(), 9));
                if (BitConverter.IsLittleEndian)
                {
                    Array.Reverse(tmp);
                }
                Int16 l = BitConverter.ToInt16(tmp, 0);
                if (l>35)
                {
                    stream.Read(bytes, result.Count, l - 35);
                    for (int id = 49; id <((l-35)+49); id++)
                    {
                        result.Add(bytes[id]);
                    }
                    if (this.TCPDataReceivedHandler != null)
                    {
                        this.TCPDataReceivedHandler(ep, result.Count, result.ToArray());
                        result.Clear();
                        Array.Clear(bytes, 0, 2000);
                        result.Capacity = 2000;
                    }
                }
                else
                {
                    if (this.TCPDataReceivedHandler != null)
                    {
                        this.TCPDataReceivedHandler(ep, result.Count, result.ToArray());
                        result.Clear();
                        Array.Clear(bytes, 0, 2000);
                        result.Capacity = 2000;
                    }
                }


            }
            System.Diagnostics.Debug.WriteLine("client Close");
            Client.Close();

        }
        catch (System.Exception ex)
        {
            throw ex;
        }
        finally
        {
            Client.Close();
            this.clients.Remove(Client);
        }

根据 Greg Suggestion 和我的研究，我也尝试使用以下方法：

NetworkStream stream = Client.GetStream();
            int bytesread = 0, OffsetTemp = 0;

            while (stream.CanRead)
            {
                OffsetTemp = 0;

                bytesread += stream.Read(bytess, OffsetTemp, 11);
                OffsetTemp = OffsetTemp + 11;



                byte[] tmp = new byte[2];
                tmp = BitConverter.GetBytes(BitConverter.ToUInt16(bytess.ToArray(), 9));
                if (BitConverter.IsLittleEndian)
                {
                    Array.Reverse(tmp);
                }
                Int16 l = BitConverter.ToInt16(tmp, 0);

                bytesread += stream.Read(bytess, OffsetTemp++, 11 + l + 3);
                for (int id = 0; id < l + 14; id++)
                {
                    result.Add(bytess[id]);
                }

                if (this.TCPDataReceivedHandler != null)
                {
                    this.TCPDataReceivedHandler(ep, result.Count, result.ToArray());
                    result.Clear();
                    Array.Clear(bytess, 0, 2000);
                }

            }
4

1 回答 1

0

使用 TCP 时，您必须记住，您放入的数据块的大小不能保证与您在接收端取出的数据块的大小相同。TCP 是一种流协议，因此它保证相同的字节以与发送的顺序相同的顺序到达另一端（如果不是，则套接字连接将被重置）。TCP 在对 的调用之间不维护任何类型的块边界send()，并且块可以根据网络条件任意拆分或合并。

您的接收器必须准备好从对 的调用中接收任何数量的数据stream.Read()，但您的代码似乎没有这样做。例如，即使一次stream.Read()只接收一个字节，正确编写的接收器代码也应该继续正常工作。

于 2012-10-14T18:53:06.867 回答