首页  思维导图  详情

netty

2023-02-14 20:38:02   6  举报





AI智能生成

netty

Netty3 源码分析

作者其他创作

大纲/内容

创建NioEventLoopGroup

没设置线程数为CPU的2倍吗，传了参数为自己设置的

children = new EventExecutor[nThreads]; 创建一个数组

遍历数组，为每一个EventExecutor是设置LinkedBlockQueue

final SelectorTuple selectorTuple = openSelector();  this.selector = selectorTuple.selector; 为每一个EventExecutor执行Selector.open

设置bootstrap属性

调用服务端方法，传入两个线程池 bootstrap.group(boosGroup, workerGroup)

将bootstrap的group属性设置为boosGroup

将bootstrap的childGroup属性设置为workerGroup

.channel(NioServerSocketChannel.class)

将ServerSocketChannel构造方法设置属性

.option(ChannelOption.SO_BACKLOG, 1024)

将这两个值放入map options.put(option, value);

.childHandler

将childHandler属性赋值为一个ChannelInitialize

bootstrap.bind(9000).sync(); 绑定端口

initAndRegister();

init

反射出ServerSocketCHannel

super(null, channel, SelectionKey.OP_ACCEPT); 将Accept事件保存

pipeline = newChannelPipeline(); 初始化一个pipeline，有一个head和一个tail

ch.configureBlocking(false); 将ServerSocketChannel设置为非阻塞

init(channel); 往piepline里面放ChannelInitializer

往piepline里面添加ServerBootstrapAcceptor

ChannelFuture regFuture = config().group().register(channel); 将注册任务加入taskQueue

eventLoop.execute(new Runnable() {                         @Override                         public void run() {                             register0(promise);                         }                     });

addTask(task); 将注册任务添加到taskQueue

startThread();

doStartThread();

SingleThreadEventExecutor.this.run();

strategy = select(curDeadlineNanos); 在里面进行selector.select()

if (strategy > 0) {                             processSelectedKeys();                         } processSelectedKey(SelectionKey k, AbstractNioChannel ch)

ranTasks = runAllTasks();

执行taskQueue里面的任务

register0

selectionKey = javaChannel().register(eventLoop().unwrappedSelector(), 0, this); serverSocketChannel注册selector

pipeline.invokeHandlerAddedIfNeeded();

会回调ChannelInitializer

pipeline.fireChannelRegistered();

执行Handler

doBind0(regFuture, channel, localAddress, promise); 绑定端口

channel.bind(localAddress, promise).addListener(ChannelFutureListener.CLOSE_ON_FAILURE);

(SelectionKey.OP_READ | SelectionKey.OP_ACCEPT)) != 0

int localRead = doReadMessages(readBuf);读信息