从零构建 gRPC 跨语言通信：C++ 服务端与 C# 客户端实战

在 calculator_service.cpp 中填充具体业务：

#include "calculator_service.h"

Status CalculatorServiceImpl::Add(ServerContext* context, const CalculationRequest* request,
                                  CalculationResult* response) {
    double result = request->a() + request->b();
    response->set_result(result);
    return Status::OK;
}

Status CalculatorServiceImpl::Subtract(ServerContext* context, const CalculationRequest* request,
                                       CalculationResult* response) {
    double result = request->a() - request->b();
    response->set_result(result);
    return Status::OK;
}

主程序与编译

服务端入口 server.cpp 负责监听端口：

#include <iostream>
#include <memory>
#include <string>
#include <grpcpp/grpcpp.h>
#include "calculator_service.h"

using grpc::Server;
using grpc::ServerBuilder;
using grpc::InsecureServerCredentials;

void RunServer() {
    std::string server_address("0.0.0.0:50051");
    CalculatorServiceImpl service;
    ServerBuilder builder;
    builder.AddListeningPort(server_address, InsecureServerCredentials());
    builder.RegisterService(&service);
    std::unique_ptr<Server> server(builder.BuildAndStart());
    std::cout << "Server listening on " << server_address << std::endl;
    server->Wait();
}

int main() {
    RunServer();
    return 0;
}

使用 CMake 管理编译：

cmake_minimum_required(VERSION 3.10)
project(grpc_server)
set(CMAKE_CXX_STANDARD 17)
find_package(Protobuf REQUIRED)
find_package(gRPC REQUIRED)
add_executable(server server.cpp calculator_service.cpp sample_service.pb.cc sample_service.grpc.pb.cc)
target_link_libraries(server PRIVATE gRPC::grpc++ gRPC::grpc protobuf::libprotobuf)

编译命令：

mkdir build && cd build
cmake .. && make
./server

C# 客户端实现

项目初始化

创建控制台项目并引入依赖：

dotnet new console -n GrpcClient
cd GrpcClient
dotnet add package Grpc.Net.Client
dotnet add package Google.Protobuf
dotnet add package Grpc.Tools

将 sample_service.proto 复制到项目目录，并在 .csproj 中添加配置：

<ItemGroup>
  <Protobuf Include="sample_service.proto" GrpcServices="Client" />
</ItemGroup>

编写客户端代码

修改 Program.cs 发起调用：

using System;
using System.Threading.Tasks;
using Grpc.Net.Client;
using SampleService.Client;

class Program {
    static async Task Main(string[] args) {
        using var channel = GrpcChannel.ForAddress("http://localhost:50051");
        var client = new Calculator.CalculatorClient(channel);
        try {
            // 加法示例
            var addRequest = new CalculationRequest { A = 5, B = 3 };
            var addResult = await client.AddAsync(addRequest);
            Console.WriteLine($"5 + 3 = {addResult.Result}");

            // 减法示例
            var subRequest = new CalculationRequest { A = 10, B = 4 };
            var subResult = await client.SubtractAsync(subRequest);
            Console.WriteLine($"10 - 4 = {subResult.Result}");
        } catch (Grpc.Core.RpcException ex) {
            Console.WriteLine($"RPC failed: {ex.Status.Detail}");
        }
    }
}

运行客户端：

dotnet run

测试与验证

启动服务端后，它会监听 0.0.0.0:50051。切换到另一个终端运行 C# 客户端，若输出如下结果，说明通信正常：

5 + 3 = 8
10 - 4 = 6

常见问题解决

连接失败

• 地址检查：确认客户端配置的地址和端口与服务端监听的一致。
• 防火墙：检查是否拦截了 50051 端口，必要时临时关闭防火墙测试。
• 协议匹配：如果服务端使用 InsecureServerCredentials，客户端也需保持兼容，不要混用 HTTPS 配置。

序列化错误

• Proto 一致性：两端 .proto 文件必须完全一致，字段顺序或类型变更会导致解析失败。
• 重新生成：修改 proto 后务必清理旧生成的代码并重新编译。

性能优化

• 连接池：gRPC 默认复用通道，但在高并发场景下可考虑自定义连接管理。
• 参数调整：根据网络状况调整超时时间和最大消息大小限制。

总结

通过以上步骤，我们完成了 C++ 服务端与 C# 客户端的 gRPC 通信搭建。这个流程展示了 gRPC 的核心能力：强类型接口、双向流式通信及跨语言支持。在实际微服务架构中，你可以基于此模式扩展更复杂的业务逻辑，利用其高性能特性提升系统整体效率。