欢迎来到尧图网

客户服务 关于我们

您的位置：首页 > 房产 > 家装 > [C++][第三方库][brpc]详细讲解

[C++][第三方库][brpc]详细讲解

2025/3/13 7:35:07 来源：https://blog.csdn.net/qq_37281656/article/details/142690660  浏览:  次   关键词：[C++][第三方库][brpc]详细讲解

目录

  • 1.介绍
  • 2.安装
  • 3.类与接口介绍
    • 1.日志输出类与接口
    • 2.ProtoBuf类与接口
    • 3.服务端类与接口
    • 4.客户端类与接口
  • 4.使用
    • 0.一般流程
    • 1.Server
    • 2.客户端 -- 同步调用
    • 3.客户端 -- 异步调用

1.介绍

  • brpc是用C++编写的工业级RPC框架，常用于搜索、存储、机器学习、广告、推荐等高性能系统
  • 具体理解：RPC是远程调用框架
    • 以前都是将数据的处理过程直接在本地封装实现，进行调用完成功能
    • RPC框架远程调用的思想不一样，是将数据处理的过程交给服务器来执行
  • 使用场景：
    • 搭建能在一个端口支持多协议的服务，或访问各种服务
    • Server能同步或异步处理请求
    • Client支持同步、异步、半同步，或使用组合channels简化复杂的分库或并发访问
    • 通过http界面调试服务，使用cpu, heap, contention profilers
    • 获得更好的延时和吞吐
    • 把组织中使用的协议快速地加入brpc，或定制各类组件，包括命名服务(dns, zk, etcd)，负载均衡(rr, random, consistent hashing)
  • 对比其他RPC框架：
    • grpc：
      • 开发者：Google
      • 语言支持：C++、Java、Python、Go
      • 序列化：PB
      • 文档：较为完善，没有中文文档
      • 编译问题：主要是需要下载submodule问题
      • 服务端推送：不支持
      • 异步调用：
        • 异步客户端需要用户自己创建消费线程，使用起来较为麻烦
        • 支持异步服务器
      • 流式传输(大块数据传输)：支持，接口简单易用
      • 易用性：
        • 简单易用
        • 支持跨语言，跨平台
    • brpc：
      • 开发者：baidu
      • 语言支持：C++
      • 序列化：PB
      • 文档：较为完善，有中文文档
      • 编译问题：基本没有问题
      • 服务端推送：支持，但支持的不好，是通过一次长的RPC调用实现的
      • 异步调用：通过回调函数支持客户端异步调用
      • 流式传输(大块数据传输)：支持，接口稍微比较原生
      • 易用性：
        • 提供简洁的API和友好的使用文档，易于上手
        • 在sofa-prpc基础上加了一些封装，比如资源管理等，更易用
    • srpc：
      • 开发者：sogou
      • 语言支持：C++
      • 序列化：PB、Thift
      • 文档：文档略显简略，没有独立网站，都托管在Github
      • 编译问题：基本没有问题
      • 服务端推送：不支持
      • 异步调用：
        • 支持异步客户端
        • 通过workflow支持异步服务器
      • 流式传输(大块数据传输)：不支持
      • 易用性：专注于异步编程，性能较高，用起来更复杂一些
    • sofa-pbrpc：
      • 开发者：baidu
      • 语言支持：C++、Java
      • 序列化：PB
      • 文档：官方文档较少
      • 编译问题：编译存在问题，依赖的库版本都比较老
      • 服务端推送：不支持
      • 异步调用：通过回调函数支持客户端异步调用
      • 流式传输(大块数据传输)：不支持
      • 易用性：
        • 轻量化
        • 接口简单，容易使用

2.安装

  • 依赖安装：
    sudo apt-get install -y libssl-dev libprotobuf-dev libprotoc-dev protobuf-compiler libleveldb-dev
  • 安装brpc：
    git clone https://github.com/apache/brpc.git
cd brpc/
mkdir build && cd build
cmake DCMAKE_INSTALL_PREFIX=/usr .. && cmake --build . -j6
make && sudo make install

3.类与接口介绍

1.日志输出类与接口

  • 包含头文件#include <butil/logging.h>
  • 日志输出这里，本质上用不着brpc的日志输出，因此这里主要介绍如何关闭日志输出
    namespace logging 
{ enum LoggingDestination { LOG_TO_NONE = 0 };struct BUTIL_EXPORT LoggingSettings { LoggingSettings(); LoggingDestination logging_dest; }; bool InitLogging(const LoggingSettings& settings); 
}

2.ProtoBuf类与接口

  • RpcController：上下文管理类，目前主要用于判断RPC请求是否是OK的
  • Closure：
    • 客户端：主要用于设置异步处理回调
    • 服务端：通过Run()宣告请求处理完毕
namespace google 
{ namespace protobuf { class PROTOBUF_EXPORT Closure { public: Closure() {} virtual ~Closure(); virtual void Run() = 0; };inline Closure* NewCallback(void (*function)()); class PROTOBUF_EXPORT RpcController { bool Failed(); std::string ErrorText() ; } } 
}

3.服务端类与接口

  • 此处只介绍主要用到的成员与接口
  • Server：服务器类
  • ServerOptions：服务器参数配置类
  • ClosureGuard：Closure对象的智能管理类
  • Controller：管理RPC调用的上下文和状态
    • 它提供了一些方法和属性来控制和检查RPC调用的状态、错误信息、超时设置
namespace brpc 
{ struct ServerOptions { //无数据传输，则指定时间后关闭连接 int idle_timeout_sec; // Default: -1 (disabled) int num_threads; // Default: #cpu-cores //.... }enum ServiceOwnership { //添加服务失败时，服务器将负责删除服务对象 SERVER_OWNS_SERVICE, //添加服务失败时，服务器也不会删除服务对象 SERVER_DOESNT_OWN_SERVICE };class Server { int AddService(google::protobuf::Service* service, ServiceOwnership ownership); int Start(int port, const ServerOptions* opt); int Stop(int closewait_ms/*not used anymore*/); int Join(); //休眠直到ctrl+c按下，或者stop和join服务器 void RunUntilAskedToQuit(); };class ClosureGuard { explicit ClosureGuard(google::protobuf::Closure* done); ~ClosureGuard() { if (_done) _done->Run(); } };class HttpHeader { void set_content_type(const std::string& type) const std::string* GetHeader(const std::string& key) void SetHeader(const std::string& key,  const std::string& value); const URI& uri() const { return _uri; } HttpMethod method() const { return _method; } void set_method(const HttpMethod method) int status_code() void set_status_code(int status_code); };class Controller : public google::protobuf::RpcController { void set_timeout_ms(int64_t timeout_ms); void set_max_retry(int max_retry); google::protobuf::Message* response(); HttpHeader& http_response(); HttpHeader& http_request(); bool Failed(); std::string ErrorText(); using AfterRpcRespFnType = std::function< void(Controller* cntl, const google::protobuf::Message* req, const google::protobuf::Message* res)>; void set_after_rpc_resp_fn(AfterRpcRespFnType&& fn) };
}

4.客户端类与接口

  • Channel：客户端与服务器网络通信信道类
  • ChannelOptions：信道配置类
namespace brpc 
{ struct ChannelOptions { //请求连接超时时间 int32_t connect_timeout_ms;// Default: 200 (milliseconds) //rpc请求超时时间 int32_t timeout_ms;// Default: 500 (milliseconds) //最大重试次数 int max_retry;// Default: 3 //序列化协议类型  options.protocol = "baidu_std"; AdaptiveProtocolType protocol; //.... };class Channel : public ChannelBase { //初始化接口，成功返回0； int Init(const char* server_addr_and_port, const ChannelOptions* options); };
}

4.使用

0.一般流程

  • 服务端：
    • 创建RPC服务子类继承PB中的EchoService服务类，并实现内部的业务接口逻辑
    • 创建RPC服务器对象，搭建服务器
    • 向服务器类中添加RPC子服务对象，告诉服务器收到什么请求用哪个接口处理
    • 启动服务器
  • 客户端：
    • 创建网络通信信道
    • 实例化PB中的EchoService_Stub类对象
    • 发起RPC请i去，获取响应进行处理
  • makefile：
    all: server client_sync client_asyncserver: server.cc main.pb.ccg++ -o $@ $^ -std=c++17 -lbrpc -lgflags -lssl -lcrypto -lprotobuf -lleveldbclient_sync: client_sync.cc main.pb.ccg++ -o $@ $^ -std=c++17 -lbrpc -lgflags -lssl -lcrypto -lprotobuf -lleveldbclient_async: client.async.cc main.pb.ccg++ -o $@ $^ -std=c++17 -lbrpc -lgflags -lssl -lcrypto -lprotobuf -lleveldb.PHONY:clean
clean:rm server client_sync  client_async

1.Server

#include <brpc/server.h>
#include <butil/logging.h>
#include "main.pb.h"// 继承于EchoService, 创建一个子类, 并实现RPC调用的业务功能
class EchoServiceImpl : public SnowK::EchoService
{
public:EchoServiceImpl(){}~EchoServiceImpl(){}void Echo(google::protobuf::RpcController *controller,const ::SnowK::EchoRequest *request,::SnowK::EchoResponse *response,::google::protobuf::Closure *done){brpc::ClosureGuard rpc_guard(done);std::cout << "收到消息: " << request->message() << std::endl;std::string str = request->message() + "--响应";response->set_message(str);// done->Run(); // 已经有了ClosureGuard, 则不再需要}
};int main(int argc, char* argv[])
{// 0.关闭brpc的默认日志输出logging::LoggingSettings settings;settings.logging_dest = logging::LoggingDestination::LOG_TO_NONE;logging::InitLogging(settings);// 1.构造服务器对象brpc::Server server;// 2.向服务器对象中，新增EchoService服务EchoServiceImpl echo_service;if (server.AddService(&echo_service, brpc::ServiceOwnership::SERVER_DOESNT_OWN_SERVICE) == -1){std::cout << "添加Rpc服务失败!" << std::endl;return -1;}// 3.启动服务器brpc::ServerOptions options;options.idle_timeout_sec = -1; // 连接空闲超时时间, 超时后连接被关闭options.num_threads = 1; // IO线程数量if(server.Start(3366, &options) == -1){std::cout << "启动服务器失败" << std::endl;return -1;}server.RunUntilAskedToQuit(); // 修改等待运行结束return 0;
}

2.客户端 – 同步调用

  • 同步调用：客户端会阻塞收到server端的响应或发生错误
    #include <brpc/channel.h>
#include "main.pb.h"int main(int argc, char* argv[])
{// 1.构造Channel信道, 连接服务器brpc::ChannelOptions options;options.connect_timeout_ms = -1; // 连接等待超时时间, -1表示一直等待options.timeout_ms = -1; // RPC请求等待超时时间, -1表示一直等待options.max_retry = 3; // 请求重试次数options.protocol = "baidu_std"; // 序列化协议, 默认使用baidu_stdbrpc::Channel channel;if(channel.Init("127.0.0.1:3366", &options) == -1){std::cout << "初始化信道失败" << std::endl;return -1;}// 2.构建EchoService_Stub对象, 用于进行RPC调用SnowK::EchoService_Stub stub(&channel);// 3.进行RPC调用SnowK::EchoRequest req;req.set_message("Hello SnowK");brpc::Controller *cntl = new brpc::Controller();SnowK::EchoResponse *resp = new SnowK::EchoResponse();stub.Echo(cntl, &req, resp, nullptr); // nullptr为同步调用if(cntl->Failed()){std::cout << "RPC调用失败" << cntl->ErrorText() << std::endl;return -1;}std::cout << "收到响应: " << resp->message() << std::endl;delete cntl;delete resp;return 0;
}

3.客户端 – 异步调用

  • 异步调用：指客户端注册一个响应处理回调函数， 当调用一个RPC接口时立即返回， 不会阻塞等待响应， 当Server端返回响应时会调用传入的回调函数处理响应
  • 具体做法：
    • 给CallMethod传递一个额外的回调对象done，CallMethod在发出request后就结束了，而不是在RPC结束后
    • 当server端返回response或发生错误(包括超时)时，done->Run()会被调用
      • 对RPC的后续处理应该写在done->Run()里，而不是CallMethod后
    • 由于CallMethod结束不意味着RPC结束，response/controller仍可能被框架及done->Run()使用，它们一般得创建在堆上， 并在done->Run()中删除
      • 如果提前删除了它们，那当done->Run()被调用时，将访问到无效内存
    #include <thread>
#include <brpc/channel.h>
#include "main.pb.h"void Callback(brpc::Controller* cntl, SnowK::EchoResponse* resp)
{std::shared_ptr<brpc::Controller> cntl_guard(cntl);std::shared_ptr<SnowK::EchoResponse> resp_guard(resp);if (cntl->Failed()){std::cout << "RPC调用失败" << cntl->ErrorText() << std::endl;return;}std::cout << "收到响应: " << resp->message() << std::endl;
}int main(int argc, char *argv[])
{// 1.构造Channel信道, 连接服务器brpc::ChannelOptions options;options.connect_timeout_ms = -1; // 连接等待超时时间, -1表示一直等待options.timeout_ms = -1;         // RPC请求等待超时时间, -1表示一直等待options.max_retry = 3;           // 请求重试次数options.protocol = "baidu_std";  // 序列化协议, 默认使用baidu_stdbrpc::Channel channel;if (channel.Init("127.0.0.1:3366", &options) == -1){std::cout << "初始化信道失败" << std::endl;return -1;}// 2.构建EchoService_Stub对象, 用于进行RPC调用SnowK::EchoService_Stub stub(&channel);// 3.进行RPC调用SnowK::EchoRequest req;req.set_message("Hello SnowK");brpc::Controller *cntl = new brpc::Controller();SnowK::EchoResponse *resp = new SnowK::EchoResponse();auto closure = google::protobuf::NewCallback(Callback, cntl, resp);stub.Echo(cntl, &req, resp, closure); // 异步调用std::cout << "异步调用结束" << std::endl;std::this_thread::sleep_for(std::chrono::seconds(3));return 0;
}

版权声明:

本网仅为发布的内容提供存储空间，不对发表、转载的内容提供任何形式的保证。凡本网注明“来源：XXX网络”的作品，均转载自其它媒体，著作权归作者所有，商业转载请联系作者获得授权，非商业转载请注明出处。

我们尊重并感谢每一位作者，均已注明文章来源和作者。如因作品内容、版权或其它问题，请及时与我们联系，联系邮箱：809451989@qq.com，投稿邮箱：809451989@qq.com

相关资讯

热文排行

最新新闻

推荐新闻

热搜词