前言
随着微服务架构的兴起,如何解决微服务间远程调用成为了首当其冲的问题。那么就让我们来看下其中一种ag真人游戏的解决方案—rpc,揭开它的神秘面纱。
需要️的是：rpc不是一个具体的技术，而是指整个网络调用过程！
一个完整的rpc架构里面包含了四个核心的组件，分别是client，client stub，server以及serverstub，这个stub可以理解为存根。调用方式如下图：
rpc的目标是要把2、3、4、5、7、8、9、10这些步骤都封装起来。只剩下1、6、11
注意：无论是何种类型的数据，最终都需要转换成二进制流在网络上进行传输，数据的发送方需要将对象转换为二进制流，而数据的接收方则需要把二进制流再恢复为对象。
那么如何实现这一步呢，rpc用的是netty框架。
老规矩，还是先来看看啥是netty:
netty 是由 jboss 提供的一个 java 开源框架。netty 提供异步的、基于事件驱动的网络应用程序框架，用以快速开发高性能、高可靠性的网络 io 程序。
netty 是一个基于 nio 的网络编程框架。
欧吼，看到这里心里一慌，那啥是nio呢一会儿再来看吧哈哈，还是先把netty搞清楚吧。
1.线程模型
netty 抽象出两组线程池：bossgroup 和 workergroup，也可以叫做
bossnioeventloopgroup 和 workernioeventloopgroup。每个线程池中都有nioeventloop 线程。bossgroup 中的线程专门负责和客户端建立连接，workergroup 中的线程专门负责处理连接上的读写。bossgroup 和 workergroup 的类型都是nioeventloopgroup。
nioeventloopgroup 相当于一个事件循环组，这个组中含有多个事件循环，每个事件循环就是一个 nioeventloop。
nioeventloop表示一个不断循环的执行事件处理的线程，每个 nioeventloop 都包含一个selector，用于监听注册在其上的 socket 网络连接（channel）
nioeventloopgroup 可以含有多个线程，即可以含有多个 nioeventloop
每个 bossnioeventloop 中循环执行以下三个步骤
select：轮训注册在其上的 serversocketchannel 的 accept 事件（op_accept 事件）
processselectedkeys：处理 accept 事件，与客户端建立连接，生成一个niosocketchannel，并将其注册到某个 workernioeventloop 上的 selector 上
runalltasks：再去以此循环处理任务队列中的其他任务
每个 workernioeventloop 中循环执行以下三个步骤：
select：轮训注册在其上的 niosocketchannel 的 read/write 事件
（op_read/op_write 事件）
processselectedkeys：在对应的 niosocketchannel 上处理 read/write 事件
runalltasks：再去以此循环处理任务队列中的其他任务
在以上两个processselectedkeys步骤中，会使用 pipeline（管道），pipeline 中引用了channel，即通过 pipeline 可以获取到对应的 channel，pipeline 中维护了很多的处理器（拦截处理器、过滤处理器、自定义处理器等）。
2.核心api介绍
2.1 channelhandler及其实现类
channelhandler 接口定义了许多事件处理的方法，我们可以通过重写这些方法去实现具 体的业务逻辑。api 关系如下图所示:
netty开发中需要自定义一个 handler 类去实现 channelhandle接口或其子接口或其实现类，然后通过重写相应方法实现业务逻辑，我们接下来看看一般都需要重写哪些方法
- public void channelactive(channelhandlercontext ctx)，通道就绪事件
- public void channelread(channelhandlercontext ctx, object msg)，通道读取数据事件
- public void channelreadcomplete(channelhandlercontext ctx) ，数据读取完毕事件
- public void exceptioncaught(channelhandlercontext ctx, throwable cause)，通道发生异常事件
2.2 channelpipeline
channelpipeline 是一个 handler 的集合，它负责处理和拦截 inbound 或者 outbound 的事件和操作，相当于一个贯穿 netty 的责任链.
如果客户端和服务器的handler是一样的，消息从客户端到服务端或者反过来，每个inbound类型或outbound类型的handler只会经过一次，混合类型的handler（实现了inbound和outbound的handler）会经过两次。准确说channelpipeline中是一个channelhandlercontext,每个上下文对象中有channelhandler. inboundhandler是按照pipleline的加载顺序的顺序执行, outboundhandler是按照pipeline的加载顺序，逆序执行
2.3 channelhandlercontext
这是事件处理器上下文对 象 ， pipeline 链 中 的 实 际 处 理 节 点 。 每 个处理节点channelhandlercontext 中 包 含 一 个 具 体 的 事 件 处 理 器 channelhandler ,同时channelhandlercontext 中也绑定了对应的 channelpipeline和 channel 的信息，方便对
channelhandler 进行调用。常用方法如下所示：
- channelfuture close()，关闭通道
- channeloutboundinvoker flush()，刷新
- channelfuture writeandflush(object msg) ， 将 数 据 写 到channelpipeline 中 当 前 channelhandler 的下一个 channelhandler 开始处理（出站）
java nio 全称java non-blocking io ，是指 jdk 提供的新 api。从 jdk1.4 开始，java 提供了一系列改进的输入/输出的新特性，被统称为 nio(即 new io)，是同步非阻塞的。
nio 有三大核心部分：channel(通道)，buffer(缓冲区), selector(选择器)
- 每个 channel 都会对应一个 buffer
- selector 对应一个线程， 一个线程对应多个 channel(连接) 3. 每个 channel 都注册到 selector选择器上
- selector不断轮询查看channel上的事件, 事件是通道channel非常重要的概念
- selector 会根据不同的事件，完成不同的处理操作
- buffer 就是一个内存块 ， 底层是有一个数组
- 数据的读取写入是通过 buffer, 这个和 bio , bio 中要么是输入流，或者是输出流, 不能双向，但是
nio 的 buffer 是可以读也可以写 , channel 是双向的.
1.缓冲区(buffer)
缓冲区本质上是一个可以读写数据的内存块，可以理解成是一个数组，该对象提供了一组方法，可以更轻松地使用内存块，缓冲区对象内置了一些机制，能够跟踪和记录缓冲区的状态变化情况。channel 提供从网络读取数据的渠道，但是读取或写入的数据都必须经由 buffer。
在 nio 中，buffer是一个顶层父类，它是一个抽象类, 类的层级关系图,常用的缓冲区分别对应byte,short, int, long,float,double,char 7种.
2.通道(channel)
通常来说nio中的所有io都是从 channel（通道） 开始的。nio 的通道类似于流，但有些区别如下：
- 通道可以读也可以写，流一般来说是单向的（只能读或者写，所以之前我们用流进行io操作的时候
需要分别创建一个输入流和一个输出流） - 通道可以异步读写
- 通道总是基于缓冲区buffer来读写
3. selector (选择器)
可以用一个线程，处理多个的客户端连接，就会使用到nio的selector(选择器). selector 能够检测多个注册的服务端通道上是否有事件发生，如果有事件发生，便获取事件然后针对每个事件进行相应的处理。这样就可以只用一个单线程去管理多个通道，也就是管理多个连接和请求。
以上就是对rpc的简单介绍，欢迎评论区留言！