分布式 RPC 系统 minirpc

• 授权协议: GPL
• 开发语言: C/C++
• 操作系统: Linux
• 软件首页: https://github.com/gityf/minirpc
• 软件文档: https://github.com/gityf/minirpc

软件介绍

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软件。

本文地址：https://codercto.com/soft/d/3357.html