命名管道程序设计的实现

1.命名管道Server和Client间通信的实现流程

(1)建立连接：服务端通过函数CreateNamedPipe创建一个命名管道的实例并返回用于今后操作的句柄，或为已存在的管道创建新的实例。如果在已定义超时值变为零以前，有一个实例管道可以使用，则创建成功并返回管道句柄，并用以侦听来自客户端的连接请求，该功能通过ConnectNamedPipe函数实现。

另一方面，客户端通过函数WaitNamedPipe使服务进程等待来自客户的实例连接，如果在超时值变为零以前，有一个管道可以为连接使用，则WaitNamedPipe将返回True，并通过调用CreateFile或CallNamedPipe来呼叫对服务端的连接。此时服务端将接受客户端的连接请求，成功建立连接，服务端ConnectNamedPipe返回True，客户端CreateFile将返回一指向管道文件的句柄。

从时序上讲，首先是客户端通过WaitNamedPipe使服务端的CreateFile在限时时间内创建实例成功，然后双方通过ConnectNamedPipe和CreateFile成功连接，并返回用以通信的文件句柄，此时双方即可进行通信。

(2)通信实现：建立连接之后，客户端与服务器端即可通过ReadFile和WriteFile，利用得到的管道文件句柄，彼此间进行信息交换。

(3)连接终止：当客户端与服务端的通信结束，或由于某种原因一方需要断开时，客户端应调用CloseFile，而服务端应接着调用DisconnectNamedPipe。当然服务端亦可通过单方面调用DisconnectNamedPipe终止连接。最后应调用函数CloseHandle来关闭该管道。

命名管道服务器端和客户端代码实现

客户端

HANDLE CltHandle；

char pipenamestr[30];

sprintf(pipenamestr,″\\servername\pipe\pipename″)

if (WaitNamedPipe( pipenamestr, NMPWAIT—WAIT—FOREVER)==FALSE

// 管道名要遵循UNC，格式为\ \．\pipe\pipname,名字不分大小写。

AfxMessageBox(″操作失败，请确定服务端正确建立管道实例！″);

Else

CltHandle=CreateFile(pipenamestr, GENERIC—READ|GENERIC—WRITE, FILE—SHARE—READ| FILE—SHARE—WRITE,NULL, OPEN—EXISTING,

//为了与命名管道连接，此参数应一直为OPEN—EXISTING

FILE—ATTRIBUTE—ARCHIVE|FILE—FLAG—WRITE—THROUGH,

// FILE—FLAG—WRITE—THROUGH会使管道WriteFile调用处于阻塞状态，直到数据传送成功。

NULL);

If (CltHandle== INVALID—HANDLE—VALUE)

AfxMessageBox(″管道连接失败″);

Else

DoUsertTransactInfo（）；

//执行用户自定义信息交换函数——从管道读、写信息。

……

服务端

HANDLE SvrHandle；

char pipenamestr[30];

sprintf(pipenamestr,″\\.\pipe\pipename″)

SvrHandle=CreateNamedPipe(pipenamestr,

PIPE—ACCESS—DUPLEX|FILE—FLAG—WRITE—THROUGH,

//阻塞模式，这种模式仅对″字节传输管道″操作有效。

FILE—WAIT|PIPE—TYPE—BYTE,

//字节模式

PIPE—UNLIMITED—INSTANCES,

128,128,

NULL,NULL);

// SECURITY—ATTRIBUTES结构指针，描述一个新管道，确定子进程的继承权，如果为NULL则该命名管道不能被继承。

If (SvrHandle==INVALID—HANDLE—VALUE)

AfxMessageBox(″管道创建失败，请确定客户端提供连接可能！″);

Else

If (ConnectNamedPipe(SvrHandle,NULL)==FALSE)

AfxMessageBox(″建立连接失败！″);

Else

DoUsertTransactInfo（）；

//用户自定义信息交换函数

……