|
说起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调用，将调用结果输出到控制台。执行结果如下图所示： |
|
|
