<dependency>

    <groupId>io.netty</groupId>

    <artifactId>netty-example</artifactId>

    <version>4.1.25.Final</version>

</dependency>

EventLoopGroup bossGroup = new NioEventLoopGroup(1); //用来处理accpet事件，并指定EventLoop数量为一个

EventLoopGroup workerGroup = new NioEventLoopGroup(); //用来处理后续的io事件，这里没有指定EventLoop数量 默认为CPU核心数*2

try {

    ServerBootstrap b = new ServerBootstrap(); //创建一个服务端netty启动器，用来帮助服务端启动

    b.group(bossGroup, workerGroup) //把刚才创建的eventloopGroup添加进去

     .channel(NioServerSocketChannel.class) //服务端对应的channel类型，这里是用来创建连接时候用的

     .option(ChannelOption.SO_BACKLOG, 100) //设置bossgroup得到的最大连接数

     .handler(new LoggingHandler(LogLevel.INFO)) //给NioServerScoketChannel设置的处理器 该handler看名字就知道是用来打印流程日志
     //上面都是设置bossgroup产生连接使用的 只对NioServerScoketChannel有效
　　　//产生连接后会相应生成NioSocketChannel用来会后续客户端io事件的处理

     .childHandler(new ChannelInitializer<SocketChannel>() { //该handler在NioSocketChannel创建的时候使用，ChannelInitializer用来帮助channel的创建

         @Override

         public void initChannel(SocketChannel ch) throws Exception {

             ChannelPipeline p = ch.pipeline();

             p.addLast(new EchoServerHandler()); //这里才是像channel添加handler

         }

     });

　　 // 绑定端口并同步阻塞

    ChannelFuture f = b.bind(PORT).sync();
　　 // 监听NioServerScoketChannel的关闭事件，同步阻塞

    f.channel().closeFuture().sync();

} finally {

    // 结束后优雅的关闭

    bossGroup.shutdownGracefully();

    workerGroup.shutdownGracefully();

}

EventLoopGroup group = new NioEventLoopGroup(); //客户端只有一个EventLoopGroup 因为客户端连接、读写事件都是由一个channel完成

try {

    Bootstrap b = new Bootstrap(); //客户端启动器

    b.group(group)

     .channel(NioSocketChannel.class) //指定客户端channel类型 后续创建时通过反射来实例化

     .option(ChannelOption.TCP_NODELAY, true) //设置NioSocketChannel类型为tcp无延迟

     .handler(new ChannelInitializer<SocketChannel>() { //帮助NioSocketChannel创建的handler

         @Override

         public void initChannel(SocketChannel ch) throws Exception {

             ChannelPipeline p = ch.pipeline();

             p.addLast(new EchoClientHandler()); //添加NioSocketChannel的handler

         }

     });

    // 连接服务端，同步阻塞

    ChannelFuture f = b.connect(HOST, PORT).sync();

    // 等待客户关闭信号，同步阻塞

    f.channel().closeFuture().sync();

} finally {

    // 结束后记得关闭

    group.shutdownGracefully();

}