Normandy 博客

我們在上一節的基礎上，討論如何實現異步的 RPC 調用。前兩節演示的函數調用都是同步的，即調用函數 Hello() 時，
客戶端將阻塞住直到服務端的 Hello() 函數返回。如果服務端函數需要進行一些費時的操作，例如復雜的計算、查詢，
客戶端只能一直阻塞在那里。這種情況下，我們可以使用異步的 RPC 提高客戶端的性能。

異步的RPC是通過配置文件（.acf）來啟用的：
--------------------------------------------
Hello.acf:

[  
       implicit_handle(handle_t HelloWorld_Binding)  
]  

interface  HelloWorld
{
       [async] Hello();  // 增加了 [async] 表明這是異步調用
}

 
原來的接口 HelloWorld 有兩個方法，Hello() 和 Shutdown()，Shutdown() 我們仍然讓它是同步調用，所以在.acf文
件中不用列出。IDL 接口文件還是可以不用修改。


服務端的代碼 server.c 中的 Hello() 要改成下面的樣子：
------------------------------------------------------
void Hello(PRPC_ASYNC_STATE rpcAsyncHandle, const unsigned char * psz)
{
     // 模擬一個長時間的操作
     printf("Sleep 5 seconds...\n");
     Sleep(5000);
 

     printf("%s\n", psz);
     // 表明調用已經完成

     RpcAsyncCompleteCall(rpcAsyncHandle, NULL);
}

服務端的其它代碼不用修改。
 

客戶端client.c中的調用方式也要換：
---------------------------------
int main(int argc, char * argv[])
{
     // 前面都相同
     ...
   
     // 下面是調用服務端的函數
     RpcTryExcept
     {

         if ( _stricmp(argv[1], "SHUTDOWN") == 0 )
         {
              Shutdown();
         }
         else
         {
              // 初始化異步調用
              RPC_ASYNC_STATE async;
              RpcAsyncInitializeHandle( &async, sizeof(async) );
              async.UserInfo = NULL;
              async.NotificationType = RpcNotificationTypeNone;

              // 本函數能立即返回
              Hello( &async, (unsigned char*)argv[1]);

              // 查詢調用的狀態
              while ( RpcAsyncGetCallStatus(&async) == RPC_S_ASYNC_CALL_PENDING )
              {
                   printf("Call Hello() pending, wait 1s...\n");
                   Sleep(1000);
              }

              // 通知調用已經完成
              RpcAsyncCompleteCall( &async, NULL );
         }
     }
     RpcExcept(1)
     {
         printf( "RPC Exception %d\n", RpcExceptionCode() );
     }
     RpcEndExcept

   
     // 后面都相同
     ...
}

這樣客戶端就實現了異步調用!

示例下載