Netty源码小窥探（二）

本文主要是介绍Netty源码小窥探（二），希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！

Netty集合链接

Netty源码小窥探（一）-CSDN博客

上次介绍了NioEventLoopGroup的子线程数目决定和创建流程，今天来讲

服务端启动配置ServerBootstrap--group方法和channel方法

首先还是摆上我们的案例代码

public final class EchoServer {static final boolean SSL = System.getProperty("ssl") != null;static final int PORT = Integer.parseInt(System.getProperty("port", "8007"));public static void main(String[] args) throws Exception {// Configure SSL.  对SSL进行相关配置final SslContext sslCtx;if (SSL) {SelfSignedCertificate ssc = new SelfSignedCertificate();sslCtx = SslContextBuilder.forServer(ssc.certificate(), ssc.privateKey()).build();} else {sslCtx = null;}// Configure the server.  开始和我们之前一样，正常配置服务端EventLoopGroup bossGroup = new NioEventLoopGroup(1);EventLoopGroup workerGroup = new NioEventLoopGroup();try {ServerBootstrap b = new ServerBootstrap();b.group(bossGroup, workerGroup).channel(NioServerSocketChannel.class).option(ChannelOption.SO_BACKLOG, 100).handler(new LoggingHandler(LogLevel.INFO)).childHandler(new ChannelInitializer<SocketChannel>() {@Overridepublic void initChannel(SocketChannel ch) throws Exception {ChannelPipeline p = ch.pipeline();if (sslCtx != null) {p.addLast(sslCtx.newHandler(ch.alloc()));}p.addLast(new LoggingHandler(LogLevel.INFO));//p.addLast(new EchoServerHandler());}});// Start the server.ChannelFuture f = b.bind(PORT).sync();// Wait until the server socket is closed.f.channel().closeFuture().sync();} finally {// Shut down all event loops to terminate all threads.bossGroup.shutdownGracefully();workerGroup.shutdownGracefully();}}
}

本次我们关注的代码部分为下面这部分，设计到group方法和channel方法

ServerBootstrap b = new ServerBootstrap();
b.group(bossGroup, workerGroup).channel(NioServerSocketChannel.class)

首先服务端的启动配置参数serverBootStrap的类型---就是ServerBootStrap类型

我们调用其group（）方法 传入我们创建的两个NioEventLoopGroup类型的事件循环组，bossGroup和workerGroup两个参数，其方法内部代码如下,

在Netty的group的方法中，习惯将bossGroup称之为parentGroup，将WorkerGroup称之为childrenGroup

该方法做了两件事，将我们的bossGroup / parentGroup交给父类的group方法处理，而将childrenGroup / WorkerGroup赋值给自己的成员变量，也是EventLoopGroup 类型的 childGroup，这样就将启动配置对象和两个NioEventLoopGroup产生关联了

public ServerBootstrap group(EventLoopGroup parentGroup, EventLoopGroup childGroup) {super.group(parentGroup);if (this.childGroup != null) {throw new IllegalStateException("childGroup set already");}this.childGroup = ObjectUtil.checkNotNull(childGroup, "childGroup");return this;}

然后是channel方法channel(NioServerSocketChannel.class) 我们知道channel方法是设置通道类型的，服务端自然是NioServerSocketChannel，通过这个配置可以让bootStrap和Channel产生联系，

那么，这个联系时如何产生的呢？为何传一个类类型就可以产生联系呢？底层实则采用了反射技术，引导类通过内部的ChannelFactory根据传入的类对象创建出对应的类型的Channel

我们首先看到channl()方法内部，可以看到这个方法返回的是一个channelFactory的对象，该对象的创建是依赖于一个ReflectiveChannelFactory的接口，我们写入的类对象也是传入了这个接口的构造中

然后我们进入到这个类的构造中查看，可以看到

第一行ObjectUtil.checkNotNull(clazz, "clazz"); 判断参数部不为null

第二行 this.constructor = clazz.getConstructor(); 就是通过类对象，使用getConstructor()方法拿到类的构造方法，存入到自己的成员构造方法中，从而后续可以利用这个成员构造方法构造出我们指定的类对象

public ReflectiveChannelFactory(Class<? extends T> clazz) {ObjectUtil.checkNotNull(clazz, "clazz");try {this.constructor = clazz.getConstructor();} catch (NoSuchMethodException e) {throw new IllegalArgumentException("Class " + StringUtil.simpleClassName(clazz) +" does not have a public non-arg constructor", e);}}

但是需要注意的是，channl（）方法设置的只是ChannelFactory对象，真正的channel构造是在bind（）方法的时候才会创建的 （对于bind方法的解析，后续会写的，这里暂时不展开讨论了）

所以可以很明确的知道，bootStrap的中对于Channel类型的决定和channel的构造，是在channel（）方法中通过反射机制让channelFactore获得对应channel的构造方法进行绑定，然后再bind方法中才会被channelFactory构造

服务端启动配置ServerBootstrap--handelr方法和childHandler方法

我们知道 handler和childHandler都是设置通道初始化相关的，和绑定我们的自定义handler息息相关，两者的区别就是，handler是帮助bossGroup也就是parentGroup进行通道初始化的，而childHandler是个workerGroup也就是childGroup设置通道初始化的

这里关注的代码部分如下

.handler(new LoggingHandler(LogLevel.INFO)).childHandler(new ChannelInitializer<SocketChannel>() {@Overridepublic void initChannel(SocketChannel ch) throws Exception {ChannelPipeline p = ch.pipeline();if (sslCtx != null) {p.addLast(sslCtx.newHandler(ch.alloc()));}p.addLast(new LoggingHandler(LogLevel.INFO));//p.addLast(new EchoServerHandler());}});

首先是handler方法的源码 跳转到AbstraceBootstrap抽象类的handler方法中，该方法的内容就是将我们传入的Handler对象赋值给自己的成员变量ChannelHandler handler

而childrenHandler方法的地层逻辑就是调用ServerBootstrap中的childHandler方法，方法内部的逻辑也就是将传入childHandler对象赋值给自己的成员变量ChannelHandler childHandler

(我们的new的channel初始化类ChannelInitializer继承自ChannelInboundHandlerAdapter，ChannelInboundHandlerAdapter接口的父接口就是ChannelHandler 所以自然能传入参数 子接口向上兼容)

ChannelInitializer<C extends Channel> extends ChannelInboundHandlerAdapter

而ServerBootstrap类是继承自AbstraceBootstrap抽象类的，也就是说childHandler方法这个方法是子类ServerBootstrap特有的，而handler方法是AbstraceBootstrap及其子类共有的

这个其实也很好理解，因为我们的服务端的启动配置ServerBootStrap和客户端的BootStrap都需要进行配置group的handler，但是服务端需要配置两个group的handler，bossGroup/parentGroup 和 workerGroup/childGroup 但是客户端BootStrap只需要配置一个parentGroup的handler，所以Netty在设计的时候，就将都需要配置的parentGroup的handler的配置方法handler写在了ServerBootStrap和BootStrap的父类AbstraceBootstrap中，而对于服务端需要配置的childGroup的handler的配置方法chirldHandler方法，单独写在ServerBootStrap中进行单独的配置

这篇关于Netty源码小窥探（二）的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！

---