第 1 章 Netty——异步和事件驱动
2017-12-11 本文已影响0人
FaDeo_O
- Netty是一款异步的事件驱动的网络应用程序框架，支持快速地开发可维护的高性能的面向协议的服务器和客户端
- 传统Java网络编程，
accept形式提供阻塞式 IO 能支撑中小数量客户端
image.png
- 存在大量线程处于休眠，只是等待输入或者输出数据就绪，资源浪费
- 需要为每个线程的调用栈都分配内存
- 大量线程上下文切换所带来的开销就会带来麻烦
-
Java NIO（New Input/Output => Non-blocking I/O）提供了非阻塞 IO，核心是
class java.nio.channels.Selector通过事件通知 API 以确定在一组非阻塞套接字中有哪些已经就绪能够进行IO操作
image.png
- 使用较少的线程便可以处理许多连接，因此也减少了内存管理和上下文切换所带来开销
- 当没有 I/O 操作需要处理的时候，线程也可以被用于其他任务
- 在高负载下可靠和高效地处理和调度 I/O 操作是一项繁琐而且容易出错的任务
-
Netty特性总结
-
设计
- 统一的 API，支持多种传输类型，阻塞的和非阻塞的
- 简单而强大的线程模型
- 真正的无连接数据报套接字支持
- 链接逻辑组件以支持复用
-
易于使用
- 文档详实，不需要 JDK 之外的依赖
-
性能
- 拥有比 Java 的核心 API 更高的吞吐量以及更低的延迟
- 得益于池化和复用，拥有更低的资源消耗
- 最少的内存复制
-
健壮性
- 不会因为慢速、快速或者超载的连接而导致 OutOfMemoryError
- 消除在高速网络中 NIO 应用程序常见的不公平读/写比率
-
安全性
- 完整的 SSL/TLS 以及 StartTLS 支持
- 可用于受限环境下，如 Applet 和 OSGI ？？？？？？
-
社区驱动
- 发布快速而且频繁
-
设计
-
Netty的核心组件
- Channel 代表一个到实体的开放连接，可看作是传入（入站）或者传出（出站）数据的载体，可以被打开或者被关闭，连接或者断开连接
-
回调 就是一个方法，一个指向已经被提供给另外一个方法的方法的引用。这使得后者可以在适当的时候调用前者,Netty 在内部使用了回调来处理事件；当一个回调被触发时，相关的事件可以被一个
interfaceChannelHandler的实现处理，比如ChannelFutureListener -
Future 可以看作是一个异步操作的结果的占位符；它将在未来的某个时刻完成，并提供对其结果的访问，Netty 提供了
ChannelFuture用于在异步操作的时候使用，每个 Netty 的出站 I/O 操作都将返回一个ChannelFuture(完全是异步和事件驱动的) -
事件和 ChannelHandler，在 Netty 中事件按照出/入站数据流进行分类
- 入站数据或相关状态更改触发的事件包括：连接已被激活或者失活；数据读取；用户事件；错误事件
-
出站事件是未来将会出发的某个动作的操作结果：打开或者关闭到远程节点的连接；将数据写或者冲刷到套接字
image.png
- ChannelHandler 为处理器提供了基本的抽象，可理解为一种为了响应特定事件而被执行的回调
- JBoss Marshalling编解码器
- CompatibleMarshallingDecoder、CompatibleMarshallingEncoder：与只使用 JDK 序列化的远程节点兼容
- MarshallingDecoder、MarshallingEncoder：适用于使用 JBoss Marshalling 的节点。这些类必须一起使用
- Netty为支持protobuf所提供的ChannelHandler实现
- ProtobufDecoder：使用 protobuf 对消息进行解码
- ProtobufEncoder：使用 protobuf 对消息进行编码
- ProtobufVarint32FrameDecoder：根据消息中的Google Protocol Buffers 的“Base 128 Varints”整型长度字段值动态地分割所接收到的 ByteBuf
- ProtobufVarint32LengthFieldPrepender：向 ByteBuf 前追加一个 Google Protocal Buffers 的“Base128 Varints”整型的长度字段值
