C++ gRPC中同一二进制内能否在gRPC方法中调用其他服务方法？

完全可行。由于两个服务都在同一个二进制文件中实现，无需通过网络发起gRPC请求，直接调用服务实现类的方法即可完成内部逻辑复用，这种方式性能更高。

具体实现步骤 #

1. 实现两个服务的具体业务类

基于proto生成的代码，分别实现MyService和OtherService的服务类，通过依赖注入让MyServiceImpl持有OtherServiceImpl的实例引用：

#include "mypackage.grpc.pb.h"
#include <grpcpp/grpcpp.h>
#include <iostream>

// 实现OtherService的业务逻辑
class OtherServiceImpl final : public mypackage::OtherService::Service {
public:
    grpc::Status Bar(grpc::ServerContext* context, 
                     const google::protobuf::Empty* request, 
                     google::protobuf::Empty* response) override {
        // 这里编写Bar方法的具体业务逻辑
        std::cout << "Executing OtherService.Bar" << std::endl;
        return grpc::Status::OK;
    }
};

// 实现MyService的业务逻辑，依赖OtherServiceImpl
class MyServiceImpl final : public mypackage::MyService::Service {
private:
    OtherServiceImpl& other_service_; // 持有OtherService实例的引用
public:
    // 通过构造函数注入OtherService实例
    explicit MyServiceImpl(OtherServiceImpl& other_service) 
        : other_service_(other_service) {}

    grpc::Status Foo(grpc::ServerContext* context, 
                     const google::protobuf::Empty* request, 
                     google::protobuf::Empty* response) override {
        std::cout << "Executing MyService.Foo, calling OtherService.Bar internally" << std::endl;

        // 构造内部调用所需的参数和上下文
        google::protobuf::Empty internal_req;
        google::protobuf::Empty internal_resp;
        grpc::ServerContext internal_ctx;

        // 直接调用OtherService的Bar方法
        grpc::Status call_status = other_service_.Bar(&internal_ctx, &internal_req, &internal_resp);
        if (!call_status.ok()) {
            // 处理内部调用失败的情况，直接返回错误状态
            return call_status;
        }

        // 继续执行Foo方法自身的业务逻辑
        return grpc::Status::OK;
    }
};

2. 启动gRPC服务器并注册两个服务

在主函数中创建两个服务实例，将OtherServiceImpl注入MyServiceImpl，然后注册到gRPC服务器：

int main(int argc, char** argv) {
    const std::string server_addr = "0.0.0.0:50051";

    // 创建服务实例，确保OtherService实例生命周期覆盖MyService
    OtherServiceImpl other_service;
    MyServiceImpl my_service(other_service);

    grpc::ServerBuilder builder;
    builder.AddListeningPort(server_addr, grpc::InsecureServerCredentials());
    // 注册两个服务到服务器
    builder.RegisterService(&my_service);
    builder.RegisterService(&other_service);

    // 启动服务器
    std::unique_ptr<grpc::Server> server = builder.BuildAndStart();
    std::cout << "Server listening on " << server_addr << std::endl;

    // 阻塞等待服务器关闭
    server->Wait();

    return 0;
}

注意事项 #

• 生命周期管理：确保OtherServiceImpl的实例存活时间不短于MyServiceImpl，避免出现悬空引用。
• 上下文处理：内部调用使用的ServerContext可以独立创建，若需要传递外部请求的元数据（如追踪ID、认证信息），可从外部context中复制相关字段到内部上下文。
• 性能优势：这种本地调用无需网络开销，比跨进程/跨机器的gRPC调用效率高得多。

内容的提问来源于stack exchange，提问作者Osurac