Netty 源码共读（一）服务端启动流程

站长

2023年01月03日 13:05 · 阅读数 41

前言

作为一个基本没有怎么系统性探索过源码的人来说，借此活动机会，也来简单学一下源码的阅读。

文明和谐，不喜勿喷

文章导读

📖 阅读本文，你将跟随我一起了解到

克隆并运行测试张师傅给出的demo

通过示例代码探索 Netty 服务端的启动流程

运行示例demo

学习源码，必不可少的我们要从一个简单的demo来入手。这里我们直接使用领读员张师傅在活动的给出的代码

克隆项目并运行

克隆项目

git clone https://github.com/arthur-zhang/netty-study.git

或者直接在IDEA中新建

Netty 源码共读（一）服务端启动流程

运行项目

找到Myserver,并运行该项目。

Netty 源码共读（一）服务端启动流程

这个服务只是个服务端。我们使用张师傅推荐的工具来充当客户端进行测试，这里选择了nc工具

Linux 下可以直接使用netcat命令。Windows下没有这个命令，需要自己安装。nc下载地址

解压文件夹，并将解压后的文件夹地址，加入到系统的环境变量即可。

Netty 源码共读（一）服务端启动流程

至此，我们已经成功的运行该示例项目，并简单测试了代码的作用

一个简单的Echo 服务。返回向服务端发送的消息。

下面，就让我们通过该服务端示例代码，来探索下Netty服务端的启动流程

服务端启动流程探索

代码

public class MyServer {
    public static void main(String[] args) throws InterruptedException {
        //引导类 ①
        ServerBootstrap serverBootstrap = new ServerBootstrap();
        //IO模型 ②
        serverBootstrap.channel(NioServerSocketChannel.class); 
        //临时存在已完成三次握手请求队列的的最大长度 ③
        serverBootstrap.option(NioChannelOption.SO_BACKLOG, 511);
        //开启 Nagle 算法
        serverBootstrap.childOption(NioChannelOption.TCP_NODELAY, true);
        //设置Log级别
        serverBootstrap.handler(new LoggingHandler(LogLevel.INFO));
        //监听端口，处理接收新的连接的 线程组 ④
        NioEventLoopGroup bossGroup = new NioEventLoopGroup(0, new DefaultThreadFactory("boss"));
        //处理每一条连接的相关IO的线程组
        NioEventLoopGroup workGroup = new NioEventLoopGroup(0, new DefaultThreadFactory("worker"));
   
        try {
            // 配置两个主要的线程组 ⑤
            serverBootstrap.group(bossGroup, workGroup);
            //Netty对 NIO 类型连接的的抽象和处理。
            final MyEchoServerHandler serverHandler = new MyEchoServerHandler();
            serverBootstrap.childHandler(new ChannelInitializer<NioSocketChannel>() {
                @Override
                protected void initChannel(NioSocketChannel ch) {
                    ChannelPipeline pipeline = ch.pipeline();
                    pipeline.addLast(new ServerIdleCheckHandler()); //⑥
                    pipeline.addLast(new LoggingHandler(LogLevel.INFO));
                    pipeline.addLast(serverHandler);
                }
            });
            //绑定启动端口 ⑦
            ChannelFuture f = serverBootstrap.bind(8888).sync();
            f.channel().closeFuture().sync();
        } finally {
            bossGroup.shutdownGracefully();
            workGroup.shutdownGracefully();
        }
    }
}

下面我们就通过这个代码，一步步的分析和了解他的过程。

ServerBootstrap

在代码的一开始，我们先定义了一个ServerBootstrap类。这个类的主要作用是来 完成服务器端的 Netty 初始化。

.channel 设置netty的ServerSocketChannel模型

在②中，我们设置了

 serverBootstrap.channel(NioServerSocketChannel.class);

从源码io.netty.bootstrap.AbstractBootstrap#channel看该方法的调用 Netty 源码共读（一）服务端启动流程该channel方法，创建了并返回了一个channelFactory的工厂实例ReflectiveChannelFactory。咋启动的时候通过这个去创建相应的channel实例。

常用的类型

NioSocketChannel/OioSocketChannel ：用于客户端的异步非阻塞/同步阻塞类型
NioServerSocketChannel/OioServerSocketChannel ：用于服务端的异步非阻塞/同步阻塞模型

.option 设置服务端接受TCP连接的相关设置

在③的示例代码中NioChannelOption.SO_BACKLOG,这个参数设置了服务端接受连接的队列的最大值，它其实对应的就是是tcp/ip协议listen函数中的backlog参数，函数listen(int socketfd,int backlog)用来初始化服务端可连接队列。

因为服务端处理客户端连接请求是顺序处理的，所以同一时间只能处理一个客户端连接，多个客户端来的时候，服务端将不能处理的客户端连接请求放在队列中等待处理，backlog参数指定了队列的大小。当超过这个限制的时候，它就是拒绝客户端的连接。

当然，他不止这一个参数，还有SO_REUSEADDR,SO_KEEPALIVE等等。