netty线程模型

Posted 2022-01-26 vsop

启动ServerBootstrap时，由main（启动线程）初始化bossGroup和childGroup，将NioServerSocketChannel（监听的端口）注册boss NioEventloop,启动对应的thread。线程启动后监听连接（ServerBootstrapAcceptor.channelRead）。
有连接到来，将NioSocketChannel（建立的连接）注册到child NioEventloop，如果该NioEventloop未绑定线程，则启动线程。线程启动后监听该连接的read。

当有新的连接建立（channel），boss group中执行选择worker group中的NioEventLoop（next）。
boss group 开启worker线程：
默认ThreadPerTaskExecutor，每个NioEventloop创建一个线程。
SingleThreadEventExecutor.execute.startThread。
开启当前NioEventLoop的woker线程，执行NioEventLoop.run。

boss group addTask(accepted channel) 由worker group处理:
SingleThreadEventExecutor.execute.addTask。
将任务添加到当前NioEventLoop的taskQueue。

boss group: interest:accept ,connect 连接，把接收的连接注册到worker group。
worker group: interest:read,write 处理注册的channels。