在客户端关闭连接后防止 Jersey Server 保持线程处于活动状态答案

【问题标题】：Prevent Jersey Server keeping thread alive after client has closed connection在客户端关闭连接后防止 Jersey Server 保持线程处于活动状态
【发布时间】：2015-10-11 02:20:46
【问题描述】：

我正在开发一个小型应用程序，该应用程序需要使用 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 管理器中所示）。
但是，如果客户端在完成之前取消请求，则该过程不再继续（如将 i 记录到日志文件中所见），但根据 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 的生产版本进行任何调整。

【问题讨论】：

你找到解决方案了吗？

标签： java tomcat jersey jersey-2.0

【解决方案1】：

您是否尝试过创建 BufferedWriter a try-with-resources statement 或捕获 IOException？

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

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

【讨论】：