java - Netty应用程序中请求和响应之间的延迟

Question

我有一个扩展 SimpleChannelInboundHandler<HttpRequest> 的处理程序。在发送特定请求的响应之前需要进行延迟，为此我使用方法 channelRead0(ChannelHandlerContext ctx, HttpRequest msg) 中的下一个代码。 :

ctx.executor().schedule(() -> ctx.write(response), 3, TimeUnit.SECONDS);

但它不起作用。我做错了什么以及如何解决这个问题？

Answer 1

我认为你需要将其更改为:

ctx.executor().schedule(() -> ctx.writeAndFlush(response), 3, TimeUnit.SECONDS);