Потеря пакетов в программировании сокетов java

Question

Я пытаюсь отправить файл с клиента на сервер. Ниже приведен код, который я попробовал. Но время от времени происходит потеря пакета во время передачи. Я не уверен, где я ошибаюсь.

SERVER КОД СТОРОНА:

public static void ReadAndWrite(byte[] aByte, Socket clientSocket, 
      InputStream inputStream, String fileOutput) 
        throws FileNotFoundException, IOException { 
     int bytesRead; 
     FileOutputStream fileOutputStream = null; 
     BufferedOutputStream bufferedOutputStream = null; 
     ByteArrayOutputStream byteArrayOutputStream = new ByteArrayOutputStream(); 
     try 
     { 
     fileOutputStream = new FileOutputStream(fileOutput); 
     bufferedOutputStream = new BufferedOutputStream(fileOutputStream); 
     bytesRead = inputStream.read(aByte, 0, aByte.length); 
     System.out.println("The length is "+bytesRead); 
     int count = 0; 
     do { 
      count++; 
      byteArrayOutputStream.write(aByte); 
      bytesRead = inputStream.read(aByte); 
     } while (bytesRead != -1); 
     System.out.println("The count is "+count); 
     System.out.println("The length is "+byteArrayOutputStream.size()); 
     bufferedOutputStream.write(byteArrayOutputStream.toByteArray()); 
     bufferedOutputStream.flush(); 
     bufferedOutputStream.close(); 
     clientSocket.close(); 
     } 
     catch(Exception ex) 
     { 
      Logger.writeLog(ex,Listen.class.getName(), LogType.EXCEPTION); 
      throw ex; 
     } 

КЛИЕНТ SIDE КОД:

public void readByteArrayAndWriteToClientSocket(
      Socket connectionSocket, BufferedOutputStream outToClient, String fileToSend) throws Exception 
    { 
     try{ 
     if (outToClient != null) 
     { 
      File myFile = new File(fileToSend); 
      System.out.println(myFile.length()); 
      byte[] byteArray = new byte[(int) myFile.length()]; 

      FileInputStream fileInputStream = null; 

      try { 
       fileInputStream = new FileInputStream(myFile); 
      } catch (IOException ex) { 
       Logger.writeLog(ex, FileUtility.class.getName(), LogType.EXCEPTION); 
       throw ex; 
      } 
      BufferedInputStream bufferedInputStream = new BufferedInputStream(fileInputStream); 

      try { 
       bufferedInputStream.read(byteArray, 0, byteArray.length); 
       outToClient.write(byteArray, 0, byteArray.length); 
       outToClient.flush(); 
       outToClient.close(); 
       connectionSocket.close(); 


       return; 
      } catch (IOException ex) { 
       Logger.writeLog(ex, FileUtility.class.getName(), LogType.EXCEPTION); 
       throw ex; 
      } 

     } 
     }catch (Exception e) { 
      Logger.writeLog(e, getClass().getName(), LogType.EXCEPTION); 
      throw e; 
     } 
    } 

Answer 1

Гнезда чтения метод будет возвращать, когда его получил все байты вы просили, или, когда он перестает получать данные из сети.

Поскольку передача часто прерывается в любой реальной сети, вам необходимо продолжать выполнять вызовы чтения до тех пор, пока вы не получите нужное количество байтов.

Вам нужно код что-то вроде этого:

 char [] buffer = new char[1024]; 
     int expect = 1000; 
     int sofar = 0; 
     int chars_read; 
     try 
     { 
      while((chars_read = from_server.read(buffer[sofar])) != -1) 
      { 
      sofar = sofar + chars_read; 
      if (sofar >= expected) break; 
      } 
     } 
     catch(IOException e) 
     { 
      to_user.println(e); 
     } 

Answer 2

Там нет «потеря пакетов», только ошибки в коде.

канонический способ скопировать поток в Java заключается в следующем:

while ((count = in.read(buffer)) > 0) 
{ 
    out.write(buffer, 0, count); 
} 

Если Вы знаете, количество байт заранее и отправитель должен держать соединение открытым после передачи, он становится:

while (total < expected && (count = in.read(buffer, 0, expected-total > buffer.length ? buffer.length : (int)(expected-total))) > 0) 
{ 
    out.write(buffer, 0, count); 
    total += count; 
} 

Забудьте обо всех ByteArrayInput/OutputStreams и дополнительных копиях. Просто прочитайте из файла и отправьте в сокет, или прочитайте из сокета и напишите в файл.