Netty为什么通道尚未连接

Question

客户端通道在服务器入站通道激活方法中初始化。我可以看到pcap已经完成了三次握手（253是本地主机，15是远程主机）

但是当写入客户端通道时，它抛出

java.nio.channels。NotYetConnectedException:io.netty.channel.AbstractChannel$AbstractUnsafe处为null。flush0（）（未知源）

根据我的理解，客户端通道应该处于活动状态，因为3次握手意味着客户端通道已经准备好发送数据包。但是通过评估clientChannel.isActive（），结果是错误的，奇怪的。

服务器入站通道：

Channel clientChannel;
@Override
public void channelActive(ChannelHandlerContext ctx) {
    final Channel inboundChannel = ctx.channel();

    try {
        Bootstrap b = new Bootstrap();
        b.group(inboundChannel.eventLoop())
            .channel(inboundChannel.getClass())
            .handler(new SomeClientChannelInitializer(ctx));

        // Make the connection attempt.
        ChannelFuture f = b.connect(host, port);
        clientChannel = f.channel();
    } catch (Exception e) {// no exception}
}

@Override
public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception {
    log.info("receive: {}", msg);
    clientChannel.writeAndFlush(msg -> this::pojo);
}

编辑：我通过添加wait解决了这个问题

  f = b.connect(host, port);
  clientChannel = f.channel();
  try {
      f.await(3L, TimeUnit.SECONDS);
      boolean success = clientChannelFuture.isSuccess();

我不确定这是否合适，官方代理示例中没有这一点。

Answer 1

您要么需要通过附加到连接ChannelFuture的ChanneFutureListener编写，要么需要sync（）/等待（）在上面。

请记住，netty中的一切都是异步的，这意味着当连接方法返回时，您触发写入时，通道可能尚未完全连接。