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

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

多個(gè)文件：

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

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

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

解決方案：

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

多個(gè)文件：這個(gè)問(wèn)題的主要原因是我們不知道接收到的字節(jié)中每個(gè)文件的 EOF dataInputStream，這可以通過(guò)在發(fā)送每個(gè)文件之前發(fā)送文件大小(以字節(jié)為單位)來(lái)解決，因此我們可以從dataInputStream之后中斷讀取文件大小并對(duì)字節(jié)緩沖區(qū)中排隊(duì)的剩余文件重復(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();
    }
}

文件接收器