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实现数据传输和业务处理。
5. rpc server单进程每秒处理142000个请求包(intel i5 cpu),可以参考统计页面的Package TPS显示。
------------------------------------------------------------------
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 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软件。