主流的RPC框架

「爱情、让人受尽委屈。」 2022-05-11 00:04 217阅读 0赞

来源：[https://zhidao.baidu.com/question/982666371522897459.html][https_zhidao.baidu.com_question_982666371522897459.html]

RPC是远程过程调用的简称，广泛应用在大规模分布式应用中，作用是有助于系统的垂直拆分，使系统更易拓展。Java中的RPC框架比较多，各有特色，广泛使用的有RMI、Hessian、Dubbo等。RPC还有一个特点就是能够跨语言。

1、RMI（远程方法调用）

JAVA自带的远程方法调用工具，不过有一定的局限性，毕竟是JAVA语言最开始时的设计，后来很多框架的原理都基于RMI，RMI的使用如下：

对外接口

<table> 
 <tbody> 
 <tr> 
 <td> 1 2 3 4 5 </td> 
 <td> <code>&lt;span&nbsp;style=</code><code>"font-size:12px;"</code><code>&gt;public&nbsp;interface&nbsp;IService&nbsp;extends&nbsp;Remote&nbsp;{&nbsp;&nbsp;</code> <code>&nbsp;&nbsp;</code>&nbsp; <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>public&nbsp;String&nbsp;queryName(String&nbsp;no)&nbsp;throws&nbsp;RemoteException;&nbsp;&nbsp;</code> <code>&nbsp;&nbsp;</code>&nbsp; <code>}&lt;/span&gt;</code> </td> 
 </tr> 
 </tbody> 
</table>

服务实现

<table> 
 <tbody> 
 <tr> 
 <td> 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 </td> 
 <td> <code>import</code>&nbsp;<code>java.rmi.RemoteException;&nbsp;&nbsp;</code> <code>import</code>&nbsp;<code>java.rmi.server.UnicastRemoteObject;&nbsp;&nbsp;</code> <code>&nbsp;&nbsp;</code>&nbsp; <code>//&nbsp;服务实现&nbsp;&nbsp;</code> <code>public</code>&nbsp;<code>class</code>&nbsp;<code>ServiceImpl&nbsp;</code><code>extends</code>&nbsp;<code>UnicastRemoteObject&nbsp;</code><code>implements</code>&nbsp;<code>IService&nbsp;{&nbsp;&nbsp;</code> <code>&nbsp;&nbsp;</code>&nbsp; <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>/**&nbsp;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>*/</code>&nbsp;&nbsp; <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>private</code>&nbsp;<code>static</code>&nbsp;<code>final</code>&nbsp;<code>long</code>&nbsp;<code>serialVersionUID&nbsp;=&nbsp;682805210518738166L;&nbsp;&nbsp;</code> <code>&nbsp;&nbsp;</code>&nbsp; <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>/**&nbsp;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>*&nbsp;@throws&nbsp;RemoteException&nbsp;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>*/</code>&nbsp;&nbsp; <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>protected</code>&nbsp;<code>ServiceImpl()&nbsp;</code><code>throws</code>&nbsp;<code>RemoteException&nbsp;{&nbsp;&nbsp;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>super</code><code>();&nbsp;&nbsp;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>}&nbsp;&nbsp;</code> <code>&nbsp;&nbsp;</code>&nbsp; <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>/*&nbsp;(non-Javadoc)&nbsp;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>*&nbsp;@see&nbsp;com.suning.ebuy.wd.web.IService#queryName(java.lang.String)&nbsp;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>*/</code>&nbsp;&nbsp; <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>@Override</code>&nbsp;&nbsp; <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>public</code>&nbsp;<code>String&nbsp;queryName(String&nbsp;no)&nbsp;</code><code>throws</code>&nbsp;<code>RemoteException&nbsp;{&nbsp;&nbsp;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>//&nbsp;方法的具体实现&nbsp;&nbsp;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>System.out.println(</code><code>"hello"</code>&nbsp;<code>+&nbsp;no);&nbsp;&nbsp;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>return</code>&nbsp;<code>String.valueOf(System.currentTimeMillis());&nbsp;&nbsp;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>}&nbsp;&nbsp;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code>&nbsp; <code>}&nbsp;&nbsp;</code> <code>RMI客户端</code> &nbsp; <code>[java]&nbsp;view&nbsp;plain&nbsp;copy</code> <code>import</code>&nbsp;<code>java.rmi.AccessException;&nbsp;&nbsp;</code> <code>import</code>&nbsp;<code>java.rmi.NotBoundException;&nbsp;&nbsp;</code> <code>import</code>&nbsp;<code>java.rmi.RemoteException;&nbsp;&nbsp;</code> <code>import</code>&nbsp;<code>java.rmi.registry.LocateRegistry;&nbsp;&nbsp;</code> <code>import</code>&nbsp;<code>java.rmi.registry.Registry;&nbsp;&nbsp;</code> <code>&nbsp;&nbsp;</code>&nbsp; <code>//&nbsp;RMI客户端&nbsp;&nbsp;</code> <code>public</code>&nbsp;<code>class</code>&nbsp;<code>Client&nbsp;{&nbsp;&nbsp;</code> <code>&nbsp;&nbsp;</code>&nbsp; <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>public</code>&nbsp;<code>static</code>&nbsp;<code>void</code>&nbsp;<code>main(String[]&nbsp;args)&nbsp;{&nbsp;&nbsp;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>//&nbsp;注册管理器&nbsp;&nbsp;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>Registry&nbsp;registry&nbsp;=&nbsp;</code><code>null</code><code>;&nbsp;&nbsp;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>try</code>&nbsp;<code>{&nbsp;&nbsp;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>//&nbsp;获取服务注册管理器&nbsp;&nbsp;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>registry&nbsp;=&nbsp;LocateRegistry.getRegistry(</code><code>"127.0.0.1"</code><code>,</code><code>8088</code><code>);&nbsp;&nbsp;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>//&nbsp;列出所有注册的服务&nbsp;&nbsp;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>String[]&nbsp;list&nbsp;=&nbsp;registry.list();&nbsp;&nbsp;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>for</code><code>(String&nbsp;s&nbsp;:&nbsp;list){&nbsp;&nbsp;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>System.out.println(s);&nbsp;&nbsp;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>}&nbsp;&nbsp;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>}&nbsp;</code><code>catch</code>&nbsp;<code>(RemoteException&nbsp;e)&nbsp;{&nbsp;&nbsp;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code>&nbsp; <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>}&nbsp;&nbsp;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>try</code>&nbsp;<code>{&nbsp;&nbsp;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>//&nbsp;根据命名获取服务&nbsp;&nbsp;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>IService&nbsp;server&nbsp;=&nbsp;(IService)&nbsp;registry.lookup(</code><code>"vince"</code><code>);&nbsp;&nbsp;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>//&nbsp;调用远程方法&nbsp;&nbsp;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>String&nbsp;result&nbsp;=&nbsp;server.queryName(</code><code>"ha&nbsp;ha&nbsp;ha&nbsp;ha"</code><code>);&nbsp;&nbsp;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>//&nbsp;输出调用结果&nbsp;&nbsp;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>System.out.println(</code><code>"result&nbsp;from&nbsp;remote&nbsp;:&nbsp;"</code>&nbsp;<code>+&nbsp;result);&nbsp;&nbsp;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>}&nbsp;</code><code>catch</code>&nbsp;<code>(AccessException&nbsp;e)&nbsp;{&nbsp;&nbsp;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code>&nbsp; <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>}&nbsp;</code><code>catch</code>&nbsp;<code>(RemoteException&nbsp;e)&nbsp;{&nbsp;&nbsp;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code>&nbsp; <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>}&nbsp;</code><code>catch</code>&nbsp;<code>(NotBoundException&nbsp;e)&nbsp;{&nbsp;&nbsp;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code>&nbsp; <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>}&nbsp;&nbsp;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>}&nbsp;&nbsp;</code> <code>}&nbsp;&nbsp;</code> <code>RMI服务端</code> &nbsp; <code>[java]&nbsp;view&nbsp;plain&nbsp;copy</code> <code>import</code>&nbsp;<code>java.rmi.RemoteException;&nbsp;&nbsp;</code> <code>import</code>&nbsp;<code>java.rmi.registry.LocateRegistry;&nbsp;&nbsp;</code> <code>import</code>&nbsp;<code>java.rmi.registry.Registry;&nbsp;&nbsp;</code> <code>&nbsp;&nbsp;</code>&nbsp; <code>//&nbsp;RMI服务端&nbsp;&nbsp;</code> <code>public</code>&nbsp;<code>class</code>&nbsp;<code>Server&nbsp;{&nbsp;&nbsp;</code> <code>&nbsp;&nbsp;</code>&nbsp; <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>public</code>&nbsp;<code>static</code>&nbsp;<code>void</code>&nbsp;<code>main(String[]&nbsp;args)&nbsp;{&nbsp;&nbsp;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>//&nbsp;注册管理器&nbsp;&nbsp;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>Registry&nbsp;registry&nbsp;=&nbsp;</code><code>null</code><code>;&nbsp;&nbsp;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>try</code>&nbsp;<code>{&nbsp;&nbsp;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>//&nbsp;创建一个服务注册管理器&nbsp;&nbsp;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>registry&nbsp;=&nbsp;LocateRegistry.createRegistry(</code><code>8088</code><code>);&nbsp;&nbsp;</code> <code>&nbsp;&nbsp;</code>&nbsp; <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>}&nbsp;</code><code>catch</code>&nbsp;<code>(RemoteException&nbsp;e)&nbsp;{&nbsp;&nbsp;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code>&nbsp; <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>}&nbsp;&nbsp;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>try</code>&nbsp;<code>{&nbsp;&nbsp;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>//&nbsp;创建一个服务&nbsp;&nbsp;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>ServiceImpl&nbsp;server&nbsp;=&nbsp;</code><code>new</code>&nbsp;<code>ServiceImpl();&nbsp;&nbsp;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>//&nbsp;将服务绑定命名&nbsp;&nbsp;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>registry.rebind(</code><code>"vince"</code><code>,&nbsp;server);&nbsp;&nbsp;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code>&nbsp; <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>System.out.println(</code><code>"bind&nbsp;server"</code><code>);&nbsp;&nbsp;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>}&nbsp;</code><code>catch</code>&nbsp;<code>(RemoteException&nbsp;e)&nbsp;{&nbsp;&nbsp;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code>&nbsp; <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>}&nbsp;&nbsp;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>}&nbsp;&nbsp;</code> <code>}</code> </td> 
 </tr> 
 </tbody> 
</table>

2、Hessian（基于HTTP的远程方法调用）

基于HTTP协议传输，在性能方面还不够完美，负载均衡和失效转移依赖于应用的负载均衡器，Hessian的使用则与RMI类似，区别在于淡化了Registry的角色，通过显示的地址调用，利用HessianProxyFactory根据配置的地址create一个代理对象，另外还要引入Hessian的Jar包。

[![6609c93d70cf3bc7caa89975db00baa1cc112afa.jpg][]][6609c93d70cf3bc7caa89975db00baa1cc112afa.jpg 1]

3、Dubbo（淘宝开源的基于TCP的RPC框架）

基于Netty的高性能RPC框架，是阿里巴巴开源的，总体原理如下：

[![c2fdfc039245d688b7c6e63daec27d1ed31b2466.jpg][]][c2fdfc039245d688b7c6e63daec27d1ed31b2466.jpg 1]

![70][]

book 开源的一个 RPC 框架，现在已经挂在 apache.org 下了。主要的几个好处：  
1. 支持非常多语言，包括在 WEB 开发中很常用的 PHP，以及最重要的 C++/Python/Java 等 WEB后端常用语言，当然，还包括很 cool 的 Ruby、Erlang。  
2. 完整的 RPC 框架实现，用脚本生成通讯相关的框架代码，开发者只需要集中精力处理好 [业务逻辑][Link 1]。比如搭建一个 Hello World Service 只需要几分钟。  
3.拥有被 Facebook、[Last.fm][] 等不少大规模互联网应用验证过的性能和可用性。  
  
Hessian是一款基于HTTP协议的RPC框架，采用的是二进制[RPC协议][RPC]，非常轻量级 ，且速度较快。  
  
当然，还有Hetty，它是一款构建于Netty和Hessian基础上的高性能的RPC框架。

[https_zhidao.baidu.com_question_982666371522897459.html]: https://zhidao.baidu.com/question/982666371522897459.html
[6609c93d70cf3bc7caa89975db00baa1cc112afa.jpg]: /images/20220511/c61722e40ffd44ee86594053ef7f2a5f.png
[6609c93d70cf3bc7caa89975db00baa1cc112afa.jpg 1]: https://gss0.baidu.com/-vo3dSag_xI4khGko9WTAnF6hhy/zhidao/pic/item/6609c93d70cf3bc7caa89975db00baa1cc112afa.jpg
[c2fdfc039245d688b7c6e63daec27d1ed31b2466.jpg]: /images/20220511/81471e03b9454cf9b36e2781eec7df9c.png
[c2fdfc039245d688b7c6e63daec27d1ed31b2466.jpg 1]: https://gss0.baidu.com/-Po3dSag_xI4khGko9WTAnF6hhy/zhidao/pic/item/c2fdfc039245d688b7c6e63daec27d1ed31b2466.jpg
[70]: /images/20220511/21aac82d68834c25b15cf53d1bd0e0ff.png
[Link 1]: https://www.baidu.com/s?wd=%E4%B8%9A%E5%8A%A1%E9%80%BB%E8%BE%91&tn=SE_PcZhidaonwhc_ngpagmjz&rsv_dl=gh_pc_zhidao
[Last.fm]: https://www.baidu.com/s?wd=Last.fm&tn=SE_PcZhidaonwhc_ngpagmjz&rsv_dl=gh_pc_zhidao
[RPC]: https://www.baidu.com/s?wd=RPC%E5%8D%8F%E8%AE%AE&tn=SE_PcZhidaonwhc_ngpagmjz&rsv_dl=gh_pc_zhidao