VC命名管道通信的实现

2016-02-19 18:35 6 1 收藏

人生本是一个不断学习的过程,在这个过程中,图老师就是你们的好帮手,下面分享的VC命名管道通信的实现懂设计的网友们快点来了解吧!

【 tulaoshi.com - 编程语言 】

无论是sqlserver的用户,还是pb的用户,作为c/s结构开发环境,他们在网络通信的实现上,都有一种共同的方法——命名管道。由于当前操作系统的不惟一性,各个系统都有其独自的通信协议,导致了不同系统间通信的困难。 !-- frame contents -- !-- /frame contents -- 尽管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,″servernamepipepipename″)
  
  if (waitnamedpipe( pipenamestr, nmpwait—wait—forever)==false
  
  // 管道名要遵循unc,格式为 .pipepipname,名字不分大小写。
  
  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,″.pipepipename″)
  
  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();
  
  //用户自定义信息交换函数
  
  ……
  
 

  二、程序设计的注重事项
  
  1.假如命名管道客户端已打开,函数将会强迫关闭管道,用disconnectnamedpipe关闭的管道,其客户端还必须用closehandle来关闭最后的管道。
  
  2.readfile和writefile的hfile句柄是由createfile及connectnamedpipe返回得到。
  
  3.一个已被某客户端连接的管道句柄在被另一客户通过connectnamedpipe建立连接之前,服务端必须用disconnectnamedpipe函数对已存在的连接进行强行拆离。服务端拆离管道会造成管道中数据的丢失,用flushfilebuffers函数可以保证数据不被丢失。
  
  4.命名管道服务端可以通过新创建的管道句柄或已被连接过其他客户的管道句柄来使用connectnamedpipe函数,但在连接新的客户端之前,服务端必须用函数disconnectnamedpipe切断之前的客户句柄,否则connectnamedpipe将会返回false。
  
  5.阻塞模式,这种模式仅对“字节传输管道操作有效,并且要求客户端与服务端不在同一机器上。假如用这种模式,则只有当函数通过网络向远端计算机管道缓冲器写数据成功时,才能有效返回。假如不用这种模式,系统会运行缺省方式以提高网络的工作效率。
  
  6.用户必须用file—create—pipe—instance来访问命名管道对象。新的命名管道建立后,来自安全参数的访问控制列表定义了访问该命名管道的权限。所有命名管道实例必须使用统一的管道传输方式、管道模式等参数。客户端未启动,管道服务端不能执行阻塞读操作,否则会发生空等的阻塞状态。当最后的命名管道实例的最后一个句柄被关闭时,就应该删除该命名管道。

来源:http://www.tulaoshi.com/n/20160219/1618248.html

延伸阅读
Winsock控件是VB5.0的新增功能,它解决了以往应用VB编程时网络中应用程序之间无法实现点对点通信的难题。Winsock使用的TCP协议和UDP协议允许建立并保持一个到远程计算机上的连接,且可以在连接结束之前实时地进行数据交换。用户仅通过设置属性并借助事件处理就能够轻而易举地连接到一个远程的计算机上,而且只用两个命令就可以实现数据交换。 ...
不知你是否用过这样的程序,他们本身并没有解压缩的功能,而是调用DOS程序PKZIP完成ZIP包的解压缩。但是在程序运行时又没有DOS控制台的窗口出现而且一切本应该在DOS下显示的信息都出现在了那个安装程序的一个文本框里。这种设计既美观又可以防止少数眼疾手快的用户提前关了你的DOS窗口。 现在就来讨论一下,如何用匿名管道技术实现这...
什么是命名查询? Hibernate允许在映射文件中定义字符串形式的查询语句,这种查询方式成为命名查询 使用命名查询有什么好处? 由于使用Hibernate的HQL常常需要在Java代码中写字符串查询语句,HQL混杂在代码之间,破坏代码可读性,通过使用命名查询,可以使业务逻辑和查询语句分离,使您专注于查询,而避免了 SQL 或者 HQL 代码分散于整个...
由于Oracle不提供用于实时输出消息的工具, Oracle数据库开发者总是要面临实时监视他们的储备过程执行的挑战。他们必须使用dbms_output.put_line调用,这个调用直到过程完成才返回结果。 在本文中,我想演示如何从Oracle8i数据库直接发送电子邮件,作为一种实时通信解决方案。这样我们要监视存储过程就不再需要等待它们完...
标签: Web开发
在漫长的前端开发旅途上,无可避免的会接触到ajax,而且一般情况下都是用在同一域下的ajax请求;但是如果请求是发生在不同的域下,请求就无法执行,并且会抛出异常提示不允许跨域请求,目前我没有找到明确的资料说明这是为什么,我觉得应该是出于安全性的考虑吧。纵然如此,要实现跨域访问的话,方法还是有的,而且不只一种,在这里介绍其中一...

经验教程

15

收藏

71
微博分享 QQ分享 QQ空间 手机页面 收藏网站 回到头部