netty启动流程图

2025-05-19 13:42:52   0  举报





仅支持查看

Netty作为高性能的异步事件驱动的网络应用框架，其启动流程是基于一系列初始化和配置步骤构建的。在启动流程图中，我们可以看到以下核心内容： 1. 创建`ServerBootstrap`实例，它是Netty服务端的启动辅助类。 2. 通过`bossGroup`和`workerGroup`参数设置两个NIO线程组：前者负责接收新的连接，后者负责处理实际的读写操作。 3. 使用`channel()`方法选择服务器端的通道实现（如`NioServerSocketChannel`）。 4. 利用`childHandler()`设置处理客户端连接数据读写的`ChannelHandler`。 5. 通过`option()`和`childOption()`方法设置网络参数，如TCP/IP参数。 6. 使用`bind()`方法将服务绑定至指定端口，并执行异步监听操作。修饰语可以包括"灵活配置"和"异步非阻塞"，描述Netty启动流程的灵活性和其非阻塞I/O的高性能特性。生成的描述通常包含如下关键信息，虽然您的要求是在280字以内，但让我们扩展一点以保持信息的完整性： Netty的启动流程灵活且高效，从初始化`ServerBootstrap`到配置线程组和通道类型，通过`childHandler()`来设置数据处理逻辑，并细致调整网络参数。所有这些步骤都是为了构建一个高性能、异步非阻塞的服务器应用。"

java

作者其他创作

大纲/内容

initAndRegister

OP_READ｜OP_ACCEPT

childGroup.register(child).addListener

业务handler

将run任务提交给eventloop

pipeline.invokeHandlerAddedIfNeeded();

p.addLast(new ChannelInitializer<Channel>() {...})

client

此时的pipeline是当前客户端连接的pipeline，即之前的socketchannel中的pipeline

pipeline.fireChannelRead(readBuf.get(i));

tail

循环执行

NioEventLoopGroup继承MultithreadEventLoopGroupnext().register(channel)

AbstractEventExecutorsafeExecute(Runnable task)task.run()

ch.unsafe().forceFlush();

initChannel

processSelectedKeysOptimized

callHandlerAddedForAllHandlers

unsafe.read();

死循环for (;;)监听io事件；

invokeChannelRegistered

pipeline中所有的handlerd的channelread方法

通过excutor启动一个线程执行

runAllTasks();

unsafe.finishConnect();

nioeventloop继承SingleThreadEventExecutor

pipeline.fireChannelRegistered();

ServerBootstrapAcceptor

head

select(wakenUp.getAndSet(false));

循环处理selectedKeys

客户端消息ON_READ事件

执行

调用每个handler的handlerAdded

注册当前客户端的socketChannel到workgroup组的一个eventloop

SocketChannel封装成NioSocketChannel

初始化：new NioEventLoopGroup（）

group是bossgroup，所以是将socketchannel注册到bossgroup中的一个eventloop上

先添加，后执行

客户端连接 ON_ACCEPT事件

AbstractNioByteChannel.read

bossGroup

如果是ON_ACCEPT事件pipeline是ServerSocketChannel的ON_READ事件，pipeline是当前客户端的socketChennel的

channel.pipeline();

OP_CONNECT

OP_WRITE

child.pipeline().addLast(childHandler);

SocketChannel ch =SocketUtils.accept(javaChannel());

SingleThreadEventExecutor.this.run();即nioeventloop.run

for循环readBuf.size()；readBuf存的是SocketChannel

pipeline.fireChannelRead(byteBuf);

doReadMessages(readBuf);

SingleThreadEventExecutor.execute(Runnable task)；addTask(task);

ch.configureBlocking(false);

ServerBootstrap.init(channel)NioServerSocketChannel

NioServerSocketChannel的pipeline

非阻塞

NioEventLoop.register(channel)

和serversocketchannel的regiester一样

buf.add(font color=\"#ff0000\

for (;;) select阻塞，直到超时或者channel有就绪事件后跳出

ChannelInitializer

protected AbstractChannel(Channel parent) { this.parent = parent; this.id = this.newId(); this.unsafe = this.newUnsafe(); this.pipeline = this.newChannelPipeline(); }

config().group().register(channel)

new ChannelInitializer<Channel>() {initChannel}

register0()

workGroup

startThread();

AbstractNioMessageChannel的NioMessageUnsafe，获取pipeline，此时只有serversocketchannel有

bind（端口号）

channel注册到selector

AbstractBootstrap的initAndRegister的config().group().register(channel)

super(parent)ch.configureBlocking(false);（非阻塞）

调用每个handler的channelRegistered

ServerBootstrap