Блог

Resteasy docs не объясняет, кто несет ответственность за закрытие потоков, переданных MultipartFormDataOutput . Давайте рассмотрим следующий пример:

 WebTarget target = ClientBuilder.newClient().target("url");
MultipartFormDataOutput formData = new MultipartFormDataOutput();
FileInputStream fis1 = new FileInputStream(new File("/path/to/image1"));
FileInputStream fis2 = new FileInputStream(new File("/path/to/image2"));
formData.addFormData("image", fis1, MediaType.APPLICATION_OCTET_STREAM_TYPE);
formData.addFormData("image", fis2, MediaType.APPLICATION_OCTET_STREAM_TYPE);
Entity<MultipartFormDataOutput> entity = Entity.entity(formData, MediaType.MULTIPART_FORM_DATA);
Response response = target.request().post(entity);
  

Будут fis1 ли и fis2 закрыты resteasy или пользователь должен позаботиться о закрытии этих потоков?

Я бы предложил использовать try-with-resource, чтобы быть уверенным, что они будут закрыты.

 WebTarget target = ClientBuilder.newClient().target("url");
MultipartFormDataOutput formData = new MultipartFormDataOutput();

try(FileInputStream fis1 = new FileInputStream(new File("/path/to/image1")));
    FileInputStream fis2 = new FileInputStream(new File("/path/to/image2")))
{
  formData.addFormData("image", fis1, MediaType.APPLICATION_OCTET_STREAM_TYPE);
  formData.addFormData("image", fis2, MediaType.APPLICATION_OCTET_STREAM_TYPE);
  Entity<MultipartFormDataOutput> entity = Entity.entity(formData, 
  MediaType.MULTIPART_FORM_DATA);
  Response response = target.request().post(entity);
}
  

Итак, я могу сам ответить на свой вопрос, надеюсь, кто-то выиграет от этого.

Resteasy закроет переданный поток. В моем случае, InputStreamProvider позаботится о закрытии FileInputStream .

      public void writeTo(InputStream inputStream, Class<?> type, Type genericType, Annotation[] annotations, MediaType mediaType, MultivaluedMap<String, Object> httpHeaders, OutputStream entityStream) throws IOException
   {
           LogMessages.LOGGER.debugf("Provider : %s,  Method : writeTo", getClass().getName());
       try
       {
           int c = inputStream.read();
           if (c == -1)
           {
               httpHeaders.putSingle(HttpHeaderNames.CONTENT_LENGTH, Integer.toString(0));
               entityStream.write(new byte[0]); // fix RESTEASY-204
               return;
           }
           else
               entityStream.write(c);
         ProviderHelper.writeTo(inputStream, entityStream);
       }
       finally
       {
         inputStream.close();
       }
   }