当前位置导航:炫浪网>>网络学院>>编程开发>>C++教程>>Visual C++教程

VC命名管道通信的实现

      无论是sqlserver的用户,还是pb的用户,作为c/s结构开发环境,他们在网络通信的实现上,都有一种共同的方法——命名管道。由于当前操作系统的不惟一性,各个系统都有其独自的通信协议,导致了不同系统间通信的困难。尽管tcp/ip协议目前已发展成为internet的标准,但仍不能保证c/s应用程序的顺利进行。命名管道作为一种通信方法,有其独特的优越性,这主要表现在它不完全依赖于某一种协议,而是适用于任何协议——只要能够实现通信。


      命名管道具有很好的使用灵活性,表现在:

      1) 既可用于本地,又可用于网络。

      2) 可以通过它的名称而被引用。

      3) 支持多客户机连接。

      4) 支持双向通信。

      5) 支持异步重叠i/o操作。

      不过,当前只有windows nt支持服务端的命名管道技术。

      一、命名管道程序设计的实现

      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来关闭该管道。

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

      (1)客户端:

      handle clthandle;

      char pipenamestr30;

      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—readfile—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();

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

      ……

      (2)服务端:

      handle svrhandle;

      char pipenamestr30;

      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();

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

 

 

共2页 首页 上一页 1 2 下一页 尾页 跳转到
相关内容
赞助商链接