博客
关于我
强烈建议你试试无所不能的chatGPT,快点击我
Netty概念和体系结构
阅读量:6495 次
发布时间:2019-06-24

本文共 1502 字,大约阅读时间需要 5 分钟。

异步和事件驱动

 Netty是一款异步的事件驱动的网络应用程序框架,支持快速地开发可维护的高性能的面向协议的服务器和客户端。

Netty简介

分类 Netty特性
设计 统一的API,支持多种传输类型,阻塞的和非阻塞的
简单强的的线程模型
真正的无连接数据报套接字支持
链接逻辑组件以支持复用
易用使用 详实的Javadoc和大量的事例集
不需要超过JDK1.6+的依赖
性能 拥有比Java的核心API更高的吞吐量以及更低的延迟
得益于池化和复用,拥有更低的资源消耗
最少的内存复制
健壮性 不会因为慢速、快速或者超载的连接而导致OutOfMemoryError
消除在高速网络中NIO应用程序常见的不公平读/写比率
安全性 完整的SSL/TLS以及StartTLS支持
可用于受限环境下,如Applet和OSGI
社区驱动 发布快速而且频繁

Netty核心组件

Netty主要构件块:

  1. Channel
  2. 回调
  3. Future
  4. 事件和ChannelHandler

Channel

 它代表一个实体(如一个硬件设备、一个文件、一个网络套接字或者一个能够执行一个或者多个不同的I/O操作的程序组件)的开放连接,如读操作和写操作。

 Channel可以看作是传入(入站)或传出(出站)数据的载体,它可以被打开或者被关闭,连接或者断开连接。

回调

 一个回调其实就是一个方法,一个指向已经被提供给另外一个方法的方法的引用,这个可以使得后者可以在适当的时候调用前者。

 例如:ChannelHandler中的channelActive()回掉方法会在当一个新的连接已经被建立时将会被调用。

Future

 Future提供了另一种在操作完成时通知应用程序的方式。这个对象可以看作是一个异步操作的结果的占位符,它将在未来的某个时刻完成,并提供对其结果的访问。

  JDK内置了java.util.cocurrent.Future,但是其所提供的实现,只允许手动检查对应的操作是否已经完成,或者一直阻塞直到它完成。
 Netty提供了自己的实现——ChannelFuture.
 ChannelFuture提供了几种额外的方法,这些方法使得我们能够注册一个或者多个ChannelListener实例。监听器的回调方法operationComplete()将会在对应的操作完成时被调用。然后监听器可以判断该操作是成功完成还是出错,如果是后者,我们还可以检索产生的Throwable。
 由ChannelFutureListener提供的通知机制消除了手动检查对应的操作是否完成的必要。
 每个Netty的出站I/O操作都将返回一个ChannelFuture,也就是说,它们都不会阻塞。

事件和ChannelHandler

 Netty使用不同的事件来通知我们状态的改变或者是操作的状态。这使得我们能够基于已经发生的事件来触发适当的动作,如:

  • 记录日志
  • 数据转换
  • 流控制
  • 应用程序逻辑

 Netty是一个编程网络框架,所以事件是按照它们入站或出站数据流的相关性进行分类的。

 可能由入站数据或者相关状态更改而触发的事件包括:

  • 连接已被激活或者连接失活
  • 数据读取
  • 用户事件
  • 错误事件

 出站事件是未来将会触发的某个动作的操作结果,包括:

  • 打开或者关闭到远程节点的连接
  • 将数据写到或者冲刷到套接字

每个事件都可以被分发给ChannelHandler类中的某个用户实现的方法。

 Netty提供了大量预定义的开箱急用的ChannelHandler实现,包括用于各种协议(如HTTP和SSL/TLS)的ChannelHandler。

流经ChannelHandler链的入站和出站事件

转载地址:http://kouyo.baihongyu.com/

你可能感兴趣的文章
mysql半同步复制实现
查看>>
沙朗javascript总结一下(一)---基础知识
查看>>
js深入研究之函数内的函数
查看>>
LeetCode:4_Median of Two Sorted Arrays | 求两个排序数组的中位数 | Hard
查看>>
uva-12657 - Boxes in a Line(双向链表)
查看>>
python之commands模块
查看>>
android应用开发--------------看RadioGroup源代码,写相似单选选项卡的集成控件(如底部导航,tab等等)...
查看>>
GCD 和延时调用
查看>>
LeetCode - Binary Tree Level Order Traversal
查看>>
FTP协议完全详解
查看>>
iOS:实现图片的无限轮播
查看>>
【C语言天天练(十五)】字符串输入函数fgets、gets和scanf
查看>>
【环境配置】配置sdk
查看>>
accept()
查看>>
USB 2.0 Hub IP Core
查看>>
USB 2.0 OTG IP Core
查看>>
解读浮动闭合最佳方案:clearfix
查看>>
Charles使用
查看>>
Python GUI编程(Tkinter) windows界面开发
查看>>
linux内核netfilter模块分析之:HOOKs点的注册及调用
查看>>