说起RPC，大家都已经很熟悉了，随着soa的出现和普及，远程分布式调用已经成为主流。今年来流行的微服务更是让RPC大放光彩。目前业界开源的rpc框架非常多，比较主流的RPC框架有facebook开发的Apache Thrift，Hadoop的Avro-RPC，google开源的gRpc等。dubbo也是基于rpc框架之上的一个服务治理框架。

下面将通过java原生的序列化，Socket通信，动态代理和反射机制，实现一个简单的RPC框架。

它主要由三部分组成：

1：服务提供者，它运行在服务端，负责提供服务接口定义和服务实现类。

2：服务发布者，它运行在RPC服务端，负责将本地服务发布成远程服务，供其他消费者调用。

3：本地服务代理，它运行在RPC客户端，通过代理调用远程服务提供者，然后将结果进行封装返回给本地消费者。

首先是服务端接口定义和实现：

服务端的服务发布者代码如下

服务发布者的主要职责如下：

1）作为服务端，监听客户端的TCP连接，接收到新的客户端连接之后，将其封装成Task，有线程池执行。

2）将客户端发送的码流反序列化成对象，反射调用服务实现者，获取执行结果。

3）将执行结果对象反序列化，通过Socket发送给客户端。

4）远程服务调用完成之后，释放socket等连接资源，防止句柄泄露。

接下来是客户端本地服务代理源码：

本地服务代理的主要功能如下：

1）将本地的接口调用转换成JDK的动态代理，在动态代理中实现接口的远程调用。

2）创建Socket客户端，根据指定地址连接远程服务提供者。

3）将远程服务调用所需的接口类，方法名，参数列表等编码后发送给服务提供者。

4）同步阻塞等待服务端返回应答，获取应答之后返回。

下面是测试代码

首先，创建一个异步发布服务端的线程并启动，用于接收RPC客户端的请求，根据请求参数调用服务实现类，返回结果给客户端。随后，创建客户端服务代理类，构造RPC请求参数，发起RPC调用，将调用结果输出到控制台。执行结果如下图所示：