EOFException或SocketException：在通過套接字傳輸文件時關閉套接字

Question

我正在開發客戶端和服務器之間的簡單文件傳輸應用程序。 這裏是我的代碼： 我的客戶（發件人）：

try{ 
       File file_sender=XMLParser.register(peername, address, port, listfile); 
       int count; 
       byte[] buffer = new byte[1024]; 
       int len=(int) file_sender.length(); 
       byte[] mybytearray = new byte[len];  
       DataOutputStream output=new DataOutputStream(Info.connection.getOutputStream()); 
       output.writeInt(len); 
       System.out.println(len); 
       BufferedInputStream bis=new BufferedInputStream(new FileInputStream(file_sender)); 
       bis.read(mybytearray, 0, len); 
       output.write(mybytearray, 0, len); 
       bis.close(); 
       output.close(); 
       // Info.connection.close(); 
      }catch(Exception ex){ 
       System.out.println(ex.toString()); 
      } 

我的服務器（接收器）：

public class IOThread extends Thread { 
private Socket connection; 
private DataInputStream input; 
public IOThread(Socket connection) throws IOException{ 
    this.connection=connection; 
    input=new DataInputStream(connection.getInputStream()); 

} 
@Override 
public void run(){ 
    while(true){ 
     try{ 
      int filesize=12022386; 
      int bytesRead; 
      int currentTot = 0; 
      byte[] bytearray = new byte [filesize]; 
      int len=input.readInt(); 
      FileOutputStream fos = new FileOutputStream("data.xml"); 
      BufferedOutputStream bos = new BufferedOutputStream(fos); 
      bytesRead=input.read(bytearray, 0,bytearray.length); 
      System.out.println(len); 
      currentTot=bytesRead; 
      do{ 
       bytesRead=input.read(bytearray, currentTot, (bytearray.length-currentTot)); 
       if(bytesRead>=0) currentTot+=bytesRead; 
       System.out.println("pos: "+currentTot); 
      } while(len!=currentTot); 
      bos.write(bytearray, 0, currentTot); 
      bos.close(); 
      //connection.close(); 
      System.out.println("Done"); 
     }catch(EOFException ex){ 
      System.out.println(ex.toString()); 
      break; 
     }catch(Exception ex){} 
    } 
} 

我想轉院多個文件，所以我不希望關閉套接字。因此，我使用變量「len」來檢查文件是否完全傳輸。

如果我在發送文件之後關閉「輸出」，那麼服務器發出EOFException並且文件發送成功。

當我不關閉輸出時，服務器無法接收文件成功。但是服務器不會拋出EOFException。

你能幫我解決這個問題嗎？ 更新：這是我在控制檯屏幕上輸出，如果我不關閉變量 「輸出」 在客戶端：

POS：496和

感謝。 對不起，我可憐的英語

Answer 1

您的BufferedOutputStream填充似乎不正確。下面的代碼必須在while循環中。

bos.write(bytearray, 0, currentTot); 

嘗試這樣的事情，而不是：

BufferedOutputStream buffOut=new BufferedOutputStream(fos); 
byte []arr = new byte [1024 * 1024]; 
int available = -1; 
while((available = buffIn.read(arr)) != -1) { 
    buffOut.write(arr, 0, available); 
}  
buffOut.flush(); 
buffOut.close(); 

並再次測試。

編輯：用@ Jason的正確評論更新了我的答案。

Answer 2

兩件事情：

首先，你似乎被忽略了你的接收代碼的文件長度是多少？您有：

 int filesize=12022386; 
     int bytesRead; 
     int currentTot = 0; 
     byte[] bytearray = new byte [filesize]; 
     int len=input.readInt(); 

您在上漿ByteArray的12022386個字節不管len的價值，你所要求的從輸入流很多字節。其次，關閉輸出流時，任何尚未寫入的緩存/緩存數據將自動刷新（即，在您的情況下，發送到服務器）。

當您完成發送第一個文件以強制完成將所有數據發送到服務器時，顯式刷新輸出流。然後，您可以繼續使用該輸出流來處理其他事情。

當傳輸完成時，在您的發送代碼中執行output.flush()。

Answer 3

問題是，您讀取的文件大小超出文件大小，即讀取的文件大小不是len，而是讀取的文件大小爲bytearray.length。

因此，你讀超過len字節，因此len!=currentTot是永遠不會滿足的，因爲，你可以從你的樣本輸出，currentTot == 496和len == 246看到。

，讓您的while循環以下變化：

do{ 
    bytesRead=input.read(bytearray, currentTot, (len - currentTot)); 
    if(bytesRead>=0) currentTot += bytesRead; 
    System.out.println("pos: " + currentTot); 
} while(len != currentTot); 

只是爲了確保你沒有一個無限循環最終由於類似的錯誤，你可以使用currentTot < len，而不是len != currentTot作爲你的條件。

此外，由於您已經在使用DataInputStream，因此請考慮使用readFully讀取套接字內容。這會阻塞，直到從套接字讀取給定數量的字節，從而消除您對while循環的需要。閱讀更多here。

Answer 4

將所有循環丟棄並在發送文件後使用DataInputStream.readFully();關閉套接字;不要結束文件長度;並使用正常大小的緩衝區，例如8192字節。