Netty之WebSocket和四种IO介绍

Netty简介

　　1、什么是netty？

　　　　　　高性能 事件驱动

　　　　　　异步非堵塞 基于NIO的客户端，服务器端编程框架

　　　　　　稳定性和伸缩性　　　

　　2、Netty的使用场景

　　　　　　高性能领域
　　　　　  多线程并发领域
　　　　　  异步通讯领域

四种IO介绍

　　一、BIO通讯

　　　　 （1）一个线程负责链接
　　　　（2）一个请求一个应答
　　　　（3）缺少弹性伸缩能力 当客户端访问增大，线程形成进程宕机。不能对外服务。

　　二、伪异步IO通讯

　　　　 （1）线程池负责链接 当有新的客户端进来，将客户端的socket封装成Task投入线程池。
　　　　（2）m请求n应答 将全部的请求放到一个线程池中，由线程池来分配线程；作到异步通讯。
　　　　（3）线程池阻塞 线程池能够设置最大访问数。并发不断增长，可能形成阻塞。

　　三、NIO通讯

　　　　（1）缓冲区Buffer ————>>> 他是一个对象，包含读和写的数据，全部数据都是用缓冲区处理的。

　　　　（2）通道Channel ————>>> 他就像是一个自来水管同样，网络数据经过Channel读取或写入，通道与流的不一样之处在于通道是双向的，流只是在一个水平线上移动，一个流他必须是inputStrem或outputStrem的子类，通道能够用于读写，或者两者同时进行。

　　　　（3）多路复用器Selector ————>>> 它会不断的轮询注册在其上的channel，若是channel发生读或写事件，那么这个channel就处于就绪状态，会被selector轮询出来，而后经过selectorKey获取就channel集合，进行后续的io操做。因为jdk使用epoll()替代传统的selector实现，因此他并无最大链接句柄限制，也就意味着只须要一个负责轮询selector的线程就能够接入成千上万的channel.

　　四、AIO通讯

　　　 　（1）链接注册读写事件和回调函数

　　　　（2）读写方法异步

　　　　（3）主动通知程序

　　　　总结：AIO异步通道经过两种方式得到操做结果，第一种就是经过返java.util.concurrent.Futur对象,第二种方式是为操做提供一个回调参数java.nio.channels.CompletionHandler，这个回调类包含completed,failed两个方法。那么AIO的套接字通道是真正的异步非阻塞io，他不须要对注册的多路复用器进行轮询操做就能实现异步读写，简化了NIO模型，这就是AIO通讯。

Netty的WebSocket通讯实现

　　1、Netty实现WebScoket通讯案例

　　　　   （1）编写存储整个工程的全局配置类 ===》 这里须要有一个Channel对象来存储每个接入进来的客户端 ===》 ChannelGroup对象 ===》为它赋值的是一个默认的ChannelGroup（DefaultChannelGroup）这里他须要一个GlobalEventExecutor.INSTANCE参数。

　　　　（2）编写WebSocket核心类。
这个类继承了SimpleChannelInboundHandler抽象类，同时这个抽象类又继承了ChannelHandlerAdapter类，而后重写ChannelHandlerAdapter类中的channelActive、channelInactive、channelReadComplete、exceptionCaught四个方法和该抽象类的messageReceived方法。在重写messageReceived方法时编写须要的业务处理方法和握手请求业务方法就好了。

　　　　（3）编写初化链接时的各个组件
这个类是继承了ChannelInitializer抽象类。重写默认的initChannel方法，调用传入的socketChannel对象通道，将各个组件写入该对象。

 

　　　　

原文出处：https://www.cnblogs.com/zhanvo/p/10905293.html