netty

ChannelHandlerAppender

SingleThread-EventExecutor

Queue taskQueue;QueueScheduledFutureTask delayedTaskQueue;volatile Thread thread;Executor executor;

Runnable

RunnableFuture

参看java nio的presson

Unsafe

ChannelFuture

Abstract-Nio-Channel

SelectableChannel ch;int readInterestOp;volatile SelectionKey selectionKey;volatile boolean inputShutdown;volatile boolean readPending;ChannelPromise connectPromise;ScheduledFuture connectTimeoutFuture;SocketAddress requestedRemoteAddress;

DefaultChannelPipeline

Nio-EventLoopGroup

Nio-Server-Socket-Channel

SelectorProvider DEFAULT_SELECTOR_PROVIDER = SelectorProvider.provider();

Abstract-EventExecutorGroup

Abstract-Nio-Unsafe

Abstract-Nio-Message-Channel

Server-Channel

ChannelHandlerInvoker

ServerBootstrap

PromiseTask

DefaultAttributeMap

DefaultPromise

EventExecutor executor;volatile Object result;Object listeners;LateListeners lateListeners;short waiters;

NioEventLoop

Selector selector;SelectedSelectionKeySet selectedKeys;SelectorProvider provider;

AbstractBootstrap

Abstract-EventExecutor

EventExecutorGroup parent;

ScheduledFuture

NetworkChannel

SelectableChannel

ChannelHandlerAdapter

约定各种ChannelHandler中应处理的方法。

ChannelPipeline

ChannelHandlerContext

DefaultChannelHandlerInvoker

EventExecutor executor;

DefaultChannelPromise

Channel channel;long checkpoint;

Channel

AbstractFuture

DefaultChannelHandlerContext

ChannelHandler handler

Abstract-Channel

Channel parent;ChannelId id;volatile boolean registered;volatile SocketAddress localAddress;volatile SocketAddress remoteAddress;Unsafe unsafe;volatile EventLoop eventLoop;DefaultChannelPipeline pipeline;MessageSizeEstimator.Handle estimatorHandle;ChannelFuture succeededFuture;VoidChannelPromise voidPromise;VoidChannelPromise unsafeVoidPromise;CloseFuture closeFuture;

Server-Socket-Channel

Future

sync()addListeners()await()

SingleThread-EventLoop

ChannelHandlerInvoker invoker;

AbstractChannelHandlerContext

int MASK_XXX;AbstractChannelHandlerContext next;AbstractChannelHandlerContext prev;AbstractChannel channel;DefaultChannelPipeline pipeline;ChannelHandlerInvoker invoker;ChannelFuture succeededFuture;String name;boolean removed;int skipFlags;

EventLoopGroup

Scheduled-ExecutorService

isDone()get()

ChannelHandler

TailContext

EventExecutor

ScheduledFutureTask

Abstract-ExecutorService

HeadContext

ServerSocketChannel

AbstractInterruptibleChannel

http://ifeve.com/netty-mina-in-depth-1/一个博客记录了netty线程运行图解

AttributeMap

Executor

ChannelPromise

EventLoop

register(Channel channel);[ChannelFuture]

ChannelInitializer

Promise

Executor-Service

Nio-Message-Unsafe

private final List readBuf;

AbstractSelectableChannel

Nio-Unsafe

Abstract-Unsafe

ChannelOutboundBuffer outboundBuffer;

InterruptibleChannel

Multithread-EventExecutorGroup

EventExecutor[] children;Set readonlyChildren;AtomicInteger childIndex;AtomicInteger terminatedChildren;Promise terminationFuture;EventExecutorChooser chooser;

EventExecutorGroup

Multithread-EventLoopGroup