泽西：在HTTP响应后关闭I/O资源

Question

我的设置：我创建了一个REST服务（Jersey/Dropwizard），可以从数据库中流式传输大量内容。在GET操作期间，服务通过连接池接入数据库，将数据打包成流，并执行一些即时转换，以各种编码（CSV、JSON等）呈现请求的数据。数据库连接的生命周期与流的生命周期相关联，只有当流关闭时，数据库连接才会被释放。

流转换由编码器类执行，该类返回StreamingOutput，然后将其传递给响应对象。编码器当前处理流完全消耗时的资源关闭。

我的问题是：由于StreamingOutput没有实现AutoCloseable，当输出仅被部分消耗时，可能会发生连接泄漏。

我有时观察到，陈旧的活动连接正在连接池中堆积，我怀疑它们是由中止的HTTP连接引起的。如下所示，当前代码处理try块中发生的异常。我无法处理的是return语句之后发生的异常，我不知道如何将资源关闭的任何指令附加到响应对象。

我的问题是：在请求终止后（定期或由于错误），如何通知响应对象关闭特定资源？或者：当请求上下文结束时，有没有更好的方法来安全地关闭任何相关资源？

 @GET
 //@Produces(...)
 html" target="_blank">public Response streamData(
        @PathParam("key") String key,
        // ... other params
        ) {

    //decode and validate params
    Stream<Pojo> ps = null;
    try {
        // connect to db and obtain data stream for <key>
        ps = loadData(db, key);
        // apply detailed encoding instrunctions and create a StreamingOutput
        final StreamingOutput stream = Encoder.encodeData(ps, encodingArgs);
        return Response.ok(stream).build();
    } catch (Exception e) {
        closeOnException(ps); // wrapper for ps.close();
        throw e;
    }
 }

Answer 1

您可以在方法HttpServletResponse中添加：

@Produces(MediaType.APPLICATION_OCTET_STREAM)
public Object streamData(
            @PathParam("key") String key,
            @Context HttpServletResponse response,
            // ... other params
            ) {
  ...
  response.getOutputStream().write(....)
  response.flushBuffer();
  response.getOutputStream().close();
  return null;
}

Answer 2

我从dropwizard邮件列表中收到了一个很好的答案，解决了我的问题，我想在这里引用它，以防有人遇到同样的问题。

https://groups.google.com/forum/#!topic/dropwizard用户/62GoLDBrQuo

引用肖恩的回答：

Jersey支持CloseableService，允许您在请求完成时注册要关闭的可关闭对象：

public Response streamData(..., @Context CloseableService closer) {
  ...
  closer.add(closeable);
  return Response.ok(...).build();
}