java - Play Framework 2：在分块响应中处理客户端断开连接

Question

我正在使用分块编码将一些实时数据转发给 Web 客户端。

通过以下方式，我可以做出 HTTP 流式响应，

public Result action() {
    return ok(new StringChunks() {
        public void onReady(final Out<String> out) {
            openStream().onData(new Consumer<String>() {
                public void accept(String string) {
                    out.write(string);
                }
            }
        }
    }
}

但是我需要在客户端断开连接后清理一些资源。（例如关闭浏览器窗口或当流到达 EOF 时）

使用 WebSocket 时，我可以使用Iteratee .mapDone 检测客户端断开连接。

使用Chunks时是否有等效的方法来检测它？

谢谢

Answer 1

嗯，刚刚想通了。

Results.Chunked.Out<A>对象具有onDisconnected(Callback0)我可以注册断开回调的方法。所以

public Result action() {
    return ok(new StringChunks() {
        public void onReady(final Out<String> out) {
            out.onDisconnected(new F.Callback0() {
                public void invoke() throws Throwable {
                    // clean up things ...
                }
            }
            openStream().onData(new Consumer<String>() {
                public void accept(String string) {
                    out.write(string);
                }
            }
        }
    }
}