Блог

Мне было интересно, могу ли я получить некоторые рекомендации по решению моей проблемы…

Видите ли, я пытаюсь освоить программирование сокетов; Мне удалось создать клиент и сервер; сервер пишет клиенту без проблем; мне даже удается отправлять файлы с помощью

 byte [] mybytearray  = new byte [(int)myFile.length()];
  FileInputStream fis = new FileInputStream(myFile);
  

Это на стороне сервера.
На стороне клиента

 byte [] mybytearray  = new byte [filesize];
InputStream is = sock.getInputStream();
FileOutputStream fileos = new FileOutputStream("Filename.dat");
BufferedOutputStream bufferos = new BufferedOutputStream(fileos);
bytesRead = is.read(mybytearray,0,mybytearray.length);
current = bytesRead;


do {
   bytesRead =
      is.read(mybytearray, current, (mybytearray.length-current));
   if(bytesRead >= 0) current  = bytesRead;
} while(bytesRead > -1);

bufferos.write(mybytearray, 0 , current);
bufferos.flush();
long end = System.currentTimeMillis();
System.out.println(end-start);
bufferos.close();
  

Мой вопрос заключается в том, что я не могу отправлять большие файлы; Я продолжаю получать
«Исключение в потоке «main» java.lang.Ошибка OutOfMemoryError: пространство кучи Java »

Любые мысли или указания о том, как я могу управлять отправкой больших файлов клиенту с сервера? Я имею в виду размеры, скажем, 600 МБ или около того …. любая мысль? Высоко ценится … спасибо

Что ж, в настоящее время вашей куче приходится пытаться удерживать ‘mybytearray’, который соответствует размеру файла, который вы пытаетесь получить (предположительно). Вам нужно переместить bos.запишите операцию () в цикл и сделайте ‘mybytearray’ фиксированным размером. Вот пример копирования одного потока в другой, который на самом деле не заботится о размере передаваемых данных:

     public static void stream(InputStream in, OutputStream out)
        throws IOException {
    byte[] buf = new byte[1024];
    int bytesRead = 0;

    try {

        while (-1 != (bytesRead = in.read(buf, 0, buf.length))) {
            out.write(buf, 0, bytesRead);
        }

    } catch (IOException e) {
        log.error("Error with streaming op: "   e.getMessage());
        throw (e);
    } finally {
                    try{
           in.close();
           out.flush();
           out.close();
                    } catch (Exception e){}//Ignore
    }
}
  

У вас заканчивается память, потому что вы выделяете mybytearray ее на длину filesize . Одним из возможных решений является вызов JVM с большей кучей; например -Xmx1G .

Однако еще один момент заключается в том, нужно ли вам читать весь файл в память — на стороне сервера это определенно не так: вы можете просто читать файл по частям в массив фиксированного размера, а затем записывать эти фрагменты в выходной поток. Таким образом, объем памяти вашего сервера не увеличится, когда он попытается отправить большие файлы обратно клиенту.

Не считывайте полный файл в ОЗУ для отправки, а отправляйте файл по частям.

 byte [] mybytearray  = new byte [(int)myFile.length()];
  

плохо, если (int)myFile.length() больше, чем умещается в памяти.

Вместо этого используйте

 byte [] buffer= new byte[4096];
  

или так и сделайте цикл, считывая из файла и отправляя в сокет.

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