资料内容:
前言
Netty是一个高性能、异步事件驱动的网络应用框架,用于快速开发可维护的高性能协议服务器和客户
端。它的服务启动过程涉及多个组件和步骤,下面我将对Netty的服务启动过程进行详细的源码解析。
简单Netty服务器启动代码示例
public class NettyServer {
public void start() throws Exception {
// 初始化BossGroup和WorkerGroup线程池
EventLoopGroup bossGroup = new NioEventLoopGroup();
EventLoopGroup workerGroup = new NioEventLoopGroup();
try {
// 初始化ServerBootstrap
ServerBootstrap b = new ServerBootstrap();
b.group(bossGroup, workerGroup)
.channel(NioServerSocketChannel.class)
.childHandler(new ChannelInitializer<SocketChannel>() {
@Override
public void initChannel(SocketChannel ch) throws Exception {
// 添加自定义的ChannelHandler处理业务逻辑
ch.pipeline().addLast(new MyChannelHandler());
}
})
.option(ChannelOption.SO_BACKLOG, 128)
.childOption(ChannelOption.SO_KEEPALIVE, true);
// 绑定端口并启动服务
ChannelFuture f = b.bind(8080).sync();
// 等待服务关闭
f.channel().closeFuture().sync();
} finally {
// 释放资源
bossGroup.shutdownGracefully();
workerGroup.shutdownGracefully();
}
}
public static void main(String[] args) throws Exception {
NettyServer server = new NettyServer();
server.start();
}
}
class MyChannelHandler extends SimpleChannelInboundHandler<ByteBuf> {
// 实现相关的事件处理逻辑
@Override
protected void channelRead0(ChannelHandlerContext ctx, ByteBuf msg) throws
Exception {
// 处理接收到的数据
}
}
主线
main线程:
创建NioEventLoopGroup、创建NioEventLoop
创建 selector
创建 server socket channel
初始化 server socket channel
给 server socket channel 从 boss group 中选择一个 NioEventLoop
boss 线程
将 server socket channel 注册到选择的 NioEventLoop 的 selector
绑定地址启动
注册接受连接事件(OP_ACCEPT)到 selector 上
NioEventLoopGroup初始化
NioEventLoopGroup 初始化的基本过程:
EventLoopGroup(其实是MultithreadEventExecutorGroup)内部维护一个类为EventExecutor[]
children 数组,其大小是nThreads;
在MultithreadEventExecutorGroup 中会调用newChild()抽象方法来初始化children 数组;
在NioEventLoopGroup 中具体实现newChild()方法,该方法返回一个NioEventLoop 实例。
初始化NioEventLoop 主要属性:
provider:在NioEventLoopGroup 构造器中通过SelectorProvider 的provider()方法获取
SelectorProvider。
selector:在NioEventLoop 构造器中调用selector = provider.openSelector()方法获取Selector
对象。