netty 使用说明

Bootstrap：客户端启动器

public class Bootstrap extends AbstractBootstrap {
    private static final InternalLogger logger = InternalLoggerFactory.getInstance(Bootstrap.class);
    private static final AddressResolverGroup DEFAULT_RESOLVER;
    private final BootstrapConfig config = new BootstrapConfig(this);
    private volatile AddressResolverGroup resolver;
    private volatile SocketAddress remoteAddress;

    public Bootstrap() {
    private Bootstrap(Bootstrap bootstrap) {


    public Bootstrap validate() {
    public Bootstrap clone() {
    public Bootstrap clone(EventLoopGroup group) {
    public Bootstrap resolver(AddressResolverGroup resolver) {

    public Bootstrap remoteAddress(SocketAddress remoteAddress) {
    public Bootstrap remoteAddress(String inetHost, int inetPort) {
    public Bootstrap remoteAddress(InetAddress inetHost, int inetPort) {

    public ChannelFuture connect() {
    public ChannelFuture connect(String inetHost, int inetPort) {
    public ChannelFuture connect(InetAddress inetHost, int inetPort) {
    public ChannelFuture connect(SocketAddress remoteAddress) {
    public ChannelFuture connect(SocketAddress remoteAddress, SocketAddress localAddress) {

    public final BootstrapConfig config() {

    void init(Channel channel) {

    final SocketAddress remoteAddress() {
    final AddressResolverGroup resolver() {

    private ChannelFuture doResolveAndConnect(final SocketAddress remoteAddress, final SocketAddress localAddress) {
    private ChannelFuture doResolveAndConnect0(final Channel channel, SocketAddress remoteAddress, final SocketAddress localAddress, final ChannelPromise promise) {
    private static void doConnect(final SocketAddress remoteAddress, final SocketAddress localAddress, final ChannelPromise connectPromise) {

    static {
        DEFAULT_RESOLVER = DefaultAddressResolverGroup.INSTANCE;
    }
}

ServerBootstrap：服务端启动器

public class ServerBootstrap extends AbstractBootstrap {
    private static final InternalLogger logger = InternalLoggerFactory.getInstance(ServerBootstrap.class);
    private final Map, Object> childOptions = new LinkedHashMap();
    private final Map, Object> childAttrs = new ConcurrentHashMap();
    private final ServerBootstrapConfig config = new ServerBootstrapConfig(this);
    private volatile EventLoopGroup childGroup;
    private volatile ChannelHandler childHandler;

    public ServerBootstrap() {
    }


    public ServerBootstrap group(EventLoopGroup group) {
    public ServerBootstrap group(EventLoopGroup parentGroup, EventLoopGroup childGroup) {
    public  ServerBootstrap childOption(ChannelOption childOption, T value) {
    public  ServerBootstrap childAttr(AttributeKey childKey, T value) {
    public ServerBootstrap childHandler(ChannelHandler childHandler) {

    public ServerBootstrap validate() {
    public ServerBootstrap clone() {

    public final ServerBootstrapConfig config() {

    final ChannelHandler childHandler() {
    final Map, Object> childOptions() {
    final Map, Object> childAttrs() {

    void init(Channel channel) {
    private ServerBootstrap(ServerBootstrap bootstrap) {


**********
内部类：ServerBootstrapAcceptor

    private static class ServerBootstrapAcceptor extends ChannelInboundHandlerAdapter {
        private final EventLoopGroup childGroup;
        private final ChannelHandler childHandler;
        private final Entry, Object>[] childOptions;
        private final Entry, Object>[] childAttrs;
        private final Runnable enableAutoReadTask;

        ServerBootstrapAcceptor(final Channel channel, EventLoopGroup childGroup, ChannelHandler childHandler, Entry, Object>[] childOptions, Entry, Object>[] childAttrs) {

        public void channelRead(ChannelHandlerContext ctx, Object msg) {
        public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) throws Exception {

        private static void forceClose(Channel child, Throwable t) {

EventExecutorGroup

public interface EventExecutorGroup extends ScheduledExecutorService, Iterable {

    boolean isShuttingDown();

    Future terminationFuture();
    Future shutdownGracefully();
    Future shutdownGracefully(long var1, long var3, TimeUnit var5);

    EventExecutor next();
    Iterator iterator();

    Future submit(Runnable var1);
     Future submit(Runnable var1, T var2);
     Future submit(Callable var1);

     ScheduledFuture schedule(Callable var1, long var2, TimeUnit var4);
    ScheduledFuture schedule(Runnable var1, long var2, TimeUnit var4);
    ScheduledFuture scheduleAtFixedRate(Runnable var1, long var2, long var4, TimeUnit var6);
    ScheduledFuture scheduleWithFixedDelay(Runnable var1, long var2, long var4, TimeUnit var6);
}

EventLoopGroup

public interface EventLoopGroup extends EventExecutorGroup {

    EventLoop next();

    ChannelFuture register(Channel var1);
    ChannelFuture register(ChannelPromise var1);

}

NioEventLoopGroup

public class NioEventLoopGroup extends MultithreadEventLoopGroup {

    public NioEventLoopGroup() {
        this(0);
    }

    public NioEventLoopGroup(int nThreads) {
    public NioEventLoopGroup(ThreadFactory threadFactory) {

    public NioEventLoopGroup(int nThreads, ThreadFactory threadFactory) {
    public NioEventLoopGroup(int nThreads, Executor executor) {
    public NioEventLoopGroup(int nThreads, ThreadFactory threadFactory, SelectorProvider selectorProvider) {
    public NioEventLoopGroup(int nThreads, ThreadFactory threadFactory, SelectorProvider selectorProvider, SelectStrategyFactory selectStrategyFactory) {
    public NioEventLoopGroup(int nThreads, Executor executor, SelectorProvider selectorProvider) {
    public NioEventLoopGroup(int nThreads, Executor executor, SelectorProvider selectorProvider, SelectStrategyFactory selectStrategyFactory) {
    public NioEventLoopGroup(int nThreads, Executor executor, EventExecutorChooserFactory chooserFactory, SelectorProvider selectorProvider, SelectStrategyFactory selectStrategyFactory) {
    public NioEventLoopGroup(int nThreads, Executor executor, EventExecutorChooserFactory chooserFactory, SelectorProvider selectorProvider, SelectStrategyFactory selectStrategyFactory, RejectedExecutionHandler rejectedExecutionHandler) {
    public NioEventLoopGroup(int nThreads, Executor executor, EventExecutorChooserFactory chooserFactory, SelectorProvider selectorProvider, SelectStrategyFactory selectStrategyFactory, RejectedExecutionHandler rejectedExecutionHandler, EventLoopTaskQueueFactory taskQueueFactory) {
    public NioEventLoopGroup(int nThreads, Executor executor, EventExecutorChooserFactory chooserFactory, SelectorProvider selectorProvider, SelectStrategyFactory selectStrategyFactory, RejectedExecutionHandler rejectedExecutionHandler, EventLoopTaskQueueFactory taskQueueFactory, EventLoopTaskQueueFactory tailTaskQueueFactory) {


    public void setIoRatio(int ioRatio) {
    public void rebuildSelectors() {

    protected EventLoop newChild(Executor executor, Object... args) throws Exception {

常用channel类（4.1.77 oio不推荐使用）

NioSocketChannel：tcp客户端
NioServerSocketChannel：tcp服务端

NioDatagramChannel：udp客户端、服务端

NioSctpChannel：sctp客户端
NioSctpServerChannel：sctp服务端

ChannelOption

public class ChannelOption extends AbstractConstant> {
    private static final ConstantPool> pool = new ConstantPool>() {
        protected ChannelOption