Java通过套接字发送字节[] ...读取的长度错误

Question

对于我的家庭作业，我有一个节点网络，它们相互传递消息。每个节点都连接到一定数量的其他节点（我使用 4 个进行测试）。每个链接都有一个权重，所有节点都计算了它们希望如何发送消息的最短路径。发送的每个数据包都由消息协议（硬编码的 int）、一个整数（表示有多少消息通过发送节点）以及数据包的路由路径组成。

每个节点的每个链接都有一个线程。每个 Link 中都有一个活动的 Socket。通过在消息的开头添加一个 4 字节的 int 来发送数据包，以告知消息的长度。

在我对网络施加压力之前，一切正常。对于我的测试，有 10 个节点，我让其中 5 个在没有 Thread.sleep() 的简单 while() 循环中发送 10000 个数据包。无一例外，在 if(a!=len) 语句执行过程中，总会出现错误。

如果我能澄清任何事情，请告诉我。提前致谢！这是代码（来自链接线程；send() 和 forward() 是从节点本身调用的）：

protected void listen(){
    byte[] b;
    int len;
    try{
        DataInputStream in = new DataInputStream(sock.getInputStream());
        while(true){
            len = in.readInt();
            b = new byte[len];
            int a = in.read(b,0,len);
            if(a!=len){
System.out.println("ERROR: " + a + "!=" + len);
                throw new SocketException(); //may have to fix...this will happen when message is corrupt/incomplete
            }
            Message m = new Message(b);
            int p = m.getProtocol();
            switch (p){
                case CDNP.PACKET:
                    owner.incrementTracker();
                    System.out.print("\n# INCOMMING TRACKER: " + m.getTracker() + "\n>>> ");
                    owner.forward(m);
            }
        }
    }catch (IOException e){
e.printStackTrace();
    }
}

public void send(int tracker){
    String[] message = { Conv.is(CDNP.PACKET), Conv.is(tracker), owner.getMST().toString() };
    Message m = new Message(message);
    forward(m);
}

public synchronized void forward(Message m){
    try{
        OutputStream out = sock.getOutputStream();
        //convert length to byte array of length 4
        ByteBuffer bb = ByteBuffer.allocate(4+m.getLength());
        bb.putInt(m.getLength());
        bb.put(m.getBytes());
        out.write(bb.array());
        out.flush();
    }catch (UnknownHostException e){
System.out.println("ERROR: Could not send to Router at " + sock.getRemoteSocketAddress().toString());
        return;
    }catch (IOException e1){

    }
}

Answer 1

int a = in.read(b,0,len);
if(a!=len){

那是行不通的。 InputStream 可能不会读取您想要的所有字节，它可能只读取当前可用的内容，并在不阻塞的情况下返回那么多。

致quote the Javadocs（强调我的）：

从输入流中读取多达 len 个字节的数据到一个字节数组中。尝试读取多达 len 个字节，但可能会读取较小的数字，可能为零。实际读取的字节数以整数形式返回。

您需要继续循环读取，直到获得所需的所有数据（或流完成）。

或者，由于您使用的是 DataInputStream，您也可以使用

in.readFully(b, 0, len);

它总是准确读取len 字节（阻塞直到它们到达，当没有足够的数据时抛出异常）。