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

服务端监听服务

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服务,但核心原理都大同小异。

最后编辑于
©著作权归作者所有,转载或内容合作请联系作者
平台声明:文章内容(如有图片或视频亦包括在内)由作者上传并发布,文章内容仅代表作者本人观点,简书系信息发布平台,仅提供信息存储服务。

推荐阅读更多精彩内容

  • Spring Cloud为开发人员提供了快速构建分布式系统中一些常见模式的工具(例如配置管理,服务发现,断路器,智...
    卡卡罗2017阅读 135,010评论 19 139
  • 摘自: https://my.oschina.net/hosee/blog/711632摘要: 本文主要说明RPC...
    holy_z阅读 1,166评论 0 7
  • 嗯今天又是休息没上班,所以又是中午(准确的说是下午……才起床。吃饭的时候盘算的下午去哪里玩,想到之前列表一个妹子去...
    挹尘阅读 293评论 0 1
  • 寒风习习,落花依依。独自行走在田野间的小路,氤氲在心上的离愁,始终带着些许迷离,些许感伤。记忆中,往昔的片段,...
    苑尧阅读 288评论 0 6
  • 最近几个月没有正正经经的跑步了,原因身体不适,医生建议忌口、多休息、不要劳累,我也感觉有心而力不足。这不吃药...
    桔子pi阅读 407评论 0 0