我已经实现了多个客户端和服务器.客户端以2分钟的固定间隔向服务器发送大小为238或564的tcp数据包.数据包的结构如下

1) Packet header — 44 bytes
This header size doesn’t change and comes with every packet.

2) After header comes more than 1 data packets and these data packets are of size 16 or 32 bytes. The number of these data packets changes with every packet coming from client to server and number of these data packets decide total size of packet (238 or 512).

3) Last 2 bytes are crc which is also fixed and doesn’t change.

我的服务器从客户端接收数据包并从主数据包中分离数据包,解析它们并将其写入excel文件.以下是我的代码

服务器代码

private void createserver(int no_of_clients)
    {
        tcpListener = new TcpListener(ipAddress, Globals.port_number);
        tcpListener.Start();

        for (int i = 0; i < no_of_clients; i++)
        {
            Thread newThread = new Thread(new ThreadStart(Listeners));
            newThread.Start();
        }
    } //End of createserver();

public void Listeners()
    {
        Socket socketForClient;

            socketForClient = tcpListener.AcceptSocket();



        if (socketForClient.Connected)
        {
            NetworkStream networkStream = new NetworkStream(socketForClient);

            int stream_size = 0;
            while (true)
            {
                byte[] raw_stream = new byte[1024];

                do
                {
                    try
                    {
                        stream_size = networkStream.Read(raw_stream, 0, 1024);
                    }
                    catch (IOException e)
                    {
                        if (e.InnerException is SocketException)
                        {
                            MessageBox.Show("The client has disconnected");
                            foreach (Socket s in active_clients)
                            {
                                if (s == socketForClient)
                                {
                                    MessageBox.Show(string.Format("Client {0} has forcibly exited", s.RemoteEndPoint));
                                    infoBox1.Text = infoBox1.Text + "\r\n" + string.Format("Client {0} has forcibly exited", s.RemoteEndPoint);
                                }
                            }
                        }
                        return;
                    }
                }
                while (networkStream.DataAvailable);

                byte[] input_data = new byte[stream_size];
                byte[] input_data1 = new byte[stream_size];
                Array.Copy(raw_stream, 0, input_data, 0, stream_size);

                if (Encoding.ASCII.GetString(input_data) != Globals.exit_code)
                {
                  Datapackparser(input_data, input_data.Length, 0, socketForClient);
                }
         }
      }

public static void Datapackparser(byte[] packet, int input_length, int indexno, Socket sk))
    {
        //remove header and crc from end of packet since I know every time it will be same                     

          // for separating data packets and parsing them on basis of packet id which comes with every individual data packets 

            data_pkts_index = 44; // since data packets start at 44. 0-43 is header
            int size_1_data_pkts = 0;
            string pkt_ids = "";

            while (data_pkts_index < tcp_pkt_size - 2)
            {
                // first 2 bytes of each data packet is size of that data packet 16 or 32
                size_1_data_pkts = Convert.ToInt32(string.Format(BitConverter.ToString(packet, data_pkts_index + 1, 1) +
                    BitConverter.ToString(packet, data_pkts_index, 1)), 16);
                // next 1 byte is packet id of each data packet on basis of which I parse them
                pkt_ids = Convert.ToInt32(packet[data_pkts_index + 2]).ToString("X");
                // this function is for parsing each data packet
                data_pkt_func(data_pkts_index, size_1_data_pkts, pkt_ids, packet, imei);
                data_pkts_index = data_pkts_index + size_1_data_pkts;time it will be same.

           }
       }

 static private void data_pkt_func(int ind, int size, string code_packet, byte[] pkt, string file1)
    {
        byte[] pass_packet = new byte[size];
        Array.Copy(pkt, ind, pass_packet, 0, size);

        if (code = "a")
        { // one type of packet
        }
        else if (code = "dsd")
        { // 2nd type of packet
        }
        else if ......
        {
         }
       // like this their are 8-9 types of data packet
    }

我面临的问题是这段代码能够在一定程度上正确解析数据包.例如,服务器接收的前10-11个数据包被正确解析但在那个异常之后“源数组不够长.检查srcIndex和长度,并且数组的下限”被抛出到行

06001

‘size’值突然跃升至4096

堆栈跟踪如下

at System.Array.Copy(Array sourceArray, Int32 sourceIndex, Array destinationArray, Int32 destinationIndex, Int32 length, Boolean reliable)

at System.Array.Copy(Array sourceArray, Int32 sourceIndex, Array destinationArray, Int32 destinationIndex, Int32 length)

at Packet_parsing.client_pkt_parsing.data_pkt_func(Int32 ind, Int32 size, String code_packet, Byte[] pkt, String file1) in WindowsFormsApplication1\packet_parser.cs:line 357

at Datapackparser(Byte[] packet, Int32 input_length, Int32 indexno, Socket sk) in WindowsFormsApplication1\packet_parser.cs:line 847

at WindowsFormsApplication1.Form1.Listeners() in \WindowsFormsApplication1\Form1.cs:line 385

at System.Threading.ThreadHelper.ThreadStart_Context(Object state)

at System.Threading.ExecutionContext.Run(ExecutionContext executionContext, ContextCallback callback, Object state, Boolean ignoreSyncCtx)

at System.Threading.ExecutionContext.Run(ExecutionContext executionContext, ContextCallback callback, Object state)

at System.Threading.ThreadHelper.ThreadStart()

所以任何人都可以帮我解决这个错误？

最佳答案 您是否在十六进制编辑器中查看了数据包,以查看数据包中的数据包大小是否正确写入？我将首先捕获异常并将数据包转储到文件中以供进一步检查.

另外,你确定你的号码解析代码是对的吗？第一个“Convert.ToInt32”行是复杂的,我找不到任何文档列出“Convert.ToInt32”作为两个参数.我怀疑如果您修复该行,您将解决问题.