本文共 2167 字，大约阅读时间需要 7 分钟。

Netty线程处理机制简解

在Netty的服务器开发中，处理请求和返回响应的线程机制是一个关键问题。本文将从理论到实践，详细解析Netty中Handler的线程执行情况。

默认线程机制 Netty的默认线程处理机制非常简洁。无论是输入Handler、输出Handler，还是内置的HeadContext，所有操作都由同一个IO线程执行。这个线程是由EventLoop负责，用户在使用Netty时无需手动指定。

代码示例 以下代码展示了一个基本的EchoServer：

EventLoopGroup bossGroup = new NioEventLoopGroup(1);
EventLoopGroup workerGroup = new NioEventLoopGroup();
ServerBootstrap serverBootstrap = new ServerBootstrap();
serverBootstrap.group(bossGroup, workerGroup)
    .channel(NioServerSocketChannel.class)
    .handler(new LoggingHandler(LogLevel.INFO))
    .childHandler(new ChannelInitializer
   
    () {
        protected void initChannel(NioSocketChannel ch) {
            ChannelPipeline pipeline = ch.pipeline();
            pipeline.addLast(new StringDecoder());
            pipeline.addLast(new StringEncoder());
            pipeline.addLast(new ServerOutHandler());
            pipeline.addLast(new ServerInHandler());
        }
    });
ChannelFuture future = serverBootstrap.bind("127.0.0.1", 8080).sync();
future.channel().closeFuture().sync();
   

在这个代码中，ServerInHandler和ServerOutHandler的方法都在IO线程执行。

线程检测 通过查看Handler中的日志，可以确认线程信息：

ServerInHandler:

@Slf4j
@Override
public void channelActive(ChannelHandlerContext ctx) throws Exception {
    System.out.println("ServerInHandler: " + Thread.currentThread().getName());
    ctx.channel().writeAndFlush("蜀道之难");
}

ServerOutHandler:

@Slf4j
@Override
public void write(ChannelHandlerContext ctx, Object msg, ChannelPromise promise) throws Exception {
    System.out.println("ServerOutHandler: " + Thread.currentThread().getName());
    ctx.write(msg, promise);
}

HeadContext内部：

@Override
public void write(ChannelHandlerContext ctx, Object msg, ChannelPromise promise) throws Exception {
    System.out.println("HeadContext: " + Thread.currentThread().getName());
    unsafe.write(msg, promise);
}

由此可见，所有Handler方法均在IO线程中执行。

线程池指定 如果要手动指定线程，需要在Handler中使用ThreadFactory或线程池。例如，改动后的输出Handler：

@Slf4j
@Override
public void write(ChannelHandlerContext ctx, Object msg, ChannelPromise promise) {
    System.out.println("ServerOutHandler: " + Thread.currentThread().getName());
    ctx.write(msg, promise);
}

此时，输出Handler的线程将与输入Handler不同。