分布式 RPC 系统:minirpc

xf3f 5年前

minirpc 是基于 protobuf 的分布式 RPC 系统。

1. rpc server端提供的service可以是so库文件方式存在,可以使用libloader工具增加到server上。
2. rpc server会将自己所提供的服务注册到agent上。
3. agent服务中心采用去中心化的方式运行,通过加入组播实现rpc server的服务列表管理和运行状态的准实时展现。
4. rpc client可以使用需要调用的server名称(字符串服务名),向agent中心获取提供此类服务的rpc server,之后连接rpc server实现数据传输和业务处理。

------------------------------------------------------------------

rpc 具体业务实现lib库编写方式:

#include "rpc_serverobserver.h"  #include "echo.pb.h"  #include "common/clogwriter.h"  #include <unistd.h>  extern "C" {      int echo_Init(CRpcSerObserver* aRpcServer);  }  class LibEchoServiceImpl : public echo::EchoService {      virtual void Echo(::google::protobuf::RpcController* controller,                        const ::echo::EchoRequest* request,                        ::echo::EchoResponse* response,                        ::google::protobuf::Closure* done) {          response->set_response(request->message()+" lib_rpc_server_echo_hello");          if (done) {              done->Run();          }      }      virtual void Dummy(::google::protobuf::RpcController* controller,                         const ::echo::DummyRequest* request,                         ::echo::DummyResponse* response,                         ::google::protobuf::Closure* done) {          if (done) {              done->Run();          }      }  };  int echo_Init(CRpcSerObserver* aRpcServer) {      DEBUG(LL_WARN, "echo_Init Begin.");      RPCREGI(aRpcServer, LibEchoServiceImpl);      return 0;  }

------------------------------------------------------------------

agent启动方式:

cd agent

[w@localhost agent]$./miniagent -d

打开agent的运行页面观察运行状态,默认端口是15218.

http://serverip:15218

分布式 RPC 系统:minirpc

rpc server启动方式:

[w@localhost protobuf]$ ./rpc_server_basic  -p 9987 -s ECHO -d
[w@localhost protobuf]$ ./rpc_server_basic  -p 9988 -s ECHO1 -d      
[w@localhost protobuf]$ ./rpc_server_basic  -h
=====================================
  使用方法: RpcServer [参数选项][-c 配置文件]
  参数选项描述:
  -p 监听端口 程序启动时绑定的监听端口。
  -s 服务名称 程序启动时提供的服务名称。
  -c 配置文件。
  -d 后台运行  守护进程方式运行。
  -l 日志级别  日志级别见如下描述:
               1. 错误日志;
               2. 警告日志;
               3. 通知日志;
               4. 重要的提示性日志;
               5. 打印关键变量的值;
               6. 开发人员的调试日志;
               7. 打开所有的日志。
  -v           输出版本信息。
  -h           输出运行帮助信息。
  启动实例:   RpcServer  -p 9090 -c RpcServer.ini -l 2 -d
=====================================

运行动态库加载工具,向服务BasicServer增加libecho.so提供的服务。

[w@localhost protobuf]$ ./rpc_libloader BasicServer load libecho.so

create success
load resp: libecho.so load success, method list:  echo.EchoService.Echo echo.EchoService.Dummy
load requ: libecho.so
load success
[w@localhost protobuf]$ ./rpc_libloader BasicServer load libecho2.so
create success
load resp: libecho2.so load success, method list:  echo2.EchoService.Echo echo2.EchoService.Dummy

参考:
代码中你会看到一些类似的开源代码。本项目中的一些代码来自如下开源软件。
haproxy
cxxtools
thrift
protobuf
kamailio
sems
fastrpc
redis
putty等。

谢谢以上开源软件的开发者们。

请不要拍砖,如果你觉得不可使用,可以选择thrift等其他rpc软件。

分布式 RPC 系统:minirpc

分布式 RPC 系统:minirpc

项目主页:http://www.open-open.com/lib/view/home/1429882164760