gRPC 是基于 HTTP/2 和 Protobuf 的高性能 RPC 框架,支持多语言,适用于低延迟、高吞吐的微服务通信。通过定义 .proto 文件声明服务接口和消息格式,使用 protoc 生成 C++ 代码,包含消息类和服务桩。服务端继承生成的服务类并实现 RPC 方法,如 SayHello 返回 “Hello, [name]”,并通过 ServerBuilder 启动监听。客户端使用存根(Stub)调用远程方法,通过 Channel 连接服务并处理响应。借助 CMake 配置编译,链接 gRPC 和 Protobuf 库,实现高效通信。关键在于掌握接口定义、代码生成与异步模型,适合性能敏感场景。

在现代分布式系统中,微服务之间需要高效、可靠的通信机制。gRPC 是 Google 开发的一个高性能、开源的远程过程调用(RPC)框架,支持多种语言,包括 C++。它基于 HTTP/2 协议,使用 Protocol Buffers(Protobuf)作为接口定义语言和数据序列化工具,非常适合构建低延迟、高吞吐量的服务间通信。
定义服务接口(.proto 文件)
使用 gRPC 的第一步是定义服务接口和消息格式。你需要编写一个 .proto 文件来声明服务方法和传输的数据结构。
例如,创建一个 helloworld.proto 文件:
syntax = "proto3";package helloworld;
立即学习“C++免费学习笔记(深入)”;
// 定义一个问候服务 service Greeter { rpc SayHello (HelloRequest) returns (HelloReply); }
// 请求消息 message HelloRequest { string name = 1; }
// 响应消息 message HelloReply { string message = 1; }
这个文件定义了一个名为 Greeter 的服务,包含一个方法 SayHello,接收一个字符串参数并返回一条消息。
生成 C++ 代码
使用 Protobuf 编译器 protoc 和 gRPC 插件生成 C++ 代码。
安装依赖后,运行以下命令:
protoc --grpc_out=. --plugin=protoc-gen-grpc=`which grpc_cpp_plugin` helloworld.proto protoc --cpp_out=. helloworld.proto
这将生成四个文件:
- helloworld.pb.h 和 helloworld.pb.cc:由 Protobuf 生成的消息类。
- helloworld.grpc.pb.h 和 helloworld.grpc.pb.cc:gRPC 生成的服务基类和桩代码。
实现服务端逻辑
继承生成的服务类,重写 RPC 方法。
示例服务实现:
#include#include "helloworld.grpc.pb.h" using grpc::Server; using grpc::ServerBuilder; using grpc::Status; using helloworld::HelloRequest; using helloworld::HelloReply; using helloworld::Greeter;
class GreeterServiceImpl final : public Greeter::Service { Status SayHello(ServerContext context, const HelloRequest request, HelloReply* reply) override { std::string prefix("Hello, "); reply->set_message(prefix + request->name()); return Status::OK; } };
void RunServer() { std::string server_address("0.0.0.0:50051"); GreeterServiceImpl service;
ServerBuilder builder; builder.AddListeningPort(server_address, grpc::InsecureServerCredentials()); builder.RegisterService(&service); std::unique_ptr
server(builder.BuildAndStart()); std::cout << "Server listening on " << server_address << std::endl; server->Wait(); }
该服务监听 50051 端口,收到请求时返回 “Hello, [name]”。
编写客户端调用
客户端通过存根(stub)调用远程服务。
#include#include "helloworld.grpc.pb.h" using grpc::Channel; using grpc::ClientContext; using grpc::Status; using helloworld::HelloRequest; using helloworld::HelloReply; using helloworld::Greeter;
class GreeterClient { public: GreeterClient(std::sharedptr
channel) : stub (Greeter::NewStub(channel)) {}std::string SayHello(const std::string& user) { HelloRequest request; request.set_name(user);
HelloReply reply; ClientContext context; Status status = stub_->SayHello(&context, request, &reply); if (status.ok()) { return reply.message(); } else { std::cout << "RPC failed: " << status.error_code() << ": " << status.error_message() << std::endl; return "RPC failed"; }}
private: std::uniqueptr<:stub> stub; };
int main(int argc, char** argv) { GreeterClient client(grpc::CreateChannel( "localhost:50051", grpc::InsecureChannelCredentials())); std::string user("world"); std::string reply = client.SayHello(user); std::cout
客户端连接本地服务,发送用户名并打印响应。
编译与链接
CMakeLists.txt 示例:
cmake_minimum_required(VERSION 3.14) project(helloworld)find_package(Protobuf REQUIRED) find_package(gRPC REQUIRED)
set(CMAKE_CXX_STANDARD 17)
add_executable(greeter_server server.cc helloworld.pb.cc helloworld.grpc.pb.cc) add_executable(greeter_client client.cc helloworld.pb.cc helloworld.grpc.pb.cc)
target_link_libraries(greeter_server ${gRPC_LIBRARIES} ${PROTOBUF_LIBRARIES}) target_link_libraries(greeter_client ${gRPC_LIBRARIES} ${PROTOBUF_LIBRARIES}) target_include_directories(greeter_server PRIVATE ${gRPC_INCLUDE_DIRS} ${PROTOBUF_INCLUDE_DIRS}) target_include_directories(greeter_client PRIVATE ${gRPC_INCLUDE_DIRS} ${PROTOBUF_INCLUDE_DIRS})
确保正确链接 gRPC 和 Protobuf 库。
基本上就这些。C++ 结合 gRPC 可以实现高效的微服务通信,特别适合对性能要求高的场景。只要定义好接口,生成代码,再实现服务逻辑,就能快速搭建出稳定、高速的 RPC 服务。关键在于熟悉 .proto 定义和异步调用模型,后续可进一步探索流式 RPC 和认证机制。不复杂但容易忽略细节,比如版本兼容和线程安全。











