Netty事件监听和处理(上)

 

陪产假结束了,今天又开始正常上班了,正好遇上米粉节活动,又要忙上一阵了,米粉节活动时间为4.03 - 4.10,有很多优惠,感兴趣的能够关注mi.com或小米商城app。java

今天给你们送了福利:小爱音箱F码,听说卖的比较好,不太好抢到,借着此次公司福利,分享给你们,以表你们的支持和鼓励。编程

掘金的运营真的很贴心,主动找到我说:个人福利文章不是技术型文章,不能推送到信息流,只能在我的主页看到,为了让更多的人参与此次抽取,建议写一篇技术文章,末尾加上送福利的内容。再次感谢掘金运营小哥「刺客」的贴心和建议。安全

RabbitMQ实战的后续章节还没来得及看,这篇就总结下以前在项目组分享过的技术点:Netty事件监听和处理。服务器

经过介绍,你会了解到:微信

  • 事件监听、NIO、线程模型等相关概念;
  • Netty整体结构;
  • 事件监听和处理;
  • 项目实践总结;

本篇先介绍下前两节,下一篇介绍后两节。markdown

本篇最后会说明下福利的抽取规则,你们积极参与 >_<网络

相关概念

Netty是一个NIO框架,它将IO通道的创建、可读、可写等状态变化,抽象成事件,以责任链的方式进行传递,能够在处理链上插入自定义的Handler,对感兴趣的事件进行监听和处理。app

因此,先介绍下事件监听、责任链模型、socket接口和IO模型、线程模型等基本概念,对后面理解Netty的事件监听和处理有很大帮助。框架

事件监听

JDK监听器模式主要包含如下元素:异步

  • EventObject 事件对象
  • EventListener 事件监听接口
  • 自定义事件源
  • 事件触发

模式很简单,用户能够自定义事件源,保存触发对象的相关数据,事件被触发后,传递给注册事件的处理者。事件监听接口是为了统一处理者方法。

举个比较好理解的按钮单击事件,其中ActionListener是事件监听器,ActionEvent是事件对象,包含了事件源:

实现一套事件监听的具体过程:

  • 肯定事件源;
  • 明确可能产生的事件,定义成不一样的事件对象或事件方法;
  • 提供一个存储结构,用于保存监听事件的对象,当事件发生时,会通知监听者;
  • 执行回调方法,进行业务处理;

事件监听

责任链模式

主要是说事件处理者的组织方式,经过责任链模式,能够在任何处理节点,添加自定义处理器,很方便。

关于责任链概念,这里再简单说下:使多个对象都有机会处理请求,从而避免请求的发送者和接受者之间的耦合关系,将这个对象连成一条链,并沿着这条链传递该请求,直到有一个对象处理他为止。

责任链模式

socket

通常说NIO,主要是针对网络IO,从网卡中读取数据,向网卡中写入数据,这就是监听器模式的数据源。

网络编程主要经过操做系统提供的socket接口进行,经过了解socket接口能够总结出有哪些事件。

socket是用户进程和内核网络协议之间的统一接口。
socket也是一种特殊的文件,网络通讯能够看做是对文件的读取,使得对网络的控制和对文件的控制同样方便。

sokcet接口

NIO和IO模型

NIO是指非阻塞IO,咱们通常说的IO都是阻塞IO,想全面了解这些概念,又会说的不少,这里就简单归纳下。

一个进程所占的内存包括用户态和内核态,为了安全,用户代码是不能直接操做内核态内存的,经过系统调用进行交互,好比读取网络数据,交互过程以下:

同步阻塞

用户线程发起read请求后,须要等待数据到达才能返回,在这期间,用户线程不能作任何事情,若是是网络编程,可能有不少Socket对象进行监听,会建立大量线程被阻塞,形成资源浪费,性能降低。

针对这种状况,出现了IO模型的概念,有几种方式:

  • 同步非阻塞IO;
  • IO多路复用;
  • 异步IO;

具体介绍,网上有不少资料,就不详细说了,这里只提下IO多路复用,说说个人理解,咱们项目中就是使用这种方式。

所谓多路复用,主要是操做系统提供给咱们这种开发模式:能够把感兴趣的IO事件(创建、可读、可写等)提早注册,并且多个socket对象能够注册到一个selector选择器上,这样就能够多个socket对象使用一个用户线程进行监听,当事件发生时,会查找对应的socket进行读、写等操做。

以前作过NIO开发的朋友,能够看下面的示例回顾下整个过程:

java NIO示例

线程模型

上面说了我对多路复用的理解,提到了一个线程监听多个socket,但若是socket不少,一个线程是处理不过来的。另外,事件的接收和判断 与 数据的读取、处理、写入,能够在不一样线程进行。

这就引出了线程模型的概念,好比Reactor和Proactor模型,具体细节就不介绍了,网上有不少资料,最终目的都是为了提升IO事件处理的性能。

Netty整体结构

这部分主要是了解下Netty,对其实现原理先不作深究。

概述

Netty 是一个异步的事件驱动的网络应用程序框架,支持快速地开发可维护的高性能的面向协议的服务器和客户端;
它驾驭了 Java 高级 API 的能力,并将其隐藏在一个易于使用的 API 以后;

Netty整体结构

  • Core(核心部分),是底层的网络通信的一些通用抽象,这部份内容是关键。
  • Transport Services(传输服务),具体的网络传输能力的定义以及一些实现。
  • Protocol Support(协议支持),netty 对于一些通用协议的编码解码实现。
零拷贝

广义的零拷贝是指计算机操做的过程当中,CPU不须要为数据在内存之间的拷贝消耗资源。Linux中的sendfile()以及 Java NIO 中的FileChannel.transferTo()方法都实现了零拷贝的功能,而在 Netty 中也经过在FileRegion中包装了 NIO 的FileChannel.transferTo()方法实现了零拷贝。

Netty中所指零拷贝,彻底在用户态,更偏向于优化数据操做。Netty容许咱们将多段数据合并为一整段虚拟数据供用户使用,而不须要对数据进行拷贝操做。

Netty零拷贝

统一的通信模型

传统的JAVA IO API 在应对不一样的传输协议时,须要使用不一样的类型和方法,例如:java.net.Socket和java.net.DatagramSocket,它们并不具备相同的超类型;Java新的IO API与原有的阻塞式IO API也不兼容;

Netty提供了统一的API编程接口,抽象了全部点对点通讯操做,仅调整几行代码,即可切换不一样的传输实现:

  • 基于NIO的TCP/IP传输
  • 基于OIO的TCP/IP传输
  • 基于OIO的UDP/IP传输
  • 本地传输
事件模型

也就是要说的事件监听和处理,提供了很好的方式去处理各类事件。

Netty事件模型

大体处理过程如上图,具体将在下一篇介绍。


福利说明

最后,说下福利:小爱音箱F码。

准备了2份,主要为了感谢「微信公众号」和「掘金社区」的朋友,每一份包括1个小爱音箱F码和1个小爱音箱 mini F码。

小米手机F码源自于英文单词”Friend”,是小米公司提供给小米核心用户及为小米作出贡献的网友的优先购买权,若是您有小米F码的话无需等待便可直接利用小米F码购买相关产品!

简单来讲,F码就是不用抢了,能够直接购买 ~

抽奖截止时间

4月9号中午12点

抽奖规则
掘金社区
  • 须要关注个人掘金帐号才有效,我的主页

  • 使用微信抽奖助手随机抽取for掘金社区;
    掘金抽奖

微信公众号
  • 须要关注个人微信公众号才有效;
    情情说

  • 使用微信抽奖助手随机抽取for微信公众号;
    微信公众号抽奖

相关文章
相关标签/搜索