江苏龙网

  1. 主页 > 生活百科 > >

netty 服务端启动流程源码详解

Netty

ServerBoostrap用户可以通过 netty 的 ServerBoostrap 启动服务端，时序图如下：

netty 服务端启动流程源码详解

文章插图
 
输入图片说明
入门例子为了便于大家理解，我们把服务端启动的代码放在下面：
public void run() throws Exception {    /**     * EventLoopGroup 是用来处理I/O操作的多线程事件循环器     * bossGroup: 用来接收进来的连接     * workerGroup: 用来处理已经被接收的连接     * 一旦‘boss’接收到连接，就会把连接信息注册到‘worker’上 。     */    EventLoopGroup bossGroup = new NioEventLoopGroup(); // (1)    EventLoopGroup workerGroup = new NioEventLoopGroup();    try {        /**         * ServerBootstrap 是一个启动 NIO 服务的辅助启动类 。         * 你可以在这个服务中直接使用 Channel，但是这会是一个复杂的处理过程，在很多情况下你并不需要这样做 。         */        ServerBootstrap b = new ServerBootstrap(); // (2)        b.group(bossGroup, workerGroup)                //指定使用 NIOServerSocketChannel 类来举例说明一个新的 Channel 如何接收进来的连接 。                .channel(NioServerSocketChannel.class) // (3)                /**                 * 这里的事件处理类经常会被用来处理一个最近的已经接收的 Channel 。                 * ChannelInitializer 是一个特殊的处理类，他的目的是帮助使用者配置一个新的 Channel 。                 * 也许你想通过增加一些处理类比如DiscardServerHandler 来配置一个新的 Channel 或者其对应的ChannelPipeline 来实现你的网络程序 。                 * 当你的程序变的复杂时，可能你会增加更多的处理类到 pipeline 上，然后提取这些匿名类到最顶层的类上 。                 */                .childHandler(new ChannelInitializer<SocketChannel>() { // (4)                    @Override                    public void initChannel(SocketChannel ch) throws Exception {                        ch.pipeline().addLast(new DiscardServerHandler());                    }                })                /**                 * 你可以设置这里指定的 Channel 实现的配置参数 。                 * 我们正在写一个TCP/IP 的服务端，因此我们被允许设置 socket 的参数选项比如tcpNoDelay 和 keepAlive 。                 * 请参考 ChannelOption 和详细的 ChannelConfig 实现的接口文档以此可以对ChannelOption 的有一个大概的认识 。                 *                 * option() 是提供给 NioServerSocketChannel 用来接收进来的连接 。                 * childOption() 是提供给由父管道 ServerChannel 接收到的连接，在这个例子中也是 NioServerSocketChannel 。                 */                .option(ChannelOption.SO_BACKLOG, 128)          // (5)                .childOption(ChannelOption.SO_KEEPALIVE, true); // (6)        /**         * 剩下的就是绑定端口然后启动服务 。这里我们在机器上绑定了机器所有网卡上的 8080 端口 。         * 当然现在你可以多次调用 bind() 方法(基于不同绑定地址) 。         */        // 绑定端口，开始接收进来的连接        ChannelFuture f = b.bind(port).sync(); // (7)        System.out.println("DiscardServer start...");        // 等待服务器  socket 关闭  。        // 在这个例子中，这不会发生，但你可以优雅地关闭你的服务器 。        f.channel().closeFuture().sync();    } finally {        workerGroup.shutdownGracefully();        bossGroup.shutdownGracefully();    }}


推荐阅读


上一篇：Netty 实战：如何实现 HTTP 服务器？

下一篇：Netty 实战：如何实现文件服务器？