AsyncResponse ConnectionCallback 不会在泽西岛触发

Question

对于异步编程，Jersey (JAX-RS) 提供了一个ConnectionCallback 回调，该回调将在连接断开时执行。来自Jersey docs：

由于一些异步请求可能需要很长时间来处理客户端可能 决定在响应之前终止其与服务器的连接 已恢复或在完全写入客户端之前。到 处理这些用例可以使用 ConnectionCallback。这 仅当连接过早时才会执行回调 在将响应写入背面时终止或丢失 客户。请注意，响应时不会调用此回调 写入成功，客户端连接按预期关闭。

听起来不错，但我永远无法点燃它。

这里有一些代码：

@GET
@Produces(MediaType.TEXT_PLAIN)
@ManagedAsync
@Path("/poll")
public void poll(@Suspended final AsyncResponse asyncResponse) {
    asyncResponse.register(new CompletionCallback() {
        @Override
        public void onComplete(Throwable throwable) {
            logger.info("onComplete called.");
        }
    });

    asyncResponse.register(new ConnectionCallback() {
        @Override
        public void onDisconnect(AsyncResponse disconnected) {
            logger.info("onDisconnect called.");
        }
    });

    asyncResponse.setTimeout(POLL_TIMEOUT_SECONDS, TimeUnit.SECONDS);
    asyncResponse.setTimeoutHandler(new TimeoutHandler() {
        @Override
        public void handleTimeout(AsyncResponse asyncResponse) {
            logger.info("handleTimeout called.");
            asyncResponse.resume(Response.status(Response.Status.OK).entity("TIMEOUT").build());
        }
    });
}

显示的另外两个回调，CompletionCallback 和 TimeoutHandler，触发得很好，没有失败。如果达到指定的超时持续时间，TimeoutHandler 将触发。如果 AsyncResponse 实例被恢复，则 CompletionCallback 触发。

但是，使用 ConnectionCallback，我可以关闭、终止或以其他方式停止连接到上面显示的 Web 服务的客户端，并且 ConnectionCallback 永远不会被触发。

我错过了什么吗？ ConnectionCallback 是否在泽西岛实现？ （在 JAX-RS 规范中它是可选的，但 Jersey 文档谈论它好像它已经实现了。）

我们将不胜感激。

Answer 1

ConnectionCallback 确实在 Jersey 中实现。并且还调用了“onDisconnect”回调。您可以在 Jersey 中查看以下代码：

https://github.com/jersey/jersey/blob/a6ff4d50da13d45ad90fd7375a15a31afa02e489/core-server/src/main/java/org/glassfish/jersey/server/ServerRuntime.java#L723

https://github.com/jersey/jersey/blob/b7907e279010e7035a7a3e529993d22f77a21e08/core-server/src/main/java/org/glassfish/jersey/server/ChunkedOutput.java#L246-L252

在写响应时抛出 IOException。因此，为了回答您的问题，没有轮询或类似机制不断检查客户端是否已连接，而是仅在写入响应时通常发生 IOException 时才调用 onDisconnect 方法。

更新 1：

另外我想引用你自己的问题：

"只有在连接过早的情况下才会执行此回调 在将响应写入背面时终止或丢失 客户”

因此，除非您尝试写入该流，否则您的回调将永远不会被触发。需要明确的是，当没有写入响应或响应为 202 时调用它并不意味着调用它，而是意味着当连接过早终止时调用它在写入响应时。

恐怕没有解决此问题的方法，除非您编写一些带有某种轮询的低级网络编程。但我不建议你这样做。

我建议您重新考虑处理此故障的方式。