学步园

     接着前面的文章《WINCE下进程间通信（一）》，现在介绍进程间通信的另一种方法。

 三、管道（消息队列）

       WINCE并不支持类似于PC机上匿名管道、命名管道的通信方式，但CE下提供了一种点对点消息队列的方法，其工作原理与管道非常类似：在通信的两端分别建立一个读队列和写队列，写进程往消息队列一端写入数据，读进程从消息队列另一端读取数据。

       消息队列相关的系统API主要有：CreateMsgQueue()、ReadMsgQueue()、WriteMsgQuue()和CloseMsgQueue()。为了方便消息队列的操作，封装了一个消息队列操作类，参考代码如下：

       头文件（CMsgQueue.h）/*******************************************************************<br /> filename: CMsgQueue.h<br /> purpose: 封装了WINCE下消息队列操作类<br /> author: firehood<br /> created: 2011.03.23<br /> ********************************************************************/<br /> #ifndef _MSG_QUEUE_H<br /> #define _MSG_QUEUE_H</p> <p>// 消息队列访问模式<br /> enum ACCESSMODE<br /> {<br /> ReadMode = 0,<br /> WriteMode<br /> };</p> <p>// 定义消息回调函数<br /> typedef BOOL (CALLBACK *MsgQueueCallBack)(PVOID pData, DWORD dwSize);</p> <p>class CMsgQueue<br /> {<br /> public:<br /> CMsgQueue();<br /> CMsgQueue(LPCWSTR lpQueueName,DWORD dwSize,ACCESSMODE accessMode);<br /> ~CMsgQueue();<br /> public:<br /> /**********************************************************************<br /> 函数名：Create<br /> 功能： 创建或打开消息队列<br /> 参数：<br /> [in]lpQueueName: 消息队列名称<br /> [in]dwSize: 每条消息的最大长度<br /> [in]accessMode 消息队列访问模式 ReadMode：只读 WriteMode：只写<br /> 返回值：<br /> 成功：TRUE 失败：FALSE<br /> **********************************************************************/<br /> BOOL Create(LPCWSTR lpQueueName,DWORD dwSize,ACCESSMODE accessMode);</p> <p> /**********************************************************************<br /> 函数名：Read<br /> 功能： 从消息队列中读取一条消息<br /> 参数：<br /> [out]lpBuffer: 存放读取的数据<br /> [in] dwSize: 读取数据的大小<br /> [out]lpNumberOfBytesRead 实际读取数据的大小<br /> [in] dwTimeout 读取超时时间(ms) 0 立即返回 INFINITE 永远等待直至消息队列中有数据<br /> 返回值：<br /> 成功：TRUE 失败：FALSE<br /> ***********************************************************************/<br /> BOOL Read(LPVOID lpBuffer,DWORD dwSize,LPDWORD lpNumberOfBytesRead,DWORD dwTimeout = 0);</p> <p> /**********************************************************************<br /> 函数名：Write<br /> 功能： 向消息队列中写入一条消息<br /> 参数：<br /> [in]lpBuffer: 待写入的数据<br /> [in]dwSize: 写入数据的大小<br /> 返回值：<br /> 成功：TRUE 失败：FALSE<br /> **********************************************************************/<br /> BOOL Write(LPVOID lpBuffer,DWORD dwSize);</p> <p> // 设置消息回调函数<br /> BOOL SetMsgCallBack(MsgQueueCallBack pCallBackFun, PVOID pParam);<br /> // 关闭消息队列<br /> void Close(void);<br /> private:<br /> // 开启读取消息线程<br /> BOOL StartRevMsgThread(void);<br /> // 停止读取消息线程<br /> BOOL StopRevMsgThread(void);<br /> // 读取消息线程<br /> static void WINAPI RevMsgThread(LPVOID pParam);<br /> private:<br /> HANDLE m_hMsgQueue;<br /> DWORD m_dwQueueSize;<br /> MsgQueueCallBack m_MsgCallBack;<br /> HANDLE m_hRevMsgThread;<br /> BOOL m_bThreadExit;<br /> };<br /> #endif

 源文件（CMsgQueue.cpp）

#include "stdafx.h"<br /> #include "CMsgQueue.h"</p> <p>CMsgQueue::CMsgQueue()<br /> {<br /> m_hMsgQueue = NULL;<br /> m_dwQueueSize = 0;<br /> m_hRevMsgThread = NULL;<br /> m_bThreadExit = FALSE;<br /> m_MsgCallBack = NULL;<br /> }</p> <p>CMsgQueue::CMsgQueue(LPCWSTR lpQueueName,DWORD dwSize,ACCESSMODE accessMode)<br /> {<br /> Create(lpQueueName,dwSize,accessMode);<br /> }</p> <p>CMsgQueue::~CMsgQueue()<br /> {<br /> Close();<br /> }</p> <p>BOOL CMsgQueue::Create(LPCWSTR lpQueueName,DWORD dwSize,ACCESSMODE accessMode)<br /> {<br /> if(!m_hMsgQueue)<br /> {<br /> m_hRevMsgThread = NULL;<br /> m_bThreadExit = FALSE;<br /> m_MsgCallBack = NULL;<br /> m_dwQueueSize = dwSize;<br /> // 创建消息队列<br /> MSGQUEUEOPTIONS options;<br /> options.dwSize = sizeof(options);<br /> options.dwFlags = MSGQUEUE_NOPRECOMMIT|MSGQUEUE_ALLOW_BROKEN;<br /> options.dwMaxMessages = 0;<br /> options.cbMaxMessage = dwSize;<br /> options.bReadAccess = (accessMode==ReadMode) ? TRUE : FALSE;<br /> m_hMsgQueue =::CreateMsgQueue(lpQueueName,&options);<br /> }<br /> return TRUE;<br /> }</p> <p>void CMsgQueue::Close(void)<br /> {<br /> if(m_hMsgQueue)<br /> {<br /> ::CloseMsgQueue(m_hMsgQueue);<br /> m_hMsgQueue = NULL;<br /> }<br /> // 注销回调函数<br /> SetMsgCallBack(NULL,NULL);<br /> }</p> <p>BOOL CMsgQueue::Read(LPVOID lpBuffer,DWORD dwSize,LPDWORD lpNumberOfBytesRead,DWORD dwTimeout)<br /> {<br /> if(m_hMsgQueue == NULL || lpBuffer == NULL)<br /> {<br /> return FALSE;<br /> }<br /> DWORD dwFlag = 0;<br /> // 从消息队列头部读出数据<br /> if(!::ReadMsgQueue(m_hMsgQueue,lpBuffer,dwSize,lpNumberOfBytesRead,dwTimeout,&dwFlag))<br /> {<br /> return FALSE;<br /> }<br /> return TRUE;<br /> }<br /> BOOL CMsgQueue::Write(LPVOID lpBuffer,DWORD dwSize)<br /> {<br /> if(m_hMsgQueue == NULL || lpBuffer == NULL)<br /> {<br /> return FALSE;<br /> }<br /> // 向消息队列尾部写入数据<br /> if(!::WriteMsgQueue(m_hMsgQueue,lpBuffer,dwSize,0,0))<br /> {<br /> return FALSE;<br /> }<br /> return TRUE;<br /> }</p> <p>BOOL CMsgQueue::SetMsgCallBack(MsgQueueCallBack pCallBackFun, PVOID pParam)<br /> {<br /> m_MsgCallBack = pCallBackFun;<br /> if (m_MsgCallBack)<br /> {<br /> if (m_hRevMsgThread == NULL)<br /> {<br /> // 开启读取线程<br /> return StartRevMsgThread();<br /> }<br /> }<br /> else<br /> {<br /> if (m_hRevMsgThread)<br /> {<br /> // 关闭读取线程<br /> return StopRevMsgThread();<br /> }<br /> }<br /> return TRUE;<br /> }</p> <p>BOOL CMsgQueue::StartRevMsgThread(void)<br /> {<br /> if(m_hRevMsgThread == NULL)<br /> {<br /> // 创建读取消息线程<br /> m_hRevMsgThread = CreateThread(NULL, 0, (LPTHREAD_START_ROUTINE)CMsgQueue::RevMsgThread, this, 0, NULL);<br /> }<br /> return (m_hRevMsgThread ? TRUE : FALSE);<br /> }</p> <p>BOOL CMsgQueue::StopRevMsgThread(void)<br /> {<br /> if(m_hRevMsgThread)<br /> {<br /> m_bThreadExit = TRUE;<br /> // 等待线程成功退出<br /> WaitForSingleObject(m_hRevMsgThread,INFINITE);<br /> CloseHandle(m_hRevMsgThread);<br /> m_hRevMsgThread = NULL;<br /> m_hRevMsgThread = FALSE;<br /> }<br /> return ((m_hRevMsgThread==NULL) ? TRUE : FALSE);<br /> }</p> <p>void WINAPI CMsgQueue::RevMsgThread(LPVOID pParam)<br /> {<br /> CMsgQueue *pMsgQueue=(CMsgQueue*)pParam;<br /> LPVOID lpBuffer;<br /> DWORD dwReadNums=0;<br /> lpBuffer=(LPVOID)malloc(pMsgQueue->m_dwQueueSize);<br /> while(!pMsgQueue->m_bThreadExit)<br /> {<br /> if(!pMsgQueue->m_hMsgQueue )<br /> break;<br /> // 从消息队列中读取一条消息（阻塞模式）<br /> BOOL ret=pMsgQueue->Read(lpBuffer,pMsgQueue->m_dwQueueSize,&dwReadNums,INFINITE);<br /> printf("Read ret=%d,dwReadNums=%d/n",ret,dwReadNums);<br /> if(dwReadNums>0)<br /> {<br /> // 调用回调函数<br /> if(pMsgQueue->m_MsgCallBack)<br /> pMsgQueue->m_MsgCallBack(lpBuffer,dwReadNums);<br /> }<br /> }<br /> printf("RevMsgThread exit.../n");<br /> free(lpBuffer);<br /> }

 使用CMsgQueue类实现进程间通信：

// 发送进程<br /> //////////////////////////////////////////////////////////////////////////////////<br /> // 创建只写消息队列<br /> CMsgQueue cMsgQueue(L"MsgQueueTest",1024,WriteMode);<br /> // 往消息队列写数据<br /> cMsgQueue.Write(L"Hello Word!",22);<br /> cMsgQueue.Close();<br /> //////////////////////////////////////////////////////////////////////////////////</p> <p>// 接收进程<br /> //////////////////////////////////////////////////////////////////////////////////<br /> // 声明消息回调函数<br /> BOOL CALLBACK RecvMsgProc(PVOID pData, DWORD dwSize);</p> <p>// 创建只读消息队列<br /> CMsgQueue cMsgQueue(L"MsgQueueTest",1024,ReadMode);<br /> // 设置消息回调函数<br /> cMsgQueue.SetMsgCallBack(RecvMsgProc,NULL);</p> <p>// 处理消息<br /> BOOL CALLBACK RecvMsgProc(PVOID pData, DWORD dwSize)<br /> {<br /> printf("RecvMsgProc:Rev data Size=%d/n",dwSize);<br /> wchar_t data[256];<br /> memcpy(data, pData,dwSize);<br /> return TRUE;<br /> }<br /> //////////////////////////////////////////////////////////////////////////////////<br />