Netty事件监听和处理(上)

通过介绍,你会了解到:

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

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

本篇最后会说明下福利的抽取规则,大家积极参与 >_<

相关概念

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

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

事件监听

JDK监听器模式主要包含以下元素:

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

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

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

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

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

责任链模式

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

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

socket

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

网络编程主要通过操作系统提供的socket接口进行,通过了解socket接口可以总结出有哪些事件。

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

NIO和IO模型

NIO是指非阻塞IO,我们一般说的IO都是阻塞IO,想全面了解这些概念,又会说的很多,这里就简单概括下。

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

用户线程发起read请求后,需要等待数据到达才能返回,在这期间,用户线程不能做任何事情,如果是网络编程,可能有很多Socket对象进行监听,会创建大量线程被阻塞,造成资源浪费,性能下降。

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

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

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

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

之前做过NIO开发的朋友,可以看下面的示例回顾下整个过程:

线程模型

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

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

Netty总体结构

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

概述

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

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

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

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传输
  • 本地传输
事件模型

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

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

欢迎扫描下方二维码,关注我的个人微信公众号 ~

原文地址:http://blog.51cto.com/13714880/2113482

时间: 2024-10-04 00:26:50

Netty事件监听和处理(上)的相关文章

Netty事件监听和处理(下)

上一篇 介绍了事件监听.责任链模型.socket接口和IO模型.线程模型等基本概念,以及Netty的整体结构,这篇就来说下Netty三大核心模块之一:事件监听和处理. 前面提到,Netty是一个NIO框架,它将IO通道的建立.可读.可写等状态变化,抽象成事件,以责任链的方式进行传递,可以在处理链上插入自定义的Handler,对感兴趣的事件进行监听和处理. 通过介绍,你会了解到: 事件监听和处理模型 事件监听:EventLoop 事件处理:ChannelPipeline和ChannelHandle

cocos2d-x 事件分发机制 ——加速计事件监听

加速计事件监听机制 在上一篇中介绍了cocos2d-x中的触摸事件机制,这篇来介绍下游戏中也经常用到的加速计事件,这些都是游戏中的经常要用到的. 移动设备上一个很重要的输入源是设备的方向,大多数设备都配备了加速计,用于测量设备静止或匀速运动时所受到的重力方向. 重力感应来自移动设备的加速计,通常支持X.Y和Z三个方向的加速度感应,又称为三向加速计.实际应用中,可以根据三个方向的力度大小来计算手机倾斜的角度和方向. 3.0机制中,我们只需要创建一个加速计监听器EventListenerAccele

Zookeeper 事件监听 - 史上最详解读

目录 写在前面 1.1. Curator 事件监听 1.1.1. Watcher 标准的事件处理器 1.1.2. NodeCache 节点缓存的监听 1.1.3. PathChildrenCache 子节点监听 1.1.4. Tree Cache 节点树缓存 写在最后 疯狂创客圈 亿级流量 高并发IM 实战 系列 疯狂创客圈 Java 分布式聊天室[ 亿级流量]实战系列之 -25[ 博客园 总入口 ] 写在前面 ? 大家好,我是作者尼恩.目前和几个小伙伴一起,组织了一个高并发的实战社群[疯狂创客

屏幕触摸事件监听,判断上下左右的操作行为,判断方法缩小的操作行为

在手机屏幕上能够实现的人机交互行为,大致包括点击按钮,拉动滑动块,物体缩放,上下左右拉动等. 手机屏幕触摸事件的监听方法: 1.首先要设置一块布局区域,frameLayout/LinearLayout等都可以,并为布局设置id: 2.在Activity中声明相应的布局类型,并通过findViewById()方法找到该布局,然后为该布局区域设置setOnTouchListener()方法,就能监听在相应屏幕触摸操作 实现屏幕触摸事件监听的代码: private LinearLayout Land;

JavaScript-4.5 事件大全,事件监听---ShinePans

绑定事件 <input type="bubtton" onclick="javascript:alert('I am clicked');"> 处理事件 <script language="JavaScript" for="对象" event="事件"> ... (事件处理代码) ... </script> 鼠标事件举例 <script language="

[基础控件]---状态切换控件CompoundButton及其子类CheckBox、RadioButton、ToggleButton、switch事件监听与场景使用

一.事件监听 对于普通的Button,对其进行事件监听Google官方给出了常见的三种监听方式:1.对每一个button设置事件监听器button.setOnClickListener(View.OnclickListener  listener);此种方法当button按钮较多时代码显得多.乱.不够简洁明了. 2.在Activity中实现接口View.OnclickListener,然后重写void onClick(View v)方法,在方法中通过switch(v.getId())予以区分不同

Windows 8 应用程序前后台切换事件监听

在一些情况下,我们需要监听应用程序切换到后台或者从后台切换至前台的事件,从而进行相关处理操作.支付宝应用锁屏(IOS,Android平台)的处理中就需要监听此事件,在用户将应用切换至后台一段时间后再切换至前台的情况下就需要弹出锁屏页面. 下图给出Windows 应用商店应用的生命周期图,应用前后台切换就是在运行和挂起直接进行切换,关于生命周期的详细介绍可以参阅官方文档:http://msdn.microsoft.com/zh-cn/library/windows/apps/hh464925.as

Java中的事件监听机制

鼠标事件监听机制的三个方面: 1.事件源对象: 事件源对象就是能够产生动作的对象.在Java语言中所有的容器组件和元素组件都是事件监听中的事件源对象.Java中根据事件的动作来区分不同的事件源对象,动作发生在哪个组件上,那么该组件就是事件源对象 2.事件监听方法: addMouseListener(MouseListener ml) ;该方法主要用来捕获鼠标的释放,按下,点击,进入和离开的动作:捕获到相应的动作后,交由事件处理类(实现MouseListener接口)进行处理. addAction

UI事件监听的击穿

什么是UI事件监听的击穿 在游戏视图中,有两个UI界面叠在一起的时候,单击一个空白处,却触发了被覆盖在下层了UI界面中的单击事件,这就是单击击穿了上层界面. 假设场景中放置了一个箱子,单击箱子会触发一个开箱事件,如果单击一个UI,恰好UI在视觉上将箱子覆盖了,那么它也许就会触发箱子的单击事件. 如何避免和解决UI事件监听的击穿 第一种方法:用一层BoxCollider覆盖,进行遮挡. 在界面底板上Attach一个BoxCollider. 第二种方法:使用EventMask Unity的Camer