亚洲伊人久久综合影院,色综合久久无码五十路人妻,潮喷大喷水系列无码久久精品

gRPC異步處理應(yīng)答

gRPC異步處理應(yīng)答

(金慶的專欄)

gRPC的示例 greeter_async_client.cc 不算是異步客戶端，
它使用了異步請(qǐng)求，但是阻塞式等待應(yīng)答，結(jié)果成為一個(gè)同步調(diào)用。

std::string SayHello(const std::string& user) {
    ...
    std::unique_ptr<ClientAsyncResponseReader<HelloReply> > rpc(
        stub_->AsyncSayHello(&context, request, &cq));
    rpc->Finish(&reply, &status, (void*)1);
    void* got_tag;
    bool ok = false;
    // Block until the next result is available in the completion queue "cq".
    cq.Next(&got_tag, &ok);

    ...
    return reply.message();
}

為了實(shí)現(xiàn)真正的異步RPC請(qǐng)求，發(fā)出請(qǐng)求后立即返回，然后在一個(gè)線程中處理所有應(yīng)答。
以下代碼經(jīng)測(cè)試表明可以使用。

// Grpc異步應(yīng)答處理，線程中運(yùn)行.
void HandleGrpcResponses()
{
    ...
   grpc::CompletionQueue & rCq = rMgr.GetCq();
   for (;;)
   {
       void * pTag;
       bool ok = false;
       // Block until the next result is available in the completion queue "cq".
       rCq.Next(&pTag, &ok);

       // Act upon the status of the actual RPC.
       std::unique_ptr<IGrpcCb> pCb(static_cast<IGrpcCb*>(pTag));
       const grpc::Status & rStatus = pCb->GetStatus();
       if (rStatus.ok())
           (*pCb)(); // run callback
   }
}

IGrpcCb是回調(diào)類，定義如下：

class IGrpcCb
{
public:
   explicit IGrpcCb(...) {};
   virtual ~IGrpcCb(void) {};

   grpc::ClientContext & GetContext() { return m_context; }
   grpc::Status & GetStatus() { return m_status; }

public:
   virtual void operator()() {};

protected:
   grpc::ClientContext m_context;
   grpc::Status m_status;
    ...
};

// R is response class like rpc::CreateRoomResponse.
template <class R>
class GrpcCb final : public IGrpcCb
{
public:
   explicit GrpcCb(...)
       : IGrpcCb(...)
       {};
   virtual ~GrpcCb(void) override {};

public:
   typedef std::unique_ptr<grpc::ClientAsyncResponseReader<R> > RpcPtr;

public:
   R & GetResp() { return m_resp; }
   void SetRpcPtrAndFinish(RpcPtr pRpc)
   {
       m_pRpc.swap(pRpc);
       m_pRpc->Finish(&m_resp, &m_status, (void*)this);
   }

public:
   virtual void operator()() override
   {
       // Deal m_resp...
   }

private:
   RpcPtr m_pRpc;
   R m_resp;
};

異步請(qǐng)求代碼示例如下：

        grpc::CompletionQueue & cq = GetCq();
       rpc::CreateRoomRequest req;

       // pGcb will be deleted in HandleGrpcResponses().
       auto pGcb = new GrpcCb<rpc::CreateRoomResponse>(...);
       pGcb->SetRpcPtrAndFinish(
           m_pStub->AsyncCreateRoom(&pGcb->GetContext(), req, &cq));

posted on 2016-01-15 14:46 金慶閱讀(1618) 評(píng)論(0) 編輯收藏引用所屬分類: 1. C/C++

只有注冊(cè)用戶登錄后才能發(fā)表評(píng)論。
【推薦】100%開源！大型工業(yè)跨平臺(tái)軟件C++源碼提供，建模，組態(tài)！

相關(guān)文章: How are dtLinks created in NavMesh C++ parameter passing rules Naming Conventions for Accessors Visual Studio 2019 Compiler Hangs Fbx File Format Identifier 查找內(nèi)存錯(cuò)誤 std::thread 中的異常會(huì)丟失調(diào)用棧用賦值代替 protobuf CopyFrom() vs2017 linux 編譯輸出改成 vs 格式為 LiteIDE 添加選中標(biāo)記

網(wǎng)站導(dǎo)航: 博客園 IT新聞 BlogJava 博問 Chat2DB 管理

金慶的專欄

公告

留言簿(12)

隨筆分類(502)

隨筆檔案(423)

相冊(cè)

搜索

積分與排名

最新評(píng)論

閱讀排行榜

評(píng)論排行榜