brpc建立一次会话处理多次request和responde代码示例

以下是一个使用brpc建立一次会话，处理多次request和response的代码示例：

#include <iostream>
#include <brpc/server.h>
#include <brpc/channel.h>

// 定义自定义的服务类
class MyService : public example::EchoService {
public:
    // 实现Echo接口的方法
    void Echo(::google::protobuf::RpcController* cntl_base,
              const ::example::EchoRequest* request,
              ::example::EchoResponse* response,
              ::google::protobuf::Closure* done) override {
        // 强制转换RpcController为brpc::Controller
        brpc::Controller* cntl =
                static_cast<brpc::Controller*>(cntl_base);

        // 输出请求消息
        std::cout << "Received request: " << request->message() << std::endl;

        // 设置响应消息
        response->set_message("Hello, " + request->message());

        // 完成处理
        done->Run();
    }
};

int main() {
    // 初始化brpc
    brpc::Server server;

    // 添加自定义的服务
    MyService service;

    // 注册服务到服务器
    if (server.AddService(&service,
                          brpc::SERVER_DOESNT_OWN_SERVICE) != 0) {
        std::cerr << "Fail to add service" << std::endl;
        return -1;
    }

    // 启动服务器
    brpc::ServerOptions options;
    if (server.Start(9000, &options) != 0) {
        std::cerr << "Fail to start server" << std::endl;
        return -1;
    }

    // 创建一个channel与服务器建立连接
    brpc::Channel channel;
    if (channel.Init("127.0.0.1:9000", NULL) != 0) {
        std::cerr << "Fail to initialize channel" << std::endl;
        return -1;
    }

    // 创建一个stub用于调用远程服务
    example::EchoService_Stub stub(&channel);

    // 创建一个请求和响应对象
    example::EchoRequest request;
    example::EchoResponse response;

    // 发送多个请求并接收响应
    for (int i = 0; i < 5; ++i) {
        // 设置请求消息
        request.set_message("World " + std::to_string(i));

        // 发起远程调用
        brpc::Controller cntl;
        stub.Echo(&cntl, &request, &response, NULL);

        // 检查远程调用是否成功
        if (cntl.Failed()) {
            std::cerr << "Fail to send request: " << cntl.ErrorText() << std::endl;
            return -1;
        }

        // 输出响应消息
        std::cout << "Received response: " << response.message() << std::endl;
    }

    // 停止服务器
    server.Stop(0);

    return 0;
}

在上面的示例中，我们首先定义了一个自定义的服务类MyService，它继承自brpc自动生成的服务类example::EchoService，并重写了Echo方法来实现自定义的逻辑。然后我们创建了一个brpc的服务器server，添加了我们的自定义服务，并启动了服务器。

接着，我们创建了一个brpc的通道channel，用于与服务器建立连接。然后创建了一个服务stubstub，用于调用远程服务。接下来，我们循环发送多个请求并接收响应。每次循环中，我们设置请求消息，创建一个brpc::Controller对象用于控制远程调用，调用stub.Echo方法发起远程调用，并检查调用是否成功。最后，我们输出响应消息。

在循环结束后，我们停止了服务器