phpdio壅塞技巧_超具体Netty入门看这篇就够了

Netty is an asynchronous event-driven network application frameworkfor rapid development of maintainable high performance protocol servers & clients.

Netty是 一个异步事宜驱动的网络运用程序框架，用于快速开拓可掩护的高性能协议做事器和客户端。

从官网上先容，Netty是一个网络运用程序框架，开拓做事器和客户端。
也便是用于网络编程的一个框架。
既然是网络编程，Socket就不谈了，为什么不用NIO呢？

2.1 NIO的缺陷

对付这个问题，之前我写了一篇文章《NIO入门》对NIO有比较详细的先容，NIO的紧张问题是：

2.2 Netty的优点

相对地，Netty的优点有很多：

上面这张图便是在官网首页的架构图，我们从上到下剖析一下。

绿色的部分Core核心模块，包括零拷贝、API库、可扩展的事宜模型。

橙色部分Protocol Support协议支持，包括Http协议、webSocket、SSL(安全套接字协议)、谷歌Protobuf协议、zlib/gzip压缩与解压缩、Large File Transfer大文件传输等等。

赤色的部分Transport Services传输做事，包括Socket、Datagram、Http Tunnel等等。

以上可看出Netty的功能、协议、传输办法都比较全，比较强大。

首先搭建一个HelloWord工程，先熟习一下API，还有为后面的学习做铺垫。
以下面这张图为依据：

4.1 引入Maven依赖

利用的版本是4.1.20，相比拟较稳定的一个版本。

<dependency> <groupId>io.netty</groupId> <artifactId>netty-all</artifactId> <version>4.1.20.Final</version></dependency>

4.2 创建做事端启动类

public class MyServer { public static void main(String[] args) throws Exception { //创建两个线程组 boosGroup、workerGroup EventLoopGroup bossGroup = new NioEventLoopGroup(); EventLoopGroup workerGroup = new NioEventLoopGroup(); try { //创建做事真个启动工具，设置参数 ServerBootstrap bootstrap = new ServerBootstrap(); //设置两个线程组boosGroup和workerGroup bootstrap.group(bossGroup, workerGroup) //设置做事端通道实现类型 .channel(NioServerSocketChannel.class) //设置线程行列步队得到连接个数 .option(ChannelOption.SO_BACKLOG, 128) //设置保持活动连接状态 .childOption(ChannelOption.SO_KEEPALIVE, true) //利用匿名内部类的形式初始化通道工具 .childHandler(new ChannelInitializer<SocketChannel>() { @Override protected void initChannel(SocketChannel socketChannel) throws Exception { //给pipeline管道设置处理器 socketChannel.pipeline().addLast(new MyServerHandler()); } });//给workerGroup的EventLoop对应的管道设置处理器 System.out.println("java技能爱好者的做事端已经准备就绪..."); //绑定端口号，启动做事端 ChannelFuture channelFuture = bootstrap.bind(6666).sync(); //对关闭通道进行监听 channelFuture.channel().closeFuture().sync(); } finally { bossGroup.shutdownGracefully(); workerGroup.shutdownGracefully(); } }}

4.3 创建做事端处理器

/ 自定义的Handler须要继续Netty规定好的HandlerAdapter 才能被Netty框架所关联，有点类似SpringMVC的适配器模式 /public class MyServerHandler extends ChannelInboundHandlerAdapter { @Override public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception { //获取客户端发送过来的 ByteBuf byteBuf = (ByteBuf) msg; System.out.println("收到客户端" + ctx.channel().remoteAddress() + "发送的：" + byteBuf.toString(CharsetUtil.UTF_8)); } @Override public void channelReadComplete(ChannelHandlerContext ctx) throws Exception { //发送给客户端 ctx.writeAndFlush(Unpooled.copiedBuffer("做事端已收到，并给你发送一个问号?", CharsetUtil.UTF_8)); } @Override public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) throws Exception { //发生非常，关闭通道 ctx.close(); }}

4.4 创建客户端启动类

public class MyClient { public static void main(String[] args) throws Exception { NioEventLoopGroup eventExecutors = new NioEventLoopGroup(); try { //创建bootstrap工具，配置参数 Bootstrap bootstrap = new Bootstrap(); //设置线程组 bootstrap.group(eventExecutors) //设置客户真个通道实现类型 .channel(NioSocketChannel.class) //利用匿名内部类初始化通道 .handler(new ChannelInitializer<SocketChannel>() { @Override protected void initChannel(SocketChannel ch) throws Exception { //添加客户端通道的处理器 ch.pipeline().addLast(new MyClientHandler()); } }); System.out.println("客户端准备就绪，随时可以起飞~"); //连接做事端 ChannelFuture channelFuture = bootstrap.connect("127.0.0.1", 6666).sync(); //对通道关闭进行监听 channelFuture.channel().closeFuture().sync(); } finally { //关闭线程组 eventExecutors.shutdownGracefully(); } }}

4.5 创建客户端处理器

public class MyClientHandler extends ChannelInboundHandlerAdapter { @Override public void channelActive(ChannelHandlerContext ctx) throws Exception { //发送到做事端 ctx.writeAndFlush(Unpooled.copiedBuffer("歪比巴卜~茉莉~Are you good~马来西亚~", CharsetUtil.UTF_8)); } @Override public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception { //吸收做事端发送过来的 ByteBuf byteBuf = (ByteBuf) msg; System.out.println("收到做事端" + ctx.channel().remoteAddress() + "的：" + byteBuf.toString(CharsetUtil.UTF_8)); }}

4.6 测试

先启动做事端，再启动客户端，就可以看到结果：

MyServer打印结果:

MyClient打印结果：

五、Netty的特性与主要组件

5.1 taskQueue任务行列步队

如果Handler处理器有一些永劫光的业务处理，可以交给taskQueue异步处理。
怎么用呢，请看代码演示：

public class MyServerHandler extends ChannelInboundHandlerAdapter { @Override public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception { //获取到线程池eventLoop，添加线程，实行 ctx.channel().eventLoop().execute(new Runnable() { @Override public void run() { try { //永劫光操作，不至于永劫光的业务操作导致Handler壅塞 Thread.sleep(1000); System.out.println("永劫光的业务处理"); } catch (Exception e) { e.printStackTrace(); } } }); }}

我们打一个debug调试，是可以看到添加进去的taskQueue有一个任务。

5.2 scheduleTaskQueue延时任务行列步队

延时任务行列步队和上面先容的任务行列步队非常相似，只是多了一个可延迟一定韶光再实行的设置，请看代码演示：

ctx.channel().eventLoop().schedule(new Runnable() { @Override public void run() { try { //永劫光操作，不至于永劫光的业务操作导致Handler壅塞 Thread.sleep(1000); System.out.println("永劫光的业务处理"); } catch (Exception e) { e.printStackTrace(); } }},5, TimeUnit.SECONDS);//5秒后实行

依然打开debug进行调试查看，我们可以有一个scheduleTaskQueue任务待实行中

5.3 Future异步机制

在搭建HelloWord工程的时候，我们看到有一行这样的代码：

ChannelFuture channelFuture = bootstrap.connect("127.0.0.1", 6666);

很多操作都返回这个ChannelFuture工具，究竟这个ChannelFuture工具是用来做什么的呢？

ChannelFuture供应操作完成时一种异步关照的办法。
一样平常在Socket编程中，等待相应结果都是同步壅塞的，而Netty则不会造成壅塞，由于ChannelFuture是采纳类似不雅观察者模式的形式进行获取结果。
请看一段代码演示：

//添加监听器channelFuture.addListener(new ChannelFutureListener() { //利用匿名内部类，ChannelFutureListener接口 //重写operationComplete方法 @Override public void operationComplete(ChannelFuture future) throws Exception { //判断是否操作成功 if (future.isSuccess()) { System.out.println("连接成功"); } else { System.out.println("连接失落败"); } }});

5.4 Bootstrap与ServerBootStrap

Bootstrap和ServerBootStrap是Netty供应的一个创建客户端和做事端启动器的工厂类，利用这个工厂类非常便利地创建启动类，根据上面的一些例子，实在也看得出来能大大地减少了开拓的难度。
首先看一个类图：

可以看出都是继续于AbstractBootStrap抽象类，以是大致上的配置方法都相同。

一样平常来说，利用Bootstrap创建启动器的步骤可分为以下几步：

5.4.1 group()

在上一篇文章《Reactor模式》中，我们就讲过做事端要利用两个线程组：