有人可能會說，如果文件大小大于Integer.MAX_VALUE字節(jié)，即 2GB，如果是這種情況，這就足夠了。

真正的問題是套接字一次只允許 65482 字節(jié)，即 64KB，這比上傳到上的大多數(shù)文檔文件大小要小得多網(wǎng)。

多個文件：

即使文件小于 64KB，此代碼的另一個問題是在發(fā)送多個文件并檢測 EOF 時，發(fā)送方不會有任何問題，因?yàn)閒ileInputStream.read()它隱式地用于打開的文件(因?yàn)?EOF 導(dǎo)致流結(jié)束本身)。

但是在從多個文件接收數(shù)據(jù)的接收端，dataInputStream一個接一個地排隊，并且沒有任何方法可以分別檢測每個文件的 EOF，因此，它將讀取排隊的整個字節(jié)作為一個文件。fileOutputStream.write(buffer)當(dāng)檢測到第一個文件的 EOF 并且剩余文件丟失時，使用寫入停止寫入此字節(jié)緩沖區(qū)。

因此，上述代碼僅適用于大小小于 64KB 的單個文件。

解決方案：

文件大?。哼@個問題的一個明顯解決方案是將文件分成多個塊，比如 4KB，然后在循環(huán)語句中通過套接字發(fā)送它們，并以類似的方式接收，即wile(stream.read(buffer)!=-1){ ... }

多個文件：這個問題的主要原因是我們不知道接收到的字節(jié)中每個文件的 EOF dataInputStream，這可以通過在發(fā)送每個文件之前發(fā)送文件大小(以字節(jié)為單位)來解決，因此我們可以從dataInputStream之后中斷讀取文件大小并對字節(jié)緩沖區(qū)中排隊的剩余文件重復(fù)相同的操作。

修改代碼：

import java.io.*;
import java.net.Socket;
public class Client {
    private static DataOutputStream dataOutputStream = null;
    private static DataInputStream dataInputStream = null;
    public static void main(String[] args) {
        try(Socket socket = new Socket("localhost",5000)) {
            dataInputStream = new DataInputStream(socket.getInputStream());
            dataOutputStream = new DataOutputStream(socket.getOutputStream());
            sendFile("path/to/file1.pdf");
            sendFile("path/to/file2.pdf");           
            dataInputStream.close();
            dataInputStream.close();
        }catch (Exception e){
            e.printStackTrace();
        }
    }
    private static void sendFile(String path) throws Exception{
        int bytes = 0;
        File file = new File(path);
        FileInputStream fileInputStream = new FileInputStream(file);        
        // send file size
        dataOutputStream.writeLong(file.length());  
        // break file into chunks
        byte[] buffer = new byte[4*1024];
        while ((bytes=fileInputStream.read(buffer))!=-1){
            dataOutputStream.write(buffer,0,bytes);
            dataOutputStream.flush();
        }
        fileInputStream.close();
    }
}

文件發(fā)送者

import java.io.DataInputStream;
import java.io.DataOutputStream;
import java.io.FileOutputStream;
import java.net.ServerSocket;
import java.net.Socket;
public class Server {
    private static DataOutputStream dataOutputStream = null;
    private static DataInputStream dataInputStream = null;
    public static void main(String[] args) {
        try(ServerSocket serverSocket = new ServerSocket(5000)){
            System.out.println("listening to port:5000");
            Socket clientSocket = serverSocket.accept();
            System.out.println(clientSocket+" connected.");
            dataInputStream = new DataInputStream(clientSocket.getInputStream());
            dataOutputStream = new DataOutputStream(clientSocket.getOutputStream());
            receiveFile("NewFile1.pdf");
            receiveFile("NewFile2.pdf");
            dataInputStream.close();
            dataOutputStream.close();
            clientSocket.close();
        } catch (Exception e){
            e.printStackTrace();
        }
    }
    private static void receiveFile(String fileName) throws Exception{
        int bytes = 0;
        FileOutputStream fileOutputStream = new FileOutputStream(fileName);        
        long size = dataInputStream.readLong();     // read file size
        byte[] buffer = new byte[4*1024];
        while (size > 0 && (bytes = dataInputStream.read(buffer, 0, (int)Math.min(buffer.length, size))) != -1) {
            fileOutputStream.write(buffer,0,bytes);
            size -= bytes;      // read upto file size
        }
        fileOutputStream.close();
    }
}

文件接收器