rpc demo-Go服务器开发

以下是一个简单的RPC（远程过程调用）示例，使用C++和gRPC库。

首先，你需要安装 gRPC 和 Protocol Buffers。可以从 gRPC 的官方网站（https://grpc.io/）下载并按照指南进行安装。
创建一个 .proto 文件来定义你的服务接口。例如，创建一个名为 demo.proto 的文件，并添加以下内容：

syntax = "proto3";

package demo;

service Calculator {
  rpc Add(AddRequest) returns (AddResponse) {}
}

message AddRequest {
  int32 num1 = 1;
  int32 num2 = 2;
}

message AddResponse {
  int32 result = 1;
}

使用 Protocol Buffers 编译器生成 C++ 代码。在终端中运行以下命令：

protoc -I=. --cpp_out=. --grpc_out=. --plugin=protoc-gen-grpc=`which grpc_cpp_plugin` demo.proto

这将生成 demo.pb.h 和 demo.pb.cc 文件。

创建一个服务器实现你的服务接口。创建一个名为 server.cpp 的文件，并添加以下内容：

#include <iostream>
#include <memory>
#include <string>

#include <grpcpp/grpcpp.h>

#include "demo.grpc.pb.h"

using grpc::Server;
using grpc::ServerBuilder;
using grpc::ServerContext;
using grpc::Status;
using demo::AddRequest;
using demo::AddResponse;
using demo::Calculator;

class CalculatorImpl final : public Calculator::Service {
public:
    Status Add(ServerContext* context, const AddRequest* request,
               AddResponse* response) override
    {
        int result = request->num1() + request->num2();
        response->set_result(result);
        return Status::OK;
    }
};

void RunServer() {
  std::string server_address("0.0.0.0:50051");
  CalculatorImpl service;

  ServerBuilder builder;
  builder.AddListeningPort(server_address, grpc::InsecureServerCredentials());
  builder.RegisterService(&service);

  std::unique_ptr<Server> server(builder.BuildAndStart());
  std::cout << "Server listening on " << server_address << std::endl;

  server->Wait();
}

int main(int argc, char** argv) {
  RunServer();

  return 0;
}

这将创建一个简单的 CalculatorImpl 类来实现 Add 方法。

创建一个客户端调用你的服务。创建一个名为 client.cpp 的文件，并添加以下内容：

#include <iostream>
#include <memory>
#include <string>

#include <grpcpp/grpcpp.h>

#include "demo.grpc.pb.h"

using grpc::Channel;
using grpc::ClientContext;
using grpc::Status;
using demo::AddRequest;
using demo::AddResponse;
using demo::Calculator;

class CalculatorClient {
public:
    CalculatorClient(std::shared_ptr<Channel> channel)
        : stub_(Calculator::NewStub(channel)) {}

    int Add(int num1, int num2) {
        AddRequest request;
        request.set_num1(num1);
        request.set_num2(num2);

        AddResponse response;

        ClientContext context;

        Status status = stub_->Add(&context, request, &response);

        if (status.ok()) {
            return response.result();
        } else {
            std::cout << "RPC failed." << std::endl;
            return -1;
        }
    }

private:
    std::unique_ptr<Calculator::Stub> stub_;
};

int main(int argc, char** argv) {
  CalculatorClient client(grpc::CreateChannel("localhost:50051",
                                              grpc::InsecureChannelCredentials()));
  int result = client.Add(3, 5);
  std::cout << "Result: " << result << std::endl;

  return 0;
}

这将创建一个 CalculatorClient 类来连接到服务器并调用 Add 方法。

使用以下命令编译服务器和客户端代码：

g++ -std=c++11 -o server server.cpp demo.pb.cc demo.grpc.pb.cc `pkg-config --cflags --libs grpc`
g++ -std=c++11 -o client client.cpp demo.pb.cc demo.grpc.pb.cc `pkg-config --cflags --libs grpc`