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.protoprotoc --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 <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;};
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 和认证机制。不复杂但容易忽略细节,比如版本兼容和线程安全。
以上就是C++如何使用gRPC进行微服务通信_C++实现高性能的远程过程调用(RPC)框架的详细内容,更多请关注创想鸟其它相关文章!
版权声明:本文内容由互联网用户自发贡献,该文观点仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。
如发现本站有涉嫌抄袭侵权/违法违规的内容, 请发送邮件至 chuangxiangniao@163.com 举报,一经查实,本站将立刻删除。
发布者:程序猿,转转请注明出处:https://www.chuangxiangniao.com/p/1487508.html
微信扫一扫
支付宝扫一扫