BRPC 回调机制实现一次请求两次响应

在 BRPC 中，可以通过设置回调函数来实现一次 request，两次 response 的机制。

具体步骤如下：

客户端发送请求时，在 request 中设置一个 callback 函数，用于接收服务端的第一次 response。
服务端在处理请求的过程中，可以在任何时刻调用 response() 函数，向客户端发送第一次 response。这个 response 将会被客户端的 callback 函数接收到。
在服务端处理完请求后，再一次调用 response() 函数，向客户端发送第二次 response。这个 response 将会直接返回给客户端，而不需要通过 callback 函数来接收。

下面是一个简单的示例代码：

客户端：

void callback(brpc::Controller* cntl, MyResponse* response) {
    // 接收服务端的第一次 response
    std::cout << 'Received first response: ' << response->message() << std::endl;
}

int main() {
    // 创建一个 stub
    MyService_Stub stub(channel);

    // 创建一个 request
    MyRequest request;
    request.set_message('hello');

    // 设置 callback 函数
    brpc::Controller* cntl = new brpc::Controller();
    cntl->set_response_attachment(new MyResponse());
    cntl->set_callback(callback);

    // 发送请求
    stub.MyMethod(cntl, &request, cntl->response_attachment(), NULL);

    return 0;
}

服务端：

void MyServiceImpl::MyMethod(google::protobuf::RpcController* cntl_base,
                              const MyRequest* request,
                              MyResponse* response,
                              google::protobuf::Closure* done) {
    brpc::Controller* cntl = static_cast<brpc::Controller*>(cntl_base);

    // 处理请求
    std::string message = request->message();
    std::cout << 'Received message: ' << message << std::endl;

    // 发送第一次 response
    response->set_message('first response');
    cntl->response_attachment().reset(response);
    cntl->response_attachment().detach();

    // 处理完请求后，发送第二次 response
    response->set_message('second response');
    cntl->response_attachment().reset(response);
    cntl->response_attachment().detach();
}

在这个示例中，客户端发送了一个请求，并设置了一个 callback 函数来接收服务端的第一次 response。当服务端处理完请求后，先通过 response() 函数发送了第一次 response，这个 response 将会被客户端的 callback 函数接收到。然后再一次调用 response() 函数，发送第二次 response，这个 response 将会直接返回给客户端。