防止Jersey服务器在客户端关闭连接后保持线程存活

Question

我正在开发一个小型应用程序，该应用程序需要使用Jersey 2.0(版本2.19)从REST端点流式传输不同长度的输出到客户端。虽然由于客户端应用程序的现有框架，这不是理想的，但客户端可以随时取消请求。

我可以使用StreamingOutput成功返回一个流输出，如下面的代码所示。

@GET
public Response test() {
        StreamingOutput stream = new StreamingOutput() {
            @Override
            public void write(OutputStream os) throws IOException, WebApplicationException {
                Writer writer = new BufferedWriter(new OutputStreamWriter(os));
                for (int i = 0; i < 500000; i++) {
                    LOGGER.info(Integer.toString(i));
                    writer.write(String.valueOf(i) + "n");
                    writer.flush();
                }
                writer.close();
            }
        };
        return Response.ok(stream).build();
}

当我从客户机调用端点并让它完成时(因此返回0 - 499999的数字)，我不会遇到任何问题，并且Tomcat内存中没有线程(如Tomcat管理器所示)。
但是，如果客户端在请求完成之前取消了请求，则该进程不再继续(通过将其记录到日志文件中可以看到)，但是根据Tomcat管理器，它仍然持有一个线程，随着线程时间的增加，但发送的字节保持不变，这些保持不变，并且在一段时间后不会超时。在应用程序日志或Tomcat日志中都不会抛出和记录异常，但是在停止Tomcat时，您可以在Tomcat日志中看到对这些线程的引用，说它可能导致内存泄漏:

SEVERE: The web application [/streaming-1.0-SNAPSHOT] created a ThreadLocal with key of type [java.lang.ThreadLocal] (value [java.lang.ThreadLocal@27d415d9]) and a value of type [org.glassfish.jersey.process.internal.RequestScope.Instance] (value [Instance{id=3ad9c61c-22cd-40d5-b810-59bff3feafa9, referenceCounter=2, store size=4}]) but failed to remove it when the web application was stopped. This is very likely to create a memory leak.

所以问题是，一旦客户端取消了与服务器的连接，是否有一种方法可以防止这些线程保留?

我做了一个巨大的假设，这是Jersey而不是Tomcat，部分是一厢情愿的想法，因为我可能不一定能够对Tomcat的生产版本进行任何调整。

Answer 1

您是否尝试过创建BufferedWriter一个try-with-resources语句或捕获IOException?

当客户端提前终止连接时，在服务器上，writer.write抛出一个未被捕获的IOException，因此BufferedWriter永远不会关闭，底层tomcat提供的OutputStream永远不会关闭。

try (Writer writer = new BufferedWriter(new OutputStreamWriter(os))) {
  ...
} catch(IOException ioe) {
  // log client termination.
}