Netty 将并发请求放入队列

Question

我的 netty 有问题，我有一个带有 FutureChannel 和 Handlers 的服务器

     ServerBootstrap b = new ServerBootstrap();
        b.group(bossGroup, workerGroup)
                .channel(NioServerSocketChannel.class)
                .childHandler(new ChannelInitializer<SocketChannel>() {
                    @Override
                    public void initChannel(SocketChannel ch) throws Exception {
                        ch.pipeline().addLast(new MyDecoder(service),new MyHander(),);

                    }

                })

我想让这个服务器成为单线程并将并发请求放入队列，我知道使用适当的调度程序应该是可能的，但我对此很陌生，不知道如何实现这一点。 感谢您的回答。

Answer 1

制作单线程处理程序很简单。

你需要为此定义另一个EventLoopGroup变量，这个变量将是我们的单线程执行器组，所以我们将线程数设置为1：

EventLoopGroup applicationGroup = new NioEventLoopGroup(1);

然后我们可以在ChannelInitializer 中使用这个组来安排任务，我们为此使用addLast(EventExecutorGroup, ChannelHandler...)：

ServerBootstrap b = new ServerBootstrap();
    b.group(bossGroup, workerGroup)
            .channel(NioServerSocketChannel.class)
            .childHandler(new ChannelInitializer<SocketChannel>() {
                @Override
                public void initChannel(SocketChannel ch) throws Exception {
                    ch.pipeline().addLast(new MyDecoder(service))
                    ch.pipeline().addLast(applicationGroup, new MyHander());

                }

            })

使用单独的applicationGroup 构建管道后，每个请求都将以单线程方式进入管道，并且可以使用简单的调试语句确认该行为。这种构造方法的优点是，您可以简单地假设处理程序中有一个线程，同时仍然以多线程和高性能对协议进行解码。

当您关闭服务器时，您应该确保正确终止 applicationGroup，就像您对 workerGroup 和 bossgroup 所做的那样