netty的底层源码（netty 源码深入分析）

时间：2023年10月13日 03:10:32

本文目录一览：

SOFARPC 故障剔除：细致到进程对外暴露服务 (IP + 服务)，部署在某个机器上的交易系统对外提供的交易查询服务 TransQueryService(服务接口) 降级级别：整个系统服务，不是接口级别。

. 分布式框架-Dubbo 旨在深度分析服务之间调用逻辑，从剖析RPC底层原理开始，通过手写RPC框架，掌握RPC实现逻辑。通过全方位介绍微服务RPC框架Dubbo，实现Dubbo在各实战场景中的应用。

这里向工作线程WorkerThread传入了socket和用于服务端实例service。WorkerThread实现了Runnable接口，用于接收RpcRequest对象，解析并且调用，生成RpcResponse对象并传输回去。

在我了解的范围里，目前只有 dubbo 、 SOFARPC 、 HSF 三个阿里系的 RPC 框架支持了接口级的服务发现。

在实际的实现中，RPC路由器和RPC服务器均是作为一个虚拟的字符型设备来存在的。

RPC 的全称是 Remote Procedure Call 是一种进程间通信方式。它允许程序调用另一个地址空间（通常是共享 *** 的另一台机器上）的过程或函数，而不用程序员显式编码这个远程调用的细节。

netty的底层源码（netty 源码深入分析）

本文将用netty实现一个简单的RPC框架。RPC，远程调用，就是A程序部署在1号机器上，B程序部署在2号机器上，A可以像调本地 *** 一样地去调用B程序，而不需要程序员额外地编写这个交互过程，这就叫RPC远程调用。

而 Client 在 Spring getBean 的时候，会创建 Client，调用远程 *** 的时候，将数据通过DubboCodec编码发送到 NettyServer，然后 NettServer 收到数据后解码，并调用本地 *** ，并返回数据，完成一次完美的 RPC 调用。

在dubbo 生产者服务暴露和消费者消费引用的过程中都会启动qos，并且qos 通过cas来保证一个jvm只启动一次。

在Dubbo的Dispatcher扩展点会使用到这些线程池，Dispatcher这个扩展点用于决定Netty ChannelHandler中的那些事件在Dubbo提供的线程池中执行。缓冲线程池，默认配置如下就默认配置来看，和Executors创建的差不多，存在内存溢出风险。

之所以 Netty 性能高，因为其使用的是 Reactor 反应器模式。关于反应器模式原理，请参见《Netty Zookeeper Redis 高并发实战》一书。

我们跟读一下源码，看看qos 服务的启动，请求处理，上下线等。在dubbo 生产者服务暴露和消费者消费引用的过程中都会启动qos，并且qos 通过cas来保证一个jvm只启动一次。

1、如果设置了优化开关（默认优化选项是开启的），则通过反射的方式从Selector中获取selectedKeys和publicSelectedKeys，将这两个成员设置为可写，通过反射，使用Netty构造的selectedKeySet将原生JDK的selectedKeys替换掉。

2、Netty是由JBOSS提供的一个java开源框架，现为Github上的独立项目。Netty提供异步的、事件驱动的 *** 应用程序框架和工具，用以快速开发高性能、高可靠性的 *** 服务器和客户端程序。

3、由于传统基于BIO的同步阻塞通信无法满足高可靠、高性能的Java服务器领域，从JDK4开始，Java提供了一套新的异步非阻塞I/O类库：NIO。然而由于NIO编程的复杂性，很长一段时间NIO编程并没有流行起来。

4、\x0d\x0a利用主从NIO线程模型，可以解决1个服务端监听线程无法有效处理所有客户端连接的性能不足问题。

5、当Netty发送或者接受一个消息的时候，就将会发生一次数据转换。入站消息会被解码：从字节转换为另一种格式(比如Java对象)；如果是出站消息，它会被编码成字节。

1、Netty有四种内存规格，tiny表示16B ~ 512B之间的内存块，samll表示512B ~ 8K之间的内存块，normal表示8K ~ 16M的内存块，Huge表示大于16M的内存块。

2、通过复习 setByteBuffer *** ，获取 NIO 缓存区 buffer 对应的直接内存地址。通过 UnsafeByteBufUtil 对应 *** ，直接从内存地址获取对应基本类型数据。

1、UnpooledDirectByteBuf 主要是通过 NIO 缓存区 buffer 来存储数据。而它获取和设置数据，也都是通过 NIO 缓存区对应 *** 实现的。光看介绍，和 UnpooledDirectByteBuf 没有任何区别。

2、引用计数记录了当前ByteBuf被引用的次数。新建一个ByteBuf它的refCnt是1，当refCnt == 0时，这个ByteBuf即可被回收。引用技术主要用于内存泄露的判断，Netty提供了内存泄露检测工具。

3、Netty通过ByteBufAllocator进行内存分配，ByteBufAllocator有两个实现类：PooledByteBufAllocator与UnpooledByteBufAllocator，其中，是否在堆内存或者直接内存分配与是否使用unsafe进行读写操作都封装在其实现类中。

Netty的组件设计： Netty的主要组件有Channel、EventLoop、ChannelFuture、ChannelHandler、ChannelPipe等。ChannelHandler充当了处理入站和出站数据的应用程序逻辑的容器。

出站：StringEncoder---HeadContext ServerHandler类是自定义的入站类，在调用channelRead0 *** 读取数据后，经服务端转发到非当前客户端。实现简单聊天室功能。

Netty事件分为入站事件与出站事件，可以通过ChannelPipline或者ChannelHandlerContext进行事件传播。

好了，到目前为止，我们对Netty的ChannelOption的设置以及底层的实现已经分析完了，简单的来说：Netty在初始化Channel时会构建一个ChannelConfig对象，而ChannelConfig是Channel配置属性的 *** 。

本书由浅入深的引领读者掌握Netty主要类库的使用，编解码框架的定制和开发，私有协议栈的设计和实现。在源码分析章节对Netty的核心类库进行原理剖析和讲解。