使用brpc库。不用原生的。-Go服务器开发

使用brpc库进行序列化和反序列化的步骤如下：

定义数据结构：在C++中，定义需要传输的数据结构，可以使用Protobuf来定义消息格式。

syntax = "proto3";
message Person {
    string name = 1;
    int32 age = 2;
}

生成代码：使用Protobuf编译器将Proto文件转换为相应的C++代码。假设生成的代码文件为example.pb.h和example.pb.cc。

protoc -I=./ --cpp_out=./ example.proto

编写服务器端代码：

#include <iostream>
#include <string>
#include "brpc/server.h"
#include "example.pb.h"
using example::Person;
// 实现服务接口
class MyService : public example::MyService {
public:
    void GetPerson(::google::protobuf::RpcController* controller,
                   const ::example::GetPersonRequest* request,
                   ::example::GetPersonResponse* response,
                   ::google::protobuf::Closure* done) override {
        Person person;
        person.set_name("Alice");
        person.set_age(25);
        response->mutable_person()->CopyFrom(person);
        done->Run();
    }
};
int main() {
    brpc::Server server;
    // 添加服务并注册回调函数
    MyService myService;
    if (server.AddService(&myService, brpc::SERVER_DOESNT_OWN_SERVICE) != 0) {
        std::cerr << "Fail to add service" << std::endl;
        return -1;
    }
    // 设置监听地址和端口
    brpc::ServerOptions options;
    if (server.Start("0.0.0.0:50051", &options) != 0) {
        std::cerr << "Fail to start server" << std::endl;
        return -1;
    }
    // 运行服务器
    server.RunUntilAskedToQuit();
    return 0;
}

编写客户端代码：

#include <iostream>
#include <string>
#include "brpc/channel.h"
#include "example.pb.h"
int main() {
    brpc::Channel channel;
    // 初始化channel
    if (channel.Init("127.0.0.1:50051", nullptr) != 0) {
        std::cerr << "Fail to initialize channel" << std::endl;
        return -1;
    }
    // 创建请求和响应对象
    example::GetPersonRequest request;
    example::GetPersonResponse response;
    // 发起远程调用
    brpc::Controller cntl;  // 控制器用于管理调用过程中的错误信息等
    example::MyService_Stub stub(&channel);
    
	// 设置请求参数，这里不需要传递任何参数
	// 调用远程函数并等待返回结果
	stub.GetPerson(&cntl, &request, &response, nullptr);
	// 检查调用是否成功，并处理响应结果
	if (cntl.Failed()) {
	    std::cerr << "RPC failed: " << cntl.ErrorText() << std::endl;
	} else {
	    const Person& person = response.person();
	    std::cout << "Name: " << person.name() << std::endl;
	    std::cout << "Age: " << person.age() << std::endl;
	}
	return 0;
}