Netty：使用 sync() 和 addListener() 的区别

Question

在服务器处理程序中，我有以下方法：

private void writeResponse(HttpObject currentObj, ChannelHandlerContext ctx) throws Exception {

    Promise<String> promise = client.run(); // client.run() will return a promise

    // the promise contains the result string I need for http response.

    promise.sync();

    // this method sends http response back, promise.getNow() is the content for the response.

    writeResponse(currentObj, ctx, promise.getNow()); 

}

client此方法是在从客户端（在代码中）获取一些数据后发送响应。当我使用浏览器对此进行测试时，我确实得到了响应内容。

但是，当我将其更改为：

private boolean writeResponse(HttpObject currentObj, ChannelHandlerContext ctx) throws Exception {

    Promise<String> promise = client.run();

    promise.addListener(new FutureListener<String>() {

        @Override

        public void operationComplete(Future<String> future) throws Exception {

            if (future.isSuccess()) {

                writeResponse(currentObj, ctx, future.getNow()); // (1)

            } else {

                writeResponse(currentObj, ctx, "FAILED");

            }

        }

    });

}

它不再起作用了。据我了解，它认为第二个也应该起作用，因为我已经确认代码确实进入了 (1) 块（if (future.isSuccess())块）。但是我在浏览器中没有得到任何响应。谁能解释一下或指出一些参考资料？我在文档中找到了await()和之间的比较，addListener但它让我感觉两者在功能上彼此相似。

Answer 1

问题是你只是调用write(...)你的ChannelFutureListener而不是writeAndFlush(...).&nbsp;因此，您的写入数据将永远不会刷新到套接字。channelReadComplete(...)可能会在执行之前触发，ChannelFutureListener因此您最终会遇到这种情况。所以让它writeAndFlush(...)在监听器中简短使用。