Netty線程模型、源碼解析

0x01：Reactor 模式

Douglas C. Schmidt 1995年提出:

An Object Behavioral Pattern for Demultiplexing and 
Dispatching Handles for Synchronous Events

Scalable IO in Java - Doug Lea

http://gee.cs.oswego.edu/dl/cpjslides/nio.pdf
基於Java IO對Reactor模式進行闡述

NIO 網絡框架的典型模式

Mina、Netty、Cindy 都是此模式的實現

• Douglas

• Doug Lea三種模式

單線程

多線程 Reactor

Multiple Reactor

其餘主從形式，可是不經常使用

Netty 和 Reactor 的模式同時都支持的

 

• 單線程的Reactor

EventLoopGroup eventExecutors = new NioEventLoopGroup(1);
ServerBootstrap serverBootstrap = new ServerBootstrap().group(eventExecutors,eventExecutors);

 

• 多線程

EventLoopGroup eventExecutors = new NioEventLoopGroup(1);
ServerBootstrap serverBootstrap = new ServerBootstrap().group(eventExecutors,eventExecutors);//Handler使用線程池進行處理

Multiple Reactor

EventLoopGroup eventExecutors = new NioEventLoopGroup(1);
EventLoopGroup workereventExecutors = new NioEventLoopGroup();
ServerBootstrap serverBootstrap = new ServerBootstrap().group(eventExecutors,workereventExecutors);

EventLoopGroup eventExecutors = new NioEventLoopGroup();
EventLoopGroup workereventExecutors = new NioEventLoopGroup();
ServerBootstrap serverBootstrap = new ServerBootstrap().group(eventExecutors,workereventExecutors);

 

0x02: 源碼

EventExecutor視圖

1. EventExecutorGroup裏面有一個EventExecutor數組，保存了多個EventExecutor;

2. EventExecutorGroup是不幹什麼事情的，當收到一個請後，他就調用next()得到一個它裏面的EventExecutor，再調用這個executor的方法；

3. next(): EventExecutorChooser.next()定義選擇EventExecutor的策略；