| 注册
请输入搜索内容

热门搜索

Java Linux MySQL PHP JavaScript Hibernate jQuery Nginx
jopen
9年前发布

Java轻量级分布式RPC框架:lindzh RPC

轻量级分部署服务调度框架的基本原理是服务提供方Provider提供rpc服务,同时把ip和端口以及发布的rpc服务注册到注册中心,客户端或者 rpc消费者从注册中心获取服务Provider列表,同时获取Provider提供的服务列表。另外客户端还会监听注册中心的数据变化,获知 server宕机或者服务不可用,将该Provider从客户端Provider缓存列表中剔除,方便做容错和负载均衡。

基本原理

Alt text

特性

一、  负载均衡  提供基于RoundRobin和随机方式的负载均衡  二、  高可用  Consumer会从注册中心获取到服务列表及该服务的提供者列表,如果某个提供者Provider网络异常或者宕机,  Consumer能马上感知到,加入不可用列表,如果从注册中心收到服务不可用会剔除缓存,不可用列表会重新尝试发起  连接,如果网络正常了会立即恢复。  三、  泛型  一般的rpc调用需要拿到服务提供方的业务api(interface class,入参class,返回值class打包到一个jar中,  依赖该jar),如果使用泛型,只需要填写interface的name,版本,方法名称,参数名称,参数值,如果是对象,  将对象字段封装到一个Map中即可,无需依赖任何业务jar即可完成rpc调用。  四、  Rpc上下文附件  Rpc调用方可以将需要传递的上下文信息填写到上下文中,而不是作为rpc的入参,这样Provider可以从上下文中获取  到掉用方的上下文信息。  五、  高可用注册中心  Rpc 框架提供了zookeeper,etcd,redis pubsub(支持单个,或者sentinel集群模式)的注册中心,具备高可  用功能。  六、  实时动态监控  Provider提供了监控的api,监控可以使用该api加入到项目或者公司的监控平台。  七、  内存使用少  Rpc使用的内存模型是tcp连接建立后自动分配一块内存,读和写都在该内存中,不需要为每次请求分配内存,同一个  tcp内存复用,数据使用了压缩的方式保存和发送,不支持返回数据量超大的调用(压缩后超过1m)。

整体架构

Alt text

泛型:GenericService,Consumer不依赖Provider的api jar包即可完成remote api调用  监控:StatMonitor,consumer注册需要的远程服务StatMonitor,调用rpc获取监控数据  Webui:一个可视化rpc管理界面,https://github.com/lindzh/rpc-webui  RPC调用:使用jdk proxy封装发送tcp数据,并等待数据返回,完成RPC调用。  负载均衡:在集群模式下,同一个版本的Rpc服务在多台服务器上部署,Consumer发起rpc调用使用负载均衡。  自动容错:发现rpc provider不可用及时剔除,当可用时加入。  代理:rpcClient注册一个remote intface时会返回一个代理。  多注册中心:提供Zookeeper,etcd,redis等注册中心,并可以实现高可用。

使用

Provider

SimpleRpcServer rpcServer = new SimpleRpcServer();  rpcServer.setHost("192.168.132.87");  rpcServer.setPort(4321);  //将一个service暴露为rpc服务  rpcServer.register(LoginRpcService.class, new LoginRpcServiceImpl());  rpcServer.startService();  // Thread.currentThread().sleep(100000);//wait for call  rpcServer.stopService();

Consumer

SimpleRpcClient rpcClient = new SimpleRpcClient();  rpcClient.setHost("192.168.132.87");  rpcClient.setPort(4321);  LoginRpcService loginRpcService = rpcClient.register(LoginRpcService.class);  rpcClient.startService();  boolean loginResult = loginRpcService.login("admin", "admin");  rpcClient.stopService();
https://github.com/lindzh/rpc

 本文由用户 jopen 自行上传分享,仅供网友学习交流。所有权归原作者,若您的权利被侵害,请联系管理员。
 转载本站原创文章,请注明出处,并保留原始链接、图片水印。
 本站是一个以用户分享为主的开源技术平台,欢迎各类分享!
 本文地址:https://www.open-open.com/lib/view/open1442242432587.html
WEB服务/RPC/SOA lindzh RPC