Jersey Speicherleck?

Question

Ich habe das folgende Code-Snippet. Einfacher Dienst, der ein Bild zurückgibt, wenn der Endpunkt aufgerufen wird.

@GET 
@Path("/categories/{category}/image") 
@Produces("image/jpeg") 
@UnitOfWork 
public StreamingOutput getCategoryImage(@PathParam("category")Category category){ 

//foo service will return an Optional 

    return fooService.getImage(category).map(new Function<InputStream, StreamingOutput>() { 
     @Override 
     public StreamingOutput apply(InputStream inputStream) { 
      return (StreamingOutput) output -> BarResource.this.copyAndClose(inputStream, output); 
     } 
    }) 
      .orElseThrow(NotFoundException::new); 
} 


//Originally this method did not exist, but I am trying this to close the 'leak' 

private long copyAndClose(InputStream inputStream, OutputStream outputStream) throws IOException{ 
    try(InputStream temp = inputStream; OutputStream tempOut = outputStream) { 
     return IOUtils.copy(temp, tempOut); 
    } 
} 

jedoch durch einen Stresstest, nannten wir diese 1600 mal/sec für ein paar Sekunden und die Speichernutzung in unserem Docker Container Himmel hochgeschnellt (von etwa 300 einen Gig auf über) können wir die Xmx eingestellt haben 512 aber die Erinnerung steigt weiter.

Fehle ich hier etwas? Wir benutzen Dropwizard und Jersey.

Answer 1

Nach dem Ausführen eines Profilers habe ich festgestellt, dass wir mehrere tausend Objekte als Reaktion auf diesen Aufruf in FooService erstellt haben. Wir waren in der Lage, es zu einem Singleton zu machen, und das scheint viele der Bedenken angesprochen zu haben.