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