首页 文章

c#源数组不够长 . 检查srcIndex和length,以及Array.Copy的数组下限

提问于
浏览
4

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

1)数据包标头 - 44字节此标头大小不会更改,并随每个数据包一起提供 . 2)在报头出现多于1个数据包之后,这些数据包的大小为16或32字节 . 这些数据包的数量随着从客户端到服务器的每个数据包而变化,并且这些数据包的数量决定了数据包的总大小(238或512) . 3)最后2个字节是crc,它也是固定的,不会改变 .

我的服务器从客户端接收数据包并从主数据包中分离数据包,解析它们并将其写入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和长度,并且数组的下限”被抛出到行

Array.Copy(pkt,ind,pass_packet,0,size);

'size'值突然跃升至4096

堆栈跟踪如下

在System.Array.Copy(数组sourceArray,Int32 sourceIndex,数组destinationArray,Int32 destinationIndex,Int32长度,布尔值可靠)处于Packet_parsing的System.Array.Copy(Array sourceArray,Int32 sourceIndex,Array destinationArray,Int32 destinationIndex,Int32 length) WindowsFormsApplication1中的.client_pkt_parsing.data_pkt_func(Int32 ind,Int32 size,String code_packet,Byte [] pkt,String file1):WindowsFormsApplication1中的Datapackparser(Byte []数据包,Int32 input_length,Int32 indexno,Socket sk)中的第357行\ _ packet_parser.cs:位于WindowsFormsApplication1.Form1.Listeners()的行847,位于\ WindowsFormsApplication1 \ Form1.cs:第385行,位于System.Threading.ThreadStart_Context(对象状态),位于System.Threading.ExecutionContext.Run(ExecutionContext executionContext,ContextCallback) System.Thread上的System.Threading.ExecutionContext.Run(ExecutionContext executionContext,ContextCallback回调,对象状态)中的回调,对象状态,布尔ignoreSyncCtx) ing.ThreadHelper.ThreadStart()

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

2 回答

  • 1

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

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

  • 1

    好的,我发现问题出在客户端 . 由于客户端的一些错误,客户端在正确发送10-12个数据包后正在向数据包添加额外的0 . 我没有访问客户端,我根据给出的规范对服务器进行了编码,因此我不知道错误,客户端开发人员也不知道这个错误 . 感谢所有答案 .

相关问题