c++如何使用gRPC构建微服务_c++高性能RPC框架实战

老浩大大_3448

发布时间：2025-12-01 10:45:08

952人浏览过

来源于php中文网

原创

gRPC是C++构建高性能微服务的优选方案，基于HTTP/2协议并结合Protocol Buffers实现高效序列化；1. 定义.proto文件描述服务接口，使用protoc生成C++桩代码；2. 服务端继承生成的Service类实现RPC方法，并通过ServerBuilder启动监听；3. 客户端创建Channel和Stub调用远程方法；4. 生产环境中应采用异步API、TLS加密、连接复用、超时控制及拦截器监控以优化性能与可靠性。

c++如何使用grpc构建微服务_c++高性能rpc框架实战

使用C++构建微服务时，gRPC是一个高性能、低延迟的远程过程调用（RPC）框架，特别适合对性能要求较高的场景。它基于HTTP/2协议，支持双向流、头部压缩和多语言互通，配合Protocol Buffers（protobuf）实现高效的数据序列化。下面介绍如何在C++中实战使用gRPC搭建微服务。

定义服务接口（.proto文件）

gRPC的核心是通过.proto文件定义服务接口和消息结构。你需要先安装protobuf编译器（protoc）和gRPC插件。

例如，创建一个名为helloworld.proto的文件：

syntax = "proto3";
<p>package helloworld;</p><p><span>立即学习</span>“<a href="https://pan.quark.cn/s/6e7abc4abb9f" style="text-decoration: underline !important; color: blue; font-weight: bolder;" rel="nofollow" target="_blank">C++免费学习笔记（深入）</a>”；</p><p>// 定义一个简单的问候服务
service Greeter {
rpc SayHello (HelloRequest) returns (HelloReply);
}</p><p>// 请求消息
message HelloRequest {
string name = 1;
}</p><p>// 响应消息
message HelloReply {
string message = 1;
}

使用以下命令生成C++代码：

protoc --grpc_out=. --cpp_out=. \
  --plugin=protoc-gen-grpc=`which grpc_cpp_plugin` helloworld.proto

这会生成四个文件：helloworld.pb.cc、helloworld.pb.h、helloworld.grpc.pb.cc、helloworld.grpc.pb.h，分别对应protobuf消息和gRPC桩代码。

实现服务端逻辑

服务端需要继承生成的Greeter::Service类，并实现SayHello方法。

C++ 算法竞赛自动化测试数据生成与校验框架

根据原题生成新题面、验证器及完整测试数据，自动套用 testlib 模板，用于用户要求生成测试数据时。

下载

示例代码：

#include <grpcpp/grpcpp>
#include "helloworld.grpc.pb.h"
<p>class GreeterServiceImpl final : public helloworld::Greeter::Service {
grpc::Status SayHello(grpc::ServerContext<em> context,
const helloworld::HelloRequest</em> request,
helloworld::HelloReply* reply) override {
std::string prefix("Hello, ");
reply->set_message(prefix + request->name());
return grpc::Status::OK;
}
};

启动gRPC服务器：

void RunServer() {
  std::string server_address("0.0.0.0:50051");
  GreeterServiceImpl service;
<p>grpc::ServerBuilder builder;
builder.AddListeningPort(server_address, grpc::InsecureServerCredentials());
builder.RegisterService(&service);
std::unique_ptr<grpc::Server> server(builder.BuildAndStart());
std::cout << "Server listening on " << server_address << std::endl;</p><p>server->Wait(); // 阻塞等待
}

编译时需链接gRPC库，如使用CMake：

find_package(gRPC REQUIRED)
target_link_libraries(your_server ${gRPC_LIBRARIES})

编写客户端调用代码

客户端通过存根（stub）调用远程服务。

#include <grpcpp/grpcpp>
#include "helloworld.grpc.pb.h"
<p>class GreeterClient {
public:
GreeterClient(std::shared<em>ptr<grpc::Channel> channel)
: stub</em>(helloworld::Greeter::NewStub(channel)) {}</p><p>std::string SayHello(const std::string& user) {
helloworld::HelloRequest request;
request.set_name(user);</p><pre class="brush:php;toolbar:false;">helloworld::HelloReply reply;
grpc::ClientContext context;
grpc::Status status = stub_->SayHello(&context, request, &reply);

if (status.ok()) {
  return reply.message();
} else {
  return "RPC failed";
}

}

private: std::uniqueptr<:greeter::stub> stub; };

主函数中调用：

int main() {
  GreeterClient client(grpc::CreateChannel(
      "localhost:50051", grpc::InsecureChannelCredentials()));
  std::string response = client.SayHello("World");
  std::cout << "Response: " << response << std::endl;
  return 0;
}