服务器端编程

第一步：maven 依赖 netty-all.jar，详情参考文章最后的maven依赖

第二步：创建服务端的NIO线程组EventLoopGroup；

EventLoopGroup bossGroup = new NioEventLoopGroup();EventLoopGroup workerGroup = new NioEventLoopGroup();

第三步：创建并配置服务端启动辅助类ServerBootstrap；

1、创建ServerBootstrap

ServerBootstrap b = new  ServerBootstrap();

2、配置ServerBootstrap实例的线程组（group）：绑定线程组

b.group(bossGroup, WorkerGroup);

3、配置ServerBootstrap实例的channel：将创建的channel为NioServerSocketChannel

b.channel(NioServerSocketChannel.class);

4、配置ServerBootstrap实例的option：配置NioServerSocketChannel的tcp参数，eg：将他的backlog设置为1024；

b.option(ChannelOption.SO_BACKLOG, 1024);

5、配置ServerBootstrap实例的childHandler：绑定I/O事件的处理类；eg 半包问题处理，记录日志，数据编码解码，用户自定义的处理等等

// 此处注意：ChildChannelHandler是自定义的，继承了ChannelHandlerAdapter类，netty框架让我们可以集中精力用于实际业务上的数据处理，此处的内容后续文章在做重点分析b.childHandler(new ChildChannelHandler());

6、配置ServerBootstrap实例的绑定并监听port与等待链路的关闭：绑定port，并调用同步阻塞方法sync来等待绑定操作完成，完成后会返回channelFuture实例（异步操作的通知回调）

// 绑定端口，同步等待绑定成功ChannelFuture  f = b.bind(8888).sync();// 阻塞等待服务端监听端口关闭，目的：等待服务端链路关闭后main函数才退出f.channel().closeFuture().sync();

7、注意：退出时，记得释放线程池资源

try{    // 服务器启动辅助类的创建与配置内容    // ...  }finally{    // 优雅退出，通过调用线程组的shutdownGracefully方法释放相关资源    bossGroup.shutdownGracefully();      workerGroup.shutdownGracefully();  }

 

客户端编程

第一步：maven 依赖 netty-all.jar

第二步：创建客户端的NIO线程组EventLoopGroup；

EventLoopGroup group = new NioEventLoopGroup();

第三步：创建并配置客户端启动辅助类Bootstrap；

1、创建Bootstrap

Bootstrap b = new  Bootstrap();

2、配置Bootstrap实例的线程组（group）：绑定线程组

b.group(group);

3、配置Bootstrap实例的channel：将创建的channel为NioSocketChannel

b.channel(NioSocketChannel.class);

4、配置Bootstrap实例的option：配置NioSocketChannel的tcp参数，eg：将他的nodelay设置为true；

b.option(ChannelOption.TCP_NODELAY, true);

5、配置Bootstrap实例的handler：绑定I/O事件的处理类；eg 半包问题处理，记录日志，数据编码解码，用户自定义的处理等等

// 此处注意：TimeClientHandler是自定义的，继承了ChannelHandlerAdapter类，netty框架让我们可以集中精力用于实际业务上的数据处理，此处的内容后续文章在做重点分析b.handler(new ChannelInitializer
     
      (){    @Override    public  void initChannel(SocketChannel ch) throws Exception{        ch.pipeline().addLast(new TimeClientHandler())    }});
     

6、配置Bootstrap实例的绑定并监听port与等待链路的关闭：绑定port，并调用同步阻塞方法sync来等待绑定操作完成，完成后会返回channelFuture实例（异步操作的通知回调）

// 绑定服务器的IP和端口，同步等待连接指定服务器成功ChannelFuture  f = b.connect(127.0.0.1，8888).sync();// 阻塞等待服务端监听端口关闭，目的：等待服务端链路关闭后main函数才退出f.channel().closeFuture().sync();

7、注意：退出时，记得释放线程池资源

try{    // 服务器启动辅助类的创建与配置内容    // ...  }finally{    // 优雅退出，通过调用线程组的shutdownGracefully方法释放相关资源    group.shutdownGracefully();  }

 

关于netty的maven依赖

         
      
       io.netty
          
      
       netty-all
          
      
       4.1.33.Final