分布式系统间通信之RPC简单Demo(七)

时间:2022-07-09 07:38:54

看似终点,回到起点。第一次接触C#,编写的第一个真正的Demo是基于Socket的简单通信,现在JAVA开始的第一个RPC的Demo也是基于Socket。。

下面通过java原生的序列化,Socket通信,动态代理和反射机制,实现最简单的RPC框架。它由三个部分组成。

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

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

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

EchoService接口定义:

分布式系统间通信之RPC简单Demo(七)

EchoService接口的实现:

分布式系统间通信之RPC简单Demo(七)

RPC服务端服务的发布:

分布式系统间通信之RPC简单Demo(七)

分布式系统间通信之RPC简单Demo(七)

服务发布者的主要作用:

  1. 作为服务端,监听客户端的TCP连接,接收到新的客户端连接之后,将其封装称task任务,由线程池执行。

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

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

  4. 远程服务调用完成后,释放Socket等连接资源,防止句柄泄露。

本地服务代理的实现:

分布式系统间通信之RPC简单Demo(七)

本地服务代理的主要功能:

1将本地的接口调用转化成JDK的动态代理,在动态代理中实现接口的远程调用

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

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

4同步阻塞等待服务端返回应答,获取应答之后返回数据。

最后测试代码:

分布式系统间通信之RPC简单Demo(七)

首先,创建一个异步发布服务端的线程并启动,用于接收RPC客户端的请求,根据请求参数调用服务实现类,返回结果给调用端。

测试结果如下:

分布式系统间通信之RPC简单Demo(七)