RPC(Remote Procedure Call)-远程过程调用,简单的理解就是像调用本地服务一样使用远程服务。RPC是分布式服务的基础,类似Hadoop,Spark,Kafka等等,都实现了自己的RPC框架。本文基于netty实现一个简易的RPC服务。
一个RPC框架一般有三个核心部分:1 基础的网络通信服务如java nio,netty等,本文使用netty作为基础网络服务 2 序列化工具,如avro,Kryo等等,本文使用java自身序列化机制 3 代理服务,如cglib,javaassist等,本文使用java动态代理机制
一 服务端
服务端监控8080端口,对客户端数据进行一系列处理之后,进入ServerHanlder调用链
ServerHanlder 继承netty中ChannelInboundHandlerAdapter。通过反射机制,调用对象方法,并将结果返回。
二 客户端调用
客户端简单过程如下:1,生成本地ClientRpc,2,生成ClientRpc的代理对象,代理远程服务,3,调用代理服务,并解析返回值
ClientRpc对象只有一个hello方法,hello方法执行System.out.println("hello xxx")。
关键部分封装在代理对象中,代理类首先将参数封装在ClassInfo对象中,该对象包含执行的类名className,方法名methodName,参数值objects,参数类型types。然后连接服务端,请求服务端的rpc执行该方法。如下所示:
客户端resultHandler服务对服务端返回结果进行解析,本文简单的打印返回结果:
最后实验的结果如下,方法在服务端执行,并将结果“hello 世界”返回给客户端:
总结:
其实Java本身提供的RMI是一种简单的RPC服务,但是RMI不能跨语言调用。当定义好协议之后,RPC服务可以实现语言无关。社区中有很多著名的开源项目都实现了自己的RPC服务,但核心原理都大同小异。