Гессе с большим двоичным файлом

как создать файловый сервлет Upload/Downlod с использованием двоичного протокола Hessian? для файлов размером более 1 ГБ. Я создаю тест для Гессиана с большими двоичными данными, но если файл превышает доступный размер ОЗУ, возникает исключение java.lang.OutOfMemoryError.

//апи для клиента

public interface Upload {
  public void upload(String filename, InputStream data);
}

//реализация

public class Upload extends HessianServlet implements Upload {
  @Override
  public void upload(String fileName, InputStream in) {
    int count = 0;
    try {
      while ((count = in.read()) != -1) {
        System.err.print("reading view in console=" + count);
      }
      in.close();
    } catch (IOException ex) {
        Logger.getLogger(Upload.class.getName()).log(Level.SEVERE, null, ex);
    }
    System.err.print("total buffers filled=" + count);
  }
}

//вызов клиента

    HessianProxyFactory proxy = new HessianProxyFactory();

    try {

//вызываем прокси для загрузки

      Upload x = (Upload) proxy.create(Upload.class, "http://localhost:8080/PathToServletFile/Upload");

      InputStream in;

      try {
        in = new FileInputStream("C:/bigFile.zip");
        x.upload("some file", in);
      } catch (FileNotFoundException ex) {
        Logger.getLogger(HessianFrame.class.getName()).log(Level.SEVERE, null, ex);
      }
    } catch (MalformedURLException ex) {
        Logger.getLogger(HessianFrame.class.getName()).log(Level.SEVERE, null, ex);
    }

//Исключение

Exception in thread "AWT-EventQueue-0" java.lang.OutOfMemoryError: Java heap space
at java.util.Arrays.copyOf(Arrays.java:2786)
at java.io.ByteArrayOutputStream.write(ByteArrayOutputStream.java:94)
at sun.net.www.http.PosterOutputStream.write(PosterOutputStream.java:61)
at com.caucho.hessian.io.HessianOutput.writeByteBufferPart(HessianOutput.java:743)
at com.caucho.hessian.io.AbstractHessianOutput.writeByteStream(AbstractHessianOutput.java:407)
at com.caucho.hessian.io.InputStreamSerializer.writeObject(InputStreamSerializer.java:70)
at com.caucho.hessian.io.HessianOutput.writeObject(HessianOutput.java:324)
at com.caucho.hessian.io.HessianOutput.call(HessianOutput.java:132)
at com.caucho.hessian.client.HessianProxy.sendRequest(HessianProxy.java:280)
at com.caucho.hessian.client.HessianProxy.invoke(HessianProxy.java:170)
at $Proxy0.upload(Unknown Source)
at hessianlargefiletest.HessianFrame.btnDownloadActionPerformed(HessianFrame.java:108)
at hessianlargefiletest.HessianFrame.access$000(HessianFrame.java:32)
at hessianlargefiletest.HessianFrame$1.actionPerformed(HessianFrame.java:56)
at javax.swing.AbstractButton.fireActionPerformed(AbstractButton.java:1995)
at javax.swing.AbstractButton$Handler.actionPerformed(AbstractButton.java:2318)
at javax.swing.DefaultButtonModel.fireActionPerformed(DefaultButtonModel.java:387)
at javax.swing.DefaultButtonModel.setPressed(DefaultButtonModel.java:242)
at javax.swing.plaf.basic.BasicButtonListener.mouseReleased(BasicButtonListener.java:236)
at java.awt.Component.processMouseEvent(Component.java:6289)
at javax.swing.JComponent.processMouseEvent(JComponent.java:3267)
at java.awt.Component.processEvent(Component.java:6054)
at java.awt.Container.processEvent(Container.java:2041)
at java.awt.Component.dispatchEventImpl(Component.java:4652)
at java.awt.Container.dispatchEventImpl(Container.java:2099)
at java.awt.Component.dispatchEvent(Component.java:4482)
at java.awt.LightweightDispatcher.retargetMouseEvent(Container.java:4577)
at java.awt.LightweightDispatcher.processMouseEvent(Container.java:4238)
at java.awt.LightweightDispatcher.dispatchEvent(Container.java:4168)
at java.awt.Container.dispatchEventImpl(Container.java:2085)
at java.awt.Window.dispatchEventImpl(Window.java:2478)
at java.awt.Component.dispatchEvent(Component.java:4482)

java hessian
person dimitri    schedule 18.04.2011    source источник
comment
Похоже, это должно сработать. или вы уверены, что не пытаетесь обработать весь ввод в памяти. то есть вы уверены, что ваш читатель не хранит данные, которые он читает, в памяти.   -  person Peter Lawrey    schedule 18.04.2011
comment
код выглядит как выше. это правильно?   -  person dimitri    schedule 18.04.2011
comment
Хм, трассировка стека выглядит так, будто данные копируются в ByteArrayOutputStream. Судя по документации, вы все делаете правильно, но библиотека ведет себя не идеально. Я предлагаю вам оригинальные разработчики. ;)   -  person Peter Lawrey    schedule 18.04.2011
comment
Вы можете сообщить об этой ошибке на странице bugs.caucho.com.   -  person Vincent Cantin    schedule 25.05.2011

Ответы (1)


arrow_upward
0
arrow_downward

вы не должны использовать прокси для отправки больших файлов

как говорится в гессенском документе:

клиенту необходимо получить контроль над протоколом Hessian напрямую, потому что прокси-интерфейс потребует буферизации всего файла перед возвратом вызова.

так что можете попробовать это (я не проверял)

public interface Download {
    public InputStream download(String filename, InputStream data){
          //create your http connection and get the outputstream
          OutputStream os = ....;

          Hessian2Output out = new Hessian2Output(os);

          out.writeObject(filename);
          byte[] buffer = new byte[1024];
          int c = -1;
          while( (c = data.read(buf)) != -1) {
             os.write(buf);
          }
          os.flush();
          //.....
    }
}
person sodarfish    schedule 05.04.2012