摘要：一旦某个事件触发，相应的则会被调用，并进行处理。事实上，内部的连接处理协议编解码超时等机制，都是通过完成的。开启源码之门理解了的事件驱动机制，我们现在可以来研究的各个模块了。
Netty是什么
大概用Netty的，无论新手还是老手，都知道它是一个“网络通讯框架”。所谓框架，基本上都是一个作用：基于底层API，提供更便捷的编程模型。那么"通讯框架"到底做了什么事情呢？回答这个问题并不太容易，我们不妨反过来看看，不使用netty，直接基于NIO编写网络程序，你需要做什么(以Server端TCP连接为例，这里我们使用Reactor模型)：
监听端口，建立Socket连接
建立线程，处理内容
读取Socket内容，并对协议进行解析
进行逻辑处理
回写响应内容
如果是多次交互的应用(SMTP、FTP)，则需要保持连接多进行几次交互
关闭连接
建立线程是一个比较耗时的操作，同时维护线程本身也有一些开销，所以我们会需要多线程机制，幸好JDK已经有很方便的多线程框架了，这里我们不需要花很多心思。
此外，因为TCP连接的特性，我们还要使用连接池来进行管理：
建立TCP连接是比较耗时的操作，对于频繁的通讯，保持连接效果更好
对于并发请求，可能需要建立多个连接
维护多个连接后，每次通讯，需要选择某一可用连接
连接超时和关闭机制
想想就觉得很复杂了！实际上，基于NIO直接实现这部分东西，即使是老手也容易出现错误，而使用Netty之后，你只需要关注逻辑处理部分就可以了。
体验Netty
这里我们引用Netty的example包里的一个例子，一个简单的EchoServer，它接受客户端输入，并将输入原样返回。其主要代码如下：
public void run() {
// Configure the server.
ServerBootstrap bootstrap = new ServerBootstrap(
new NioServerSocketChannelFactory(
Executors.newCachedThreadPool(),
Executors.newCachedThreadPool()));
// Set up the pipeline factory.
bootstrap.setPipelineFactory(new ChannelPipelineFactory() {
public ChannelPipeline getPipeline() throws Exception {
return Channels.pipeline(new EchoServerHandler());
}
});
// Bind and start to accept incoming connections.
bootstrap.bind(new InetSocketAddress(port));
}
这里 EchoServerHandler 是其业务逻辑的实现者，大致代码如下：
public class EchoServerHandler extends SimpleChannelUpstreamHandler {
@Override
public void messageReceived(
ChannelHandlerContext ctx, MessageEvent e) {
// Send back the received message to the remote peer.
e.getChannel().write(e.getMessage());
}
}
还是挺简单的，不是吗？
Netty背后的事件驱动机制
完成了以上一段代码，我们算是与Netty进行了第一次亲密接触。如果想深入学习呢？
阅读源码是了解一个开源工具非常好的手段，但是Java世界的框架大多追求大而全，功能完备，如果逐个阅读，难免迷失方向，Netty也并不例外。相反，抓住几个重点对象，理解其领域概念及设计思想，从而理清其脉络，相当于打通了任督二脉，以后的阅读就不再困难了。
理解Netty的关键点在哪呢？我觉得，除了NIO的相关知识，另一个就是事件驱动的设计思想。什么叫事件驱动？我们回头看看 EchoServerHandler 的代码，其中的参数： public void messageReceived(ChannelHandlerContext ctx, MessageEvent e) ，MessageEvent就是一个事件。这个事件携带了一些信息，例如这里 e.getMessage() 就是消息的内容，而 EchoServerHandler 则描述了处理这种事件的方式。一旦某个事件触发，相应的Handler则会被调用，并进行处理。这种事件机制在UI编程里广泛应用，而Netty则将其应用到了网络编程领域。
在Netty里，所有事件都来自 ChannelEvent 接口，这些事件涵盖监听端口、建立连接、读写数据等网络通讯的各个阶段。而事件的处理者就是 ChannelHandler ，这样，不但是业务逻辑，连网络通讯流程中底层的处理，都可以通过实现 ChannelHandler 来完成了。事实上，Netty内部的连接处理、协议编解码、超时等机制，都是通过handler完成的。当博主弄明白其中的奥妙时，不得不佩服这种设计！
下图描述了Netty进行事件处理的流程。 Channel 是连接的通道，是ChannelEvent的产生者，而 ChannelPipeline 可以理解为ChannelHandler的集合。
开启Netty源码之门
理解了Netty的事件驱动机制，我们现在可以来研究Netty的各个模块了。Netty的包结构如下：
org └── jboss └── netty ├── bootstrap 配置并启动服务的类 ├── buffer 缓冲相关类，对NIO Buffer做了一些封装 ├── channel 核心部分，处理连接 ├── container 连接其他容器的代码 ├── example 使用示例 ├── handler 基于handler的扩展部分，实现协议编解码等附加功能 ├── logging 日志 └── util 工具类
在这里面， channel 和 handler 两部分比较复杂。我们不妨与Netty官方的结构图对照一下，来了解其功能。
具体的解释可以看这里： http://netty.io/3.7/guide/#ar... 。图中可以看到，除了之前说到的事件驱动机制之外，Netty的核心功能还包括两部分：
Zero-Copy-Capable Rich Byte Buffer
零拷贝的Buffer。为什么叫零拷贝？因为在数据传输时，最终处理的数据会需要对单个传输层的报文，进行组合或者拆分。NIO原生的ByteBuffer无法做到这件事，而Netty通过提供Composite(组合)和Slice(切分)两种Buffer来实现零拷贝。这部分代码在 org.jboss.netty.buffer 包中。
这里需要额外注意，不要和操作系统级别的Zero-Copy混淆了, 操作系统中的零拷贝主要是用户空间和内核空间之间的数据拷贝, NIO中通过DirectBuffer做了实现.
Universal Communication API
统一的通讯API。这个是针对Java的Old I/O和New I/O，使用了不同的API而言。Netty则提供了统一的API( org.jboss.netty.channel.Channel )来封装这两种I/O模型。这部分代码在 org.jboss.netty.channel 包中。
此外，Protocol Support功能通过handler机制实现。
文章版权归作者所有，未经允许请勿转载,若此文章存在违规行为，您可以联系管理员删除。
转载请注明本文地址：https://www.ucloud.cn/yun/77663.html
摘要：简单来说就是把注册的动作异步化，当异步执行结束后会把执行结果回填到中抽象类一般就是公共逻辑的处理，而这里的处理主要就是针对一些参数的判断，判断完了之后再调用方法。 阅读这篇文章之前，建议先阅读和这篇文章关联的内容。 1. 详细剖析分布式微服务架构下网络通信的底层实现原理（图解） 2. (年薪60W的技巧)工作了5年，你真的理解Netty以及为什么要用吗？（深度干货）...
1.EventLoopGroup类结构 showImg(https://segmentfault.com/img/bVbuL9F?w=470&h=433); 重点：继承了ScheduledExecutorService类 2.NioEventLoopGroup类结构 showImg(https://segmentfault.com/img/bVbuL9Y?w=537&h=699); 核心代码Nio...
摘要：零前期准备文章异常啰嗦且绕弯。二是底层真正起作用的类，并且提供了大量的静态方法。在普通的线程中，这个对象由于本身没有的原生支持，所以只能附着在对象当中。同一个线程中如果创建多个对象，获取到的是同一个。 零 前期准备 0 FBI WARNING 文章异常啰嗦且绕弯。 1 版本 JDK 版本 : OpenJDK 11.0.1 IDE : idea 2018.3 Netty 版本 : net...
摘要：一些想法这个系列想开很久了，自己使用也有一段时间了，利用也编写了一个简单的框架，并运用到工作中了，感觉还不错，趁着这段时间工作不是很忙，来分析一波源码，提升下技术硬实力。 一些想法 这个系列想开很久了，自己使用netty也有一段时间了，利用netty也编写了一个简单的框架，并运用到工作中了，感觉还不错，趁着这段时间工作不是很忙，来分析一波源码，提升下技术硬实力。 结构 这里先看下net...
摘要：版本选择目前企业使用最多的版本，最为稳定。例如使用的就是版本引入了内存池等重大特性，可以有效的降低负载，使用的就是已经被废弃了，具体可参见所以这里我搭建的源码阅读环境是存在的版本。 showImg(https://segmentfault.com/img/remote/1460000012398550?w=1624&h=1080); Netty 简介 Netty 是由 JBOSS 提供...
阅读 1291·2021-09-27 13:56
阅读 2303·2019-08-26 10:35
阅读 3481·2019-08-23 15:53
阅读 1824·2019-08-23 14:42
阅读 1216·2019-08-23 14:33
阅读 3534·2019-08-23 12:36
阅读 1931·2019-08-22 18:46
阅读 956·2019-08-22 14:06
