Netty中的工作组与处理程序线程

Question

我正在设置一个Netty服务器来接受多个传入的客户端连接，这将反过来做一些处理，但对wroker线程组vs Handler线程感到困惑

我尝试分配10个工作线程和20个处理线程，如下所示。

EventLoopGroup bossGroup = new NioEventLoopGroup(1);
EventLoopGroup workerGroup = new NioEventLoopGroup(10);
EventExecutorGroup handlerThread = new DefaultEventExecutorGroup(20);

try {
    ServerBootstrap serverBootstrap = new ServerBootstrap();
    serverBootstrap.group(bossGroup, workerGroup);
    serverBootstrap.channel(NioServerSocketChannel.class);
    serverBootstrap.localAddress(new 
    InetSocketAddress(hostName,Integer.parseInt(port)));

    // initialize a new child handler for incoming request
    logger.debug("Incoming request from TCP client...assigning a new Server Handler");
    serverBootstrap.childHandler(new ChannelInitializer<SocketChannel>() {
    protected void initChannel(SocketChannel socketChannel) throws Exception 
    {
    socketChannel.pipeline().addLast(handlerThread,new NettyServerHandler());
                }
            });
            ChannelFuture channelFuture = serverBootstrap.bind().sync();
            channelFuture.channel().closeFuture().sync();

        } catch (Exception e) {
            logger.error("Unable to initialize TCP Server");
        } 

我无法理解工作组的任务和创建新服务器处理程序之间的区别。据我所知，处理器线程池将分配给NettyServerHandler的每个实例。但是，创建由10个线程组成的工作组池的作用是什么呢？

Answer 1

您不必创建一个包含10个线程的EventLoopGroup来接受10个客户端。只需在bossGroup上传递一个线程，而在workerGroup上传递一个线程就足够了：

EventLoopGroup bossGroup = new NioEventLoopGroup(1);
EventLoopGroup workerGroup = new NioEventLoopGroup();

确保ServerBootstrap（）。childOption（ChannelOption.SO_BACKLOG，10）设置为至少10以接受10个客户端。

所以EventLoopGroup的角色是接受我所知道的客户端。另一方面，ServerHandler用于接收数据并管理如何处理数据，您可以通过覆盖ChannelHandlerAdapter方法来拦截是否有人加入或连接是否有任何问题。

我希望我理解你的问题并帮助你理解它，

问候