Win32 RPC 編程(三)

Win32 RPC 編程(三) 示例下載

咱們在上一節的基礎上，討論如何實現異步的 RPC 調用。前兩節演示的函數調用都是同步的，即調用函數 Hello() 時，客戶端將阻塞住直到服務端的 Hello() 函數返回。若是服務端函數須要進行一些費時的操做，例如複雜的計算、查詢，客戶端只能一直阻塞在那裏。這種狀況下，咱們能夠使用異步的 RPC 提升客戶端的性能。

異步的RPC是經過配置文件（.acf）來啓用的：

 

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

服務端的代碼 server.c 中的 Hello() 要改爲下面的樣子：

 Cpp代碼

void Hello(PRPC_ASYNC_STATE rpcAsyncHandle, const unsigned char * psz)
{
    // 模擬一個長時間的操做
    printf("Sleep 5 seconds...\n");
    Sleep(5000);
    printf("%s\n", psz);
    // 代表調用已經完成

    RpcAsyncCompleteCall(rpcAsyncHandle, NULL);
}

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中的調用方式也要換：

 Cpp代碼

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


        // 後面都相同
        ...
}

 

Hello.acf:
[
    implicit_handle(handle_t HelloWorld_Binding)
]

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

Hello.acf:
[  
	implicit_handle(handle_t HelloWorld_Binding)  
]  

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