当前位置: 首页 > 知识库问答 >
问题:

为什么sync()在频道未来的netty中不生效

郎俊雅
2023-03-14

我正在学习Netty,我不太了解ChannelFuture的同步方法,这是我的示例:

public class EchoServer {
    private final int port;

    public EchoServer(int port) {
        this.port = port;
    }

    public static void main(String[] args) throws Exception {
        if (args.length != 1) {
            System.err.println("Usage: " + EchoServer.class.getSimpleName() + " <port>");
            return;
        }

        int port = Integer.parseInt(args[0]);

        new EchoServer(port).start();
    }

    public void start() throws Exception {
        // final EchoServerHandler serverHandler = new EchoServerHandler();
        EventLoopGroup group = new NioEventLoopGroup();

        try {
            ServerBootstrap b = new ServerBootstrap();
            b.group(group).channel(NioServerSocketChannel.class).localAddress(new InetSocketAddress(port)).childHandler(new ChannelInitializer<SocketChannel>() {

                @Override
                protected void initChannel(SocketChannel ch) throws Exception {
                    // ch.pipeline().addLast(serverHandler);
                }
            });

            ChannelFuture f = b.bind().sync();
            f.channel().closeFuture().sync();
        } finally {
            group.shutdownGracefully().sync();
        }
    }
}



public class EchoClient {
    private final String host;
    private final int port;

    public EchoClient(String host, int port) {
        this.host = host;
        this.port = port;
    }

    public void start() throws Exception {
        EventLoopGroup group = new NioEventLoopGroup();

        try {
            Bootstrap b = new Bootstrap();
            b.group(group).channel(NioSocketChannel.class).remoteAddress(new InetSocketAddress(host, port)).handler(new ChannelInitializer<SocketChannel>() {

                @Override
                protected void initChannel(SocketChannel ch) throws Exception {
                    // ch.pipeline().addLast(new EchoClientHandler());
                }
            });


            ChannelFuture f = b.connect().sync().addListener(future -> {

                   if(future.isSuccess()) {

                       System.out.println(port + " bind success");

                   } else{

                       System.err.println(port + " bind fail");

                   }

               });

            System.out.println("aaa");

            f.channel().closeFuture().sync();
        } finally {
            group.shutdownGracefully().sync();
        }
    }

    public static void main(String[] args) throws Exception {
        if (args.length != 2) {
            System.err.println("Usage: " + EchoClient.class.getSimpleName() + " <host> <port>");
            return;
        }

        String host = args[0];
        int port = Integer.parseInt(args[1]);

        new EchoClient(host, port).start();
    }
}

我的问题是,无论我在EchoClient中删除了什么sync()。ChannelFuture的类f=b.connect()。无论是否为sync(),结果总是:aaa 8811 bind success

在我看来,如果添加sync(),结果应该是:8811 bind success aaa

由于主线程会等待通道连接,

如果我删除 sync(),结果应该是:aaa 8811 绑定成功

由于connect()是异步

为什么我错了?

共有1个答案

郑翰海
2023-03-14

sync()将在操作完成后立即解除屏蔽,然后EventLoop将通知所有附加的监听器到ChannelFuture。由于您的主线程和EventLoop线程是不同的,因此您很有可能会在ChannelFutureListener中之前在主线程中看到System.out.println(…)

 类似资料:
  • 客户端通道在服务器入站通道激活方法中初始化。我可以看到pcap已经完成了三次握手(253是本地主机,15是远程主机) 但是当写入客户端通道时,它抛出 java.nio.channels。NotYetConnectedException:io.netty.channel.AbstractChannel$AbstractUnsafe处为null。flush0()(未知源) 根据我的理解,客户端通道应该

  • 我想用Netty实现Slack API客户端。Slack有几十种方法,每种方法都有不同的URL和响应格式。 我应该为每种方法创建一个通道并重复使用单个引导程序,还是应该为所有通信使用单个通道?实际上,我做这个项目是为了学习Netty,我无法从文档和示例(这些都是非常基本的)中理解策略。 对于通道每API方法,我可以使用不同的处理程序来处理不同的数据类型,但对于单个通道,我无法做到这一点,是吗? 我

  • 问题内容: 我正在使用以下示例代码创建频道: 所以在这里我得到了一个通道(将来的通道),但是我的应用程序吞吐量会很高,所以我认为一个通道是不够的,所以请让我知道我如何创建通道池。 我正在使用netty 4.0 问题答案: 请参阅http://netty.io/news/2015/05/07/4-0-28-Final.html上的部分

  • 我正在使用Netty 4(alpha8)。 我想在管道中的ChannelHanders之间共享一些数据,在Netty的以前版本中,我想我会使用ChannelLocal,有没有Netty 4的等效版本?

  • 我刚开始和内蒂一起工作。我已经有了一个服务器,我正在为一个客户端写代码。 在客户端,我用下面的代码为ClientBootstrap对象设置了一个新的PipelineFactory 其中ResponseHandler()是我扩展SimpleChannelHandler的类。 我想找到频道ID。我做到了。 但它会抛出IllelgalStateException并表示我无法调用getPipeline()

  • 在Netty 4“代理”示例中,通道自动读取选项已被禁用: 如果注释了< code>childOption(ChannelOption。AUTO_READ,false),代理示例将无法工作。更详细地说,在类< code > hexdumproxyfrontendhandler 的方法< code>channelRead中,< code>outboundChannel将总是不活动的。 我研究了Net