内蒂：ctx。通道（）。从Netty的工作线程以外的线程发送数据时，writeAndFlush（out）不工作

Question

我在我的一个项目中使用Netty。有一个流程，我必须从其他线程（其他netty的工作线程）向客户端发送一些数据：

final ChannelFuture writeAndFlushFuture = ctx.channel().writeAndFlush(out)
                        .addListener(new GenericFutureListener<Future<? super Void>>() {
                            @Override
                            public void operationComplete(Future<? super Void> future) throws Exception {
                                LOGGER.info("=========> dsgdsfgdsfgdfsgdfsgsdgfd");
                            }
                        });

此外，我正在等待客户端接收到我的有效负载后的响应。我也将超时与它相关联，因此每当客户端在时间范围内没有回复时，我都会关闭来自服务器的上下文（假设连接错误）。

发生了一些奇怪的事情。每当我将有效负载发送给客户机时，我都不会在日志中打印它

dsgdsfgdsfgdfsgdfsgsdgfd

但是，由于超时，它是在我关闭连接之前打印的。我不确定我可能做错了什么，因为没有立即发送有效负载，而是在关闭连接之前。

这里会发生什么？

Answer 1

实际上，当我将对象写入上下文时，缺少了一个刷新：

ctx.writeAndFlush(commands);

现在，它工作正常。但奇怪的是，当在Netty的工作线程中执行时，即使没有刷新，它也可以正常工作。