轻量级分布式RPC框架 lindzh RPC

• 授权协议: MIT
• 开发语言: Java
• 操作系统: 跨平台
• 软件首页: https://github.com/lindzh/rpc
• 软件文档: https://github.com/lindzh/rpc/blob/master/doc/rpc-doc.pdf

软件介绍

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

基本原理

特性

一、  负载均衡
提供基于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）。

整体架构

泛型：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://www.codercto.com/soft/d/3351.html