Java TCP Socket收发字节数组异常：接收全0数组问题排查

嘿，我看到你的问题了——客户端收到全0数组，核心问题其实是你在服务器和客户端都没有真正从输入流里读取数据，只是创建了字节数组但没把流里的内容读进去！而且你的怀疑没错，readFully确实是更可靠的选择，下面一步步帮你修正代码。

问题根源分析 #

服务器端的问题 #

你在服务器里创建了byte[] message = new byte[length];，但完全没有从inFromClient输入流中读取客户端发送的字节数据，这个数组一直是默认的全0状态。之后你修改的是这个空数组，发回客户端自然也是全0。

客户端接收的问题 #

客户端在等待服务器响应时，同样只创建了messageFromServer数组，但没有调用读取方法从inFromClient中获取服务器发回的字节，所以数组保持默认的全0。

为什么用readFully？ #

普通的read(byte[])方法可能只读取流中当前可用的部分字节（网络传输可能分批次到达），而readFully(byte[])会阻塞直到读取满整个数组的长度，对于你这种固定长度的字节数组传输场景，能确保数据完整读取，避免部分读取导致的错误。

修改后的完整代码 #

修正后的客户端代码 #

import java.io.DataInputStream;
import java.io.DataOutputStream;
import java.net.Socket;
import java.util.Arrays;

class TCPClient2 {
    public static void main(String argv[]) {
        try {
            System.out.println("Client started");
            Socket clientSocket = new Socket("localhost", 8080);
            DataOutputStream outToServer = new DataOutputStream(clientSocket.getOutputStream());
            System.out.println("\nByte array printed before sending to server:\n");
            byte[] message = new byte[10];
            // byte[] message = new byte[] { -1, -128, 1, 127, 23, 23, 23, 23, 23, 10 }; // 可以尝试这个测试数组
            message[0] = 1; // 修改第一个字节
            for(int i = 0; i < message.length; i++) {
                System.out.println(message[i]); // 打印发送前的数组
            }
            System.out.println(Arrays.toString(message)); // 打印发送前的数组字符串形式
            System.out.println("\n");
            
            outToServer.writeInt(message.length); // 发送消息长度
            outToServer.write(message); // 发送消息数组
            outToServer.flush(); // 强制刷新缓冲区，确保数据立即发送
            
            // 等待并接收服务器响应
            System.out.println("byte array received from server class: \n");
            DataInputStream inFromServer = new DataInputStream(clientSocket.getInputStream());
            int length = inFromServer.readInt(); // 读取响应长度
            
            byte[] messageFromServer = new byte[length];
            inFromServer.readFully(messageFromServer); // 关键：用readFully完整读取响应数组
            
            for(int i = 0; i < messageFromServer.length; i++) {
                System.out.println(messageFromServer[i]);// 打印接收的数组
            }
            System.out.println(Arrays.toString(messageFromServer));// 打印接收数组的字符串形式
            
            // 关闭资源
            inFromServer.close();
            outToServer.close();
            clientSocket.close();
        }catch (Exception e) {
            e.printStackTrace();
        }
    }
}

修正后的服务器代码 #

import java.io.DataInputStream;
import java.io.DataOutputStream;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.Arrays;

class TCPServer2 {
    public static void main(String argv[]) {
        try {
            System.out.println("waiting for connections");
            ServerSocket welcomeSocket = new ServerSocket(8080);
            Socket connectionSocket = welcomeSocket.accept();
            System.out.println("connection established");
            
            DataInputStream inFromClient = new DataInputStream(connectionSocket.getInputStream());
            int length = inFromClient.readInt(); // 读取客户端发送的消息长度
            
            byte[] message = new byte[length];
            inFromClient.readFully(message); // 关键：用readFully完整读取客户端发送的数组
            
            // 打印接收的数组
            System.out.println("Received message from client:");
            for(int i = 0; i < message.length; i++) {
                System.out.println(message[i]);
            }
            System.out.println(Arrays.toString(message));
            System.out.println("message from client printed");
            
            // 修改数组内容
            message[0] = 1; 
            message[9] = 1; 
            
            // 发送修改后的数组给客户端
            DataOutputStream outToClient = new DataOutputStream(connectionSocket.getOutputStream());
            outToClient.writeInt(message.length); // 发送消息长度
            outToClient.write(message); // 发送修改后的数组
            outToClient.flush(); // 强制刷新缓冲区
            
            System.out.println("message to client sent");
            
            // 关闭资源
            outToClient.close();
            inFromClient.close();
            connectionSocket.close();
            welcomeSocket.close();
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}

额外注意事项 #

• 加上flush()：Socket的输出流默认有缓冲区，调用flush()可以确保数据立即发送到网络，避免因缓冲区未满导致的延迟。
• 资源关闭：记得在finally块或者用try-with-resources关闭流和Socket，避免资源泄漏（上面的代码已经添加了关闭逻辑，你也可以用try-with-resources简化）。
• 异常处理：可以更细化异常类型（比如IOException），方便排查问题。

内容的提问来源于stack exchange，提问作者Znile