从 java 套接字读取字节：获取 ArrayIndexOutOfBounds

Question

我遇到了这个非常奇怪的问题：我有一个小程序可以从套接字读取字节； 每当我调试时，程序都运行良好；但每次我运行它（就像直接运行它），我都会收到 ArrayIndexOutOfBounds 异常。什么给了？我对套接字来说读得太快了吗？我错过了什么吗？

这是 main()：

public static void main(String[] args){

    TParser p = new TParser();

    p.init();

    p.readPacket(); 

    p.sendResponse();

    p.readPacket();

    p.sendResponse();

    p.shutdown();

}

init 方法是我创建用于读写的套接字的地方； 下一个方法（readPacket）是问题开始出现的地方；我将整个缓冲区读取到一个私有字节数组中，这样我就可以自由地操作数据；例如，根据数据上的某些字节，我设置了一些属性：

public void readPacket(){       

    System.out.println("readPacket");
    readInternalPacket();
    setPacketInfo();
}

private void readInternalPacket(){
    System.out.println("readInternalPacket");
    try {           
        int available=dataIN.available();           
        packet= new byte[available];    
        dataIN.read(packet,0,available);

        dataPacketSize=available;

    }
    catch (Exception e) {
        e.printStackTrace();
    }
}


private void setPacketInfo() {

    System.out.println("setPacketInfo");
    System.out.println("packetLen: " +dataPacketSize);

    byte[] pkt= new byte[2];
    pkt[0]= packet[0];
    pkt[1]= packet[1];

    String type= toHex(pkt);
    System.out.println("packet type: "+type);
    if(type.equalsIgnoreCase("000F")){
        recordCount=0;
        packetIterator=0;
        packetType=Constants.PacketType.ACKPacket;
        readIMEI();
        validateDevice();

    }
}

它中断的行是 pkt[1]= packet[1] 行

； (setPacketInfo)

意味着它当时只有 1 个字节...但是那怎么可能，如果我调试它时它运行得完美呢？我必须对套接字进行一些健全性检查吗？ （dataIN 的类型为 DataInputStream）

我应该将方法放在单独的线程上吗？我一遍又一遍地检查这个问题，甚至更换了我的内存模块（当我开始对此有奇怪的想法时）

......请帮助我。

Answer 1

我不知道周围的代码，尤其是 dataIN 的类，但我认为您的代码是这样做的：

int available=dataIN.available(); 根本不等待数据，仅返回有 0 个字节可用，

因此您的数组大小为 0，然后执行：

pkt[0]= packet[0]; pkt[1]= packet[1]; 超出范围。

我建议您至少循环直到 available() 返回您期望的 2 ，但我无法确定这是正确的 (* ) 或正确的 (* * ) 的方式来做到这一点，因为我不知道 dataIN 的类实现。

注意：(*) 如果 available() 可以单独返回 2 个字节，则这是不正确的。 (** ) 如果 dataIN 本身提供等待方法，则不是正确的方法。

Answer 2

难道从套接字读取数据是一个异步过程，并且在 packet[] 完全填满之前调用 setPacketInfo() 吗？如果是这种情况，它可能在调试时运行得很好，但当它真正在不同机器上使用套接字时运行得很糟糕。

您可以在 setPacketInfo() 方法中添加一些代码来检查 packet[] 变量的长度。

 byte[] pkt= new byte[packet.length];
 for(int x = 0; x < packet.length; x++)
 {
      pkt[x]= packet[x];
 }

不太确定为什么你甚至将 packet[] 变量复制到 pkt[] 中？

Answer 3

您在面向流的层上使用面向数据包的协议，而不传输真实的数据包长度。由于碎片，接收到的数据的大小可能小于您发送的数据包。

因此我强烈建议在发送实际数据包之前发送数据包大小。在接收方，您可以使用 DataInputStream 并使用阻塞读取来检测传入数据包：

private void readInternalPacket() {
    System.out.println("readInternalPacket");
    try {
        int packetSize = dataIN.readInt();
        packet = new byte[packetSize];
        dataIN.read(packet, 0, packetSize);
        dataPacketSize = packetSize;
    } catch (Exception e) {
        e.printStackTrace();
    }
}

当然，您还必须修改发送方，在数据包之前发送数据包大小。

Answer 4

添加到@eznme 的答案。您需要从基础流中读取数据，直到不再有待处理的数据。这可能需要一次或多次读取，但当 available 方法返回 0 时，将指示流结束。我建议使用 Apache IOUtils 将输入流“复制”到 ByteArrayOutputStream，然后从中获取 byte[] 数组。

在您的 setPacketInfo 方法中，您应该在获取协议头字节之前检查数据缓冲区长度：

byte[] pkt= new byte[2];
if((packet != null) && (packet.length >= 2)) {
    pkt[0]= packet[0];
    pkt[1]= packet[1];
    // ...
}

这将消除您在读取零长度数据缓冲区时遇到的越界异常你的协议。

Answer 5

您永远不应该依赖 dataIN.available()，并且 dataIN.read(packet,0,available); 返回一个整数，表示您收到了多少字节。该值并不总是与可用值相同，并且它也可能小于缓冲区的大小。

您应该这样阅读：

byte[] packet = new byte[1024];  //
dataPacketSize = dataIN.read(packet,0,packet.length);

您还应该将 DataInputStream 包装在 BufferedInputStream 中，并注意获得少于 2 个字节的情况，这样您就不会'不要尝试处理您尚未收到的字节。