Java Socket多文件传输问题求助：已知成因却不知解决方案

嘿，我懂你现在的处境——已经把多文件传输的头部信息（文件数量、文件名、文件大小）搞定了，就是卡在文件字节数据的缓冲区传输这一步，对吧？别慌，我来给你把这部分的逻辑理清楚，再给你完整的代码实现，确保传输过程稳定不翻车。

先说说你当前代码可能存在的问题 #

你原来的while循环只判断count = in.read(buffer) > 0，但这里有两个大坑：

1. Socket的read()方法不一定会一次性读取到你想要的字节数，而且如果不限制总读取字节数，会把下一个文件的头部数据（比如下一个文件的文件名）当成当前文件的内容读进来，直接搞乱后续的解析逻辑。
2. 如果连接没关闭，read()会一直阻塞等待，不会返回-1，导致程序卡死。

完整的发送端实现（文件数据部分） #

发送端要严格按照“文件数量→文件名→文件大小→文件数据”的顺序发送，而且文件数据要按文件大小控制发送的总字节数，代码如下：

// 假设你已经拿到了要传输的文件列表List<File> fileList
Socket socket = new Socket("接收端IP", 8888);
DataOutputStream out = new DataOutputStream(socket.getOutputStream());

// 1. 发送文件数量
int fileCount = fileList.size();
out.writeInt(fileCount);

for (File file : fileList) {
    String fileName = file.getName();
    long fileSize = file.length();
    
    // 2. 发送文件名
    out.writeUTF(fileName);
    // 3. 发送文件大小
    out.writeLong(fileSize);
    
    // 4. 发送文件字节数据（核心部分）
    try (FileInputStream fis = new FileInputStream(file)) {
        byte[] buffer = new byte[8192]; // 8KB缓冲区，这个大小可以根据需求调整
        long bytesSent = 0;
        int count;
        
        while (bytesSent < fileSize && (count = fis.read(buffer)) != -1) {
            out.write(buffer, 0, count); // 只写入实际读取到的字节数
            bytesSent += count;
            out.flush(); // 强制刷新缓冲区，避免数据积压
        }
    } catch (IOException e) {
        System.err.println("发送文件" + fileName + "时出错：" + e.getMessage());
        e.printStackTrace();
    }
}

// 最后关闭资源（建议用try-with-resources自动关闭）
out.close();
socket.close();

对应的接收端实现（文件数据部分） #

接收端要和发送端的逻辑严格对应，按顺序读取，并且根据文件大小控制读取的总字节数，避免多读或者少读：

ServerSocket serverSocket = new ServerSocket(8888);
Socket socket = serverSocket.accept();
DataInputStream in = new DataInputStream(socket.getInputStream());

// 1. 读取文件数量
int fileCount = in.readInt();
String saveDir = "./received_files/";
// 确保保存目录存在
new File(saveDir).mkdirs();

for (int i = 0; i < fileCount; i++) {
    // 2. 读取文件名
    String fileName = in.readUTF();
    // 3. 读取文件大小
    long fileSize = in.readLong();
    
    // 4. 读取文件字节数据（核心部分）
    try (FileOutputStream fos = new FileOutputStream(saveDir + fileName)) {
        byte[] buffer = new byte[8192];
        long bytesReceived = 0;
        int count;
        
        while (bytesReceived < fileSize) {
            // 计算还需要读取的字节数，避免浪费缓冲区空间
            int bytesToRead = (int) Math.min(buffer.length, fileSize - bytesReceived);
            count = in.read(buffer, 0, bytesToRead);
            
            if (count == -1) {
                // 连接意外断开，抛出异常或者做其他处理
                throw new IOException("传输中断：文件" + fileName + "未接收完整");
            }
            
            fos.write(buffer, 0, count);
            bytesReceived += count;
        }
        
        System.out.println("文件" + fileName + "接收完成，大小：" + fileSize + "字节");
    } catch (IOException e) {
        System.err.println("接收文件" + fileName + "时出错：" + e.getMessage());
        e.printStackTrace();
    }
}

// 关闭资源
in.close();
socket.close();
serverSocket.close();

敲黑板！几个必须注意的关键点 #

• 数据顺序严格匹配：发送端的writeInt()对应接收端的readInt()，writeUTF()对应readUTF()，顺序绝对不能乱，不然会把文件大小当成文件名读，直接炸锅。
• 文件大小的校验：接收端必须靠fileSize来终止文件数据的读取，不能依赖read() == -1——因为Socket连接在传输完所有文件前不会关闭，read()会一直阻塞。
• 资源自动关闭：用Java 7+的try-with-resources语法，不用手动写finally关流，既简洁又能避免资源泄漏。
• 缓冲区大小调整：8KB的缓冲区是比较通用的选择，你也可以根据文件大小调整（比如大文件用32KB/64KB），但别设太大，不然会占用过多内存。

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