步读取操作。否则,应将这个参数设为NULL
)
详细参数请见:http://baike.baidu.com/view/1336847.htm。行了,假设看这篇文章的同学都已经 了VS2005下MFC的创建和使用,下面的内容将开始实刀实枪的开始“管道之 旅”,使用MFC创建一个标准的管道通讯程序。
【server部分:】
1、为了更好的控制我们的程序,第一步定义一个管道基类是个好的做法 ,在这里我们借鉴一个例子,创建一个"CMyPipe.h"的头文件,代码 如下:
#pragma once
class CMyPipe //创建我们的通道基类,主要为了方便定位通道
{
public:
CMyPipe(); //创建一个构造函数;
CMyPipe(LPCTSTR lpctstr); //构造函数的重载;
~CMyPipe(); //一个析构函数;
protected:
HANDLE MyPipe; //创建一个HANDLE 变量,用于定义我们的通道 头
CString MyPipeName; //创建一个通道名;
};
2、定义一个基类CMyPipe的扩展类CPipeServer ,将其写入到一个新的头文件中,在这里我命名为pp.h,代码如下:
#pragma once
#include "CMyPipe.h"
class CPipeServer:public CMyPipe //定义基类CMyPipe的扩展 类
{
public: //构造函数
CPipeServer();
CPipeServer(LPCTSTR lpPipeName); //构造函数重载
~CPipeServer(); //析构函数
CWnd* GethWndServer(); //定义一个获取窗口函数
CWnd* SethWndServer(CWnd *pWndServer); //定义设置窗口的 函数
bool ServerReplyInfo(CString StrReply); //定义创建通道反 馈信息的函数
bool ServerExit(); //服务器退出时使用
static UINT ServerReadProc(LPVOID lParam); //管道服务器 创建后的操作,创建服务器可不是让他闲着。。。
void InitPipeServer(UINT InstanceCount);
void UnInitPipeServer(void);
CPipeServer *m_pPipeServer; //CPipeServer类动态数组(可实 现多个管道实例,提高管道服务器端负荷处理能力)
UINT m_InstanceCount; //管道实例个数
private:
CWnd* m_pWndServer; //定义将要写入的窗口类变量
CWinThread *m_pWinThread; //每次使用新线程调用服务器时的 存储线程变量
CString m_StrReply; //接收的信息存储变量
};
3、接下来我们将对之前定义的函数在项目中的 cpp文件中进行实例化,并做应用:
//3个CMyPipe基类的实例化
CMyPipe::CMyPipe()//直接定义管道名
{
MyPipeName=_T("\\\\.\\pipe\\snmp");
}
CMyPipe::CMyPipe(LPCTSTR lpPipeName) //管道名的重载
{
MyPipeName=lpPipeName;
}
::CMyPipe::~CMyPipe()
{
MyPipeName.Empty();
}
CPipeServer::CPipeServer():CMyPipe()
{
m_StrReply.Empty();
m_pWndServer=NULL;
}
CPipeServer::CPipeServer(LPCTSTR lpPipeName):CMyPipe (lpPipeName)
{
m_StrReply.Empty();
m_pWndServer=NULL;
}
CPipeServer::~CPipeServer()
{
m_StrReply.Empty();
m_pWndServer=NULL;
}
//因为涉及到了新建线程接收管道信息,所以需要定位控件窗口
CWnd * CPipeServer::SethWndServer(CWnd *pWndServer)
{
return m_pWndServer=pWndServer;
}
CWnd* CPipeServer::GethWndServer()
{
return m_pWndServer;
}
//定位控件窗口
void CPipeServer::InitPipeServer(UINT InstanceCount)
{
m_pPipeServer=NULL;
m_InstanceCount=0;
m_pPipeServer=new CPipeServer[InstanceCount];
if(m_pPipeServer!=NULL)
m_InstanceCount=InstanceCount;
}
void CPipeServer::UnInitPipeServer(void)
{
if(m_pPipeServer!=NULL){
delete [] m_pPipeServer;
m_pPipeServer=NULL;
m_InstanceCo
|