netty实现简单RPC

    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调用链

《netty实现简单RPC》 服务端监听服务

ServerHanlder 继承netty中ChannelInboundHandlerAdapter。通过反射机制,调用对象方法,并将结果返回。

《netty实现简单RPC》 反射执行方法

二 客户端调用

客户端简单过程如下:1,生成本地ClientRpc,2,生成ClientRpc的代理对象,代理远程服务,3,调用代理服务,并解析返回值

《netty实现简单RPC》

ClientRpc对象只有一个hello方法,hello方法执行System.out.println(“hello xxx”)。

关键部分封装在代理对象中,代理类首先将参数封装在ClassInfo对象中,该对象包含执行的类名className,方法名methodName,参数值objects,参数类型types。然后连接服务端,请求服务端的rpc执行该方法。如下所示:

《netty实现简单RPC》 代理远程服务

客户端resultHandler服务对服务端返回结果进行解析,本文简单的打印返回结果:

《netty实现简单RPC》 客户端处理返回值

最后实验的结果如下,方法在服务端执行,并将结果“hello 世界”返回给客户端:

《netty实现简单RPC》

总结:

       其实Java本身提供的RMI是一种简单的RPC服务,但是RMI不能跨语言调用。当定义好协议之后,RPC服务可以实现语言无关。社区中有很多著名的开源项目都实现了自己的RPC服务,但核心原理都大同小异。

    原文作者:图灵家的油烟机
    原文地址: https://www.jianshu.com/p/fa50fdcd185e
    本文转自网络文章,转载此文章仅为分享知识,如有侵权,请联系博主进行删除。
点赞