點對點消息隊列函數:用于WinCE的IPC機制
本文說明點對點消息隊列 — 一個鮮為人知的 IPC 機制,它高效、靈活,并且專用于 Windows CE 4.0 及其更高版本。此外,本文還說明如何設計和使用托管包裝,使 .NET Compact Framework 應用程序中的 IPC 極其簡便。
開發人員能夠以多種方式使用點對點消息隊列。開發人員通常在無法宿主 .NET Compact Framework 運行庫的情況下使用 IPC 作為替代方案(本機進程通過 IPC 與托管進程進行通訊),并且點對點消息隊列是***選擇。點對點消息隊列還可以與操作系統進行交互,例如,用于獲取電源信息。本文不介紹點對點消息隊列的其他用途,這些用途留待您了解核心原理之后自行探究。
本部分以一個您易于了解的方式描述點對點消息隊列函數。
當開發人員使用 IPC 時,一個進程創建用于寫入的隊列,另一個進程創建用于讀取的隊列 (CreateMsgQueue)。在雙向 IPC 通訊中,開發人員在通訊的每一端(在兩個獨立的進程間或同一進程的兩個對象間)都需要兩個隊列。
在使用點對點消息隊列時,開發人員可以采用若干種方法。例如,有用于讀取 (ReadMsgQueue)、寫入 (WriteMsgQueue) 和關閉隊列 (CloseMsgQueue) 的方法。此外,如果除了隊列句柄之外,開發人員還具有擁有該隊列的源進程的句柄,那么他們就可以打開現有隊列 (OpenMsgQueue)。開發人員可以查詢一些統計信息 (GetMsgQueueInfo),***可以使他們的應用程序等待隊列句柄 (WaitForSingleObject) 接收信號,以便確定隊列中是否有數據。
打開一個現有隊列時,開發人員只能指定一個選項 — 該隊列是用于讀還是用于寫。當創建隊列時,開發人員可以指定其他參數:名稱 (lpszName) 和選項(類型為 MSGQUEUOPTIONS 的 lpOptions)。隊列選項包括以下內容:單個消息的***大小 (cbMaxMessage)、隊列中消息的隨機***數量 (dwMaxMessages)、是否應該動態分配緩沖區(dwFlags、MSGQUEUE_NOPRECOMMIT),以及閱讀器是否可以在沒有編寫器的情況下存在(dwFlags、MSGQUEUE_ALLOW_BROKEN),反之亦然。關閉隊列時,開發人員將句柄作為參數 ( hMsgQ )。
寫入隊列需要一個指針 ( lpBuffer )、消息中的字節數 ( cbDataSize )、超時 ( dwTimeout ),以及該消息是否是一個警告消息( dwFlags 、MSGQUEUE_MSGALERT)。從隊列讀取需要:傳入一個緩沖區 (lpBuffer)、緩沖區的大小 ( cbBufferSize ),以及一個超時值 ( dwTimeout );因此,可獲悉實際字節數 ( lpNumberOfBytesRead ) 以及該消息是否為一個警告( pdwFlags 、MSGQUEUE_MSGALERT)。注意,超時是以毫秒計算的;0 表示“不阻塞”,而 INFINITE (-1) 表示“阻塞,直到操作完成或隊列狀態更改”。如果成功,讀函數和寫函數都返回 TRUE;否則,返回 FALSE。在后一種情況中,您可以獲得擴展的錯誤信息 (GetLastError)。函數返回 FALSE 的可能原因有:緩沖區太小 (ERROR_INSUFFICIENT_BUFFER);沒有編寫器或閱讀器,且開發人員未按前面段落中所述的那樣指定 MSGQUEUE_ALLOW_BROKEN (ERROR_PIPE_NOT_CONNECTED);或者發生超時 (ERROR_TIMEOUT)。對于 WriteMsgQueue,如果未按前面段落中所述的那樣指定 MSGQUEUE_NOPRECOMMIT,則也可能得到錯誤 ERROR_OUTOFMEMORY。
可調用 GetMsgQueueInfo 來獲得包含統計信息的結構 (MSGQUEUEINFO)。該結構包含的信息包括開發人員在創建隊列時傳入的一些參數:消息的***大小 (cbMaxMessage)、消息的***數量 (dwMaxMessages)、是否應該動態分配緩沖區(dwFlags、MSGQUEUE_NOPRECOMMIT),以及閱讀器是否可以在沒有編寫器的情況下存在(dwFlags、MSGQUEUE_ALLOW_BROKEN),反之亦然。此外,該結構還包含以下內容:當前隊列中非警告信息的數量 (dwCurrentMessages)、隊列中曾經存在消息的***數量 (dwMaxQueueMessages)、當前閱讀器的數量 (wNumReaders),以及當前編寫器的數量 (wNumWriters)。
【編輯推薦】