zoukankan      html  css  js  c++  java
  • VC命名管道通信的实现

    无论是SQL Server的用户,还是PB的用户,作为C/S结构开发环境,他们在网络通信的

    实现上,都有一种共同的方法__命名管道。由于当前操作系统的不惟一性,各个系统

    都有其独自的通信协议,导致了不同系统间通信的困难。尽管TCP/IP协议目前已发展成

    Internet的标准,但仍不能保证C/S应用程序的顺利进行。命名管道作为一种通信方

    法,有其独特的优越性,这主要表现在它不完全依赖于某一种协议,而是适用于任何

    协议__只要能够实现通信。

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

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

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

      3) 支持多客户机连接。

      4) 支持双向通信

      5) 支持异步重叠I/O操作。

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

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

      1.命名管道ServerClient间通信的实现流程

      (1)建立连接:服务端通过函数CreateNamedPipe创建一个命名管道的实例并返回用于

    今后操作的句柄,或为已存在的管道创建新的实例。如果在已定义超时值变为零以前,有

    一个实例管道可以使用,则创建成功并返回管道句柄,并用以侦听来自客户端的连接请求,

    该功能通过ConnectNamedPipe函数实现。

      另一方面,客户端通过函数WaitNamedPipe使服务进程等待来自客户的实例连接,如

    果在超时值变为零以前,有一个管道可以为连接使用,则WaitNamedPipe将返回True,并

    通过调用CreateFileCallNamedPipe来呼叫对服务端的连接。此时服务端将接受客户端

    的连接请求,成功建立连接,服务端ConnectNamedPipe返回True,客户端CreateFile将返

    回一指向管道文件的句柄。

      从时序上讲,首先是客户端通过WaitNamedPipe使服务端的CreateFile在限时时间内

    创建实例成功,然后双方通过ConnectNamedPipeCreateFile成功连接,并返回用以通信

    的文件句柄,此时双方即可进行通信。

      (2)通信实现:建立连接之后,客户端与服务器端即可通过ReadFileWriteFile

    利用得到的管道文件句柄,彼此间进行信息交换。

      (3)连接终止:当客户端与服务端的通信结束,或由于某种原因一方需要断开时,客

    户端应调用CloseFile,而服务端应接着调用DisconnectNamedPipe。当然服务端亦可通

    过单方面调用DisconnectNamedPipe终止连接。最后应调用函数CloseHandle来关闭该管道。

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

      (1)客户端:

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

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

      ……

      (2)服务端:

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

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

      ……

      二、程序设计的注意事项

      1.如果命名管道客户端已打开,函数将会强迫关闭管道,用DisconnectNamedPipe关闭

    的管道,其客户端还必须用CloseHandle来关闭最后的管道。

      2. ReadFileWriteFilehFile句柄是由CreateFileConnectNamedPipe返回得到。

      3.一个已被某客户端连接的管道句柄在被另一客户通过ConnectNamedPipe建立连接之前,服务端必须用DisconnectNamedPipe函数对已存在的连接进行强行拆离。服务端拆离管道会造成管道中数据的丢失,用FlushFileBuffers函数可以保证数据不被丢失。

      4.命名管道服务端可以通过新创建的管道句柄或已被连接过其他客户的管道句

    柄来使用ConnectNamedPipe函数,但在连接新的客户端之前,服务端必须用函数

    DisconnectNamedPipe切断之前的客户句柄,否则ConnectNamedPipe 将会返回False

      5.阻塞模式,这种模式仅对“字节传输管道"操作有效,并且要求客户端与服务端不

    在同一机器上。如果用这种模式,则只有当函数通过网络向远端计算机管道缓冲器写数

    据成功时,才能有效返回。如果不用这种模式,系统会运行缺省方式以提高网络的工作效率。

      6.用户必须用FILE_CREATE_PIPE_INSTANCE 来访问命名管道对象。新的命名管

    道建立后,来自安全参数的访问控制列表定义了访问该命名管道的权限。所有命名管道

    实例必须使用统一的管道传输方式、管道模式等参数。客户端未启动,管道服务端不能

    执行阻塞读操作,否则会发生空等的阻塞状态。当最后的命名管道实例的最后一个句柄

    被关闭时,就应该删除该命名管道。

  • 相关阅读:
    [CTF]Capture The Flag -- 夺旗赛
    [DesignPattern]Builder设计模式
    [Git]Git 常用的操作命令
    给定一个整数数组 nums 和一个目标值 target,请你在该数组中找出和为目标值的那 两个 整数,并返回他们的数组下标。 你可以假设每种输入只会对应一个答案。但是,你不能重复利用这个数组中同样的元素。 示例: 给定 nums = [2, 7, 11, 15], target = 9 因为 nums[0] + nums[1] = 2 + 7 = 9 所以返回 [0, 1]
    QT 实现 读取 增加 删除 实时操作xml
    QT5-图形视图框架
    C++之QT
    ,即双方交锋的次数。随后N行,每行给出一次交锋的信息,即甲、乙双方同时给出的的手势。C代表“锤子”、J代表“剪刀”、B代表“布”,第1个字母代表甲方,第2个代表乙方,中间有1个空格。
    要获得一个C语言程序的运行时间,常用的方法是调用头文件time.h,其中提供了clock()函数,可以捕捉从程序开始运行到clock()被调用时所耗费的时间。这个时间单位是clock tick,即“时钟打点”。同时还有一个常数CLK_TCK,给
    给定N个非0的个位数字,用其中任意2个数字都可以组合成1个2位的数字。要求所有可能组合出来的2位数字的和。例如给定2、5、8,则可以组合出:25、28、52、58、82、85,它们的和为330。
  • 原文地址:https://www.cnblogs.com/ahuo/p/614723.html
Copyright © 2011-2022 走看看