這部分基本和上一節(jié)一樣，不過上一節(jié)中 RPC 是通過 Named Pipe 調(diào)用的，這里我們?cè)僭囈幌?TCP 的方式。
代碼大部分都是相同的, IDL 接口不用變(無(wú)論是通過什么方式 RPC，接口都是與之無(wú)關(guān)的)。

服務(wù)端要換成 TCP 的方式：
---------------------------------
int main(int argc,char * argv[])
{
     // 用TCP 方式作為RPC 的通道。綁定端口13521。
     RpcServerUseProtseqEp(
         (unsigned char *)"ncacn_ip_tcp",
         RPC_C_PROTSEQ_MAX_REQS_DEFAULT,
         (unsigned char *)"13521",
         NULL);    

     // 注意：從Windows XP SP2 開始，增強(qiáng)了安全性的要求，如果用 RpcServerRegisterIf() 注冊(cè)
     // 接口，客戶端調(diào)用時(shí)會(huì)出現(xiàn) RpcExceptionCode() == 5，即Access Denied 的錯(cuò)誤. 因此，必
     // 須用 RpcServerRegisterIfEx 帶 RPC_IF_ALLOW_CALLBACKS_WITH_NO_AUTH 標(biāo)志允許客戶端直
     // 接調(diào)用。

     // RpcServerRegisterIf(HelloWorld_v1_0_s_ifspec, NULL, NULL);
     RpcServerRegisterIfEx(
         HelloWorld_v1_0_s_ifspec, // Interface to register.
         NULL,
         NULL, // Use the MIDL generated entry-point vector.
         RPC_IF_ALLOW_CALLBACKS_WITH_NO_AUTH,
         0,
         NULL);

       // 后面都相同
       ...

     return 0;
}

 
客戶端的調(diào)用方式也要換：
---------------------------------
int main(int argc, char * argv[])
{
     // 前面都相同
     ...
   
     // 用 TCP 方式作為 RPC 的通道。服務(wù)器端口 13521。第3個(gè)
     // 參數(shù) NetworkAddr 如果取 NULL，那么就是連接本機(jī)服務(wù),
     // 也可以取IP, 域名, servername 等
     RpcStringBindingCompose(
         NULL,
         (unsigned char*)"ncacn_ip_tcp",
         (unsigned char*)"localhost" /*NULL*/,
         (unsigned char*)"13521",
         NULL,
         &pszStringBinding
     );
   
     // 后面都相同
     ...
}

別的地方都是一樣的。
我們?cè)谏弦还?jié)的基礎(chǔ)上，討論如何實(shí)現(xiàn)異步的 RPC 調(diào)用。前兩節(jié)演示的函數(shù)調(diào)用都是同步的，即調(diào)用函數(shù) Hello() 時(shí)，
客戶端將阻塞住直到服務(wù)端的 Hello() 函數(shù)返回。如果服務(wù)端函數(shù)需要進(jìn)行一些費(fèi)時(shí)的操作，例如復(fù)雜的計(jì)算、查詢，
客戶端只能一直阻塞在那里。這種情況下，我們可以使用異步的 RPC 提高客戶端的性能。

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

[  
       implicit_handle(handle_t HelloWorld_Binding)  
]  

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

 
原來的接口 HelloWorld 有兩個(gè)方法，Hello() 和 Shutdown()，Shutdown() 我們?nèi)匀蛔屗峭秸{(diào)用，所以在.acf文
件中不用列出。IDL 接口文件還是可以不用修改。


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

     printf("%s/n", psz);
     // 表明調(diào)用已經(jīng)完成

     RpcAsyncCompleteCall(rpcAsyncHandle, NULL);
}

服務(wù)端的其它代碼不用修改。
 

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

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

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

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

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

   
     // 后面都相同
     ...
}

這樣客戶端就實(shí)現(xiàn)了異步調(diào)用!

Win32 RPC 編程(四)