一.初步了解Netty
Netty是一个NIO的编程框架,Netty是非常容易和快速开发出网络应用程序的,它提供了一种全新的形式来方便你编写网络应用:它提供了对一些对复杂问题的抽象,提供了一套非常容易使用的api来把我们的业务逻辑和纯粹处理网络的代码分离开来。因为Betty是基于NIO,因此它的整个API都是异步的。
Netty简化了基于TCP和UDP的编程,但是你仍可以用它的底层的API做一些底层处理,因为Netty提供了一系列高抽象的API。
Netty有一系列丰富的特性,让我们来看一下它的强大之处:
1.有一套统一的API来处理异步和同步编程模式
2.使用非常灵活
3.简单但却强大的线程机制
4.业务组件分离方便重用
5.极小的缩减不必要的Memory Copy
Netty开始-理解Netty的设计理念NIO
二.异步编程模式设计
一般来说网络编程都会面临着并发问题,那么我们就来看一下为何异步编程模式会很好的解决这个问题,其实这也就诠释了netty背后的设计思想。
在现在,瓶颈总是在IO处理上,异步的处理方式就是你可以不用一直等待任务(IO)处理完成,而是在任务进行的时候还可以做其它事情。那么如何实现这个呢?让我们来认识一下实现异步的两种处理方式:
CallBack:回调是异步处理经常用到的编程模式,回调函数通常被绑定到一个方法上,并且在方法完成之后才执行,这种处理方式在javascript当中得到了充分的运用。回调给我们带来的难题是当一个问题处理过程中涉及很多回调时,代码是很难读的。
Futures:Futures是一种抽象,它代表一个事情的执行过程中的一些关键点,我们通过Future就可以知道任务的执行情况,比如当任务没完成时我们可以做一些其它事情。它给我们带来的难题是我们需要去判断future的值来确定任务的执行状态。
其实这两者很难界定那个好或坏,其实Netty中这两者都有用到。
异步模式(NIO)和非异步模式(BIO)(N可以理解为non-blocking或new)
Block IO会对每个连接创建一个线程,因此这极大限制了JVM创建线程的数量(当然线程池可缓解这个问题,但是也仅仅是缓解),如图所示:
NIO会通过专门的Selector来管理请求,然后可由一个线程来处理请求,如图所示:
在NIO中,不得不提到的是关于抽象的数据容器ByteBuffer,ByteBuffer允许相同的数据在不同ByteBuffer之间共享而不需要再拷贝一次来处理。Slicing-ByteBuffer允许创建一个新的ByteBuffer通过暴露一个子边界的形式共享原ByteBuffer的数据,这就大大减少了在数据处理过程中内存的copy(Zero-copy)。ByteBuffer通过一些索引来记录读写的信息,当你向其中写数据时,它会自动跟踪你写到ByteBuffer的位置,类似,他也会自动跟踪你读的位置。而且ByteBuffer还提供了很多方法让你切换读写模式(flip)或者清空(clear)或者压缩(compact)等。
关于Selectors,NIOAPI通过selector来处理网络事件和数据。一个Channel代表一个网络连接。Selector的作用就是来决定这些Channel是否已准备好读或者写操作,一个selector可以处理很多连接请求,这就解决了为一个连接创建一个线程的问题。要想用一个selector需要以下步骤:
1.创建一个或多个selector用来给打开的channels注册。
2.当一个channel注册后,就需要来确定哪种事件需要你监听,通常有四种事件:
OP_ACCEPT
OP_CONNECT
OP_READ
OP_WRITE
3.当channels被注册后,你需要调用Selector.select()方法来阻塞直到上述事件发生。
4.当方法没有阻塞时,你会获得所有SelectionKey实例,这些实例包含了已注册channel的引用和其状态,这样你就可以做你的操作了。
三.Netty VS JavaNIO
1.跨平台性和通用型
NIO某些底层的操作依赖于操作系统,因此,你写的NIO程序有可能在windows上运行良好,但到了Linux可能会出现问题。 Java6和Java7对NIO提供了不同的解决方案,两个API是不通用的。
2.拓展了ByteBuffer
Netty提供了对ByteBuffer的封装类ByteBuf,拓展了JDK中ByteBuffer的功能,增强了易用性。
3. 数据拆分和聚集
很多时候我们想把数据分割成独立的Bytebuffer来处理,比如Http协议Header放到一个buffer中,而Body放到另一个buffer中。很不幸,对于这种处理方式直到Java7才出现,而且如果处理不当,会极易造成OutOfMemoryError。
Scattering And Gathering:
4.解决了著名的epoll bug
文章来源:http://blog.csdn.net/suifeng3051/article/details/23348587
相关推荐
java_Netty权威指南,详解nio,tcp,http,netty.rar
包含了Netty,NIO AIO,Mina知识的详解以及netty结合spring protocolbuf的源码
第72讲:Netty线程模型深度解读与架构设计原则 第73讲:Netty底层架构系统总结与应用实践 第74讲:Netty对于异步读写操作的架构思想与观察者模式的重要应用 第75讲:适配器模式与模板方法模式在入站处理器中的...
netty深入学习包括重要地方的源码分析以及java nio的详解,绝对干货!!!
同步,一个任务的完成之前不能做其他操作,必须等待(等于在打电话) 异步,一个任务的完成之前,可以进行其他操作(等于在聊QQ) 阻塞,是相对于CPU来说的, 挂起当前线程,不能做其他操作只能等待 非阻塞,,无须挂...
72_Netty线程模型深度解读与架构设计原则 73_Netty底层架构系统总结与应用实践 74_Netty对于异步读写操作的架构思想与观察者模式的重要应用 75_适配器模式与模板方法模式在入站处理器中的应用 76_Netty项目开发过程...
从IO流到BIO,再到NIO,AIO,以及Reactor模式和Proactor模式来分析netty
精通并发与netty视频教程(2018)视频教程 netty视频教程 Java视频教程目录: 1_学习的要义 2_Netty宏观理解 3_Netty课程大纲深度解读 4_项目环境搭建与Gradle配置 5_Netty执行流程分析与重要组件介绍 6_Netty回调与...
下面小编就为大家带来一篇基于NIO的Netty网络框架(详解)。小编觉得挺不错的,现在就分享给大家,也给大家做个参考。一起跟随小编过来看看吧
Java高级编程、内有Java IO NIO,Java+netty等框架技术详解。
分布式架构 漫谈分布式架构 初识分布式架构与意义 如何把应用从单机扩展到分布式 大型分布式架构演进过程 分布式架构设计 主流架构模型-SOA架构... Netty无锁化串行设计及高并发处理机制 手写实现多协议RPC框架
nacos源码研究: 1.nacas的通讯原理,netty的NIO通讯; 2.TM实现原理解析; 3.RM实现原理解析; 4.TM\RM\TC之间的通信梳理; 5.seata客户端、服务端和通信参数详解。
iRpc介绍iRpc为一款基于Nio通信实现的轻量级高性能rpc框架,支持单机及leader-follower部署模式,配置简单,通信效率高。提供同步和异步(callBack模式)等多种消息发送方式,不依赖于第三方注册中心即可实现服务端自主...