「邮槽」单向进程间通信——Console程序设计

    技术2022-05-19  33

    命名规则

     

                // ./Mailslot/name                      标定同一台机器上的一个本地邮槽            //servername/Mailslot/name     标定名为servername的一个远程邮槽服务器            // domainname/Mailslot/name   标定在指定的domain(域)内,使用特定name(名字)的所有邮槽            //*/Mailslot/name                      标定系统主域内,标定特定name(名字)的所有邮槽

     

                除了Mailslot 为指定名称外,其他字串均可自由设定

     

    创建邮槽服务器端:"邮槽服务器端只能进行读"

     

    #include <stdio.h>

    #include <tchar.h>

    #include <Windows.h>

     

     

    int _tmain(int argc, _TCHAR* argv[])

    {

        HANDLE Mailslot;

        char   buffer[256];

        DWORD  NumberOfBytesRead;

     

     

        // 创建邮槽,获得邮槽句柄

        // MAILSLOT_WAIT_FOREVER 参数指明数据读取时间为永久

        if ((Mailslot = CreateMailslot(TEXT(".//Mailslot//Myslot"), 0,

            MAILSLOT_WAIT_FOREVER, NULL)) == INVALID_HANDLE_VALUE)

        {

            printf("邮槽服务器创建失败,错误代码: %d/n", GetLastError());

            return -1;

        }

     

        // 读取邮槽中的数据

        // MAILSLOT_WAIT_FOREVER 参数将导致ReadFile函数持续保有控制权,直至读到数据

        while(ReadFile(Mailslot, buffer, 256, &NumberOfBytesRead,

            NULL) != 0)

        {

            buffer[NumberOfBytesRead] = 0; //设置字符串尾

            printf("%s/n", buffer);

        }

        return 0;

    }

     

     

    创建邮槽客户端 :"邮槽客户端只能进行写"

     

    #include <stdio.h>

    #include <tchar.h>

    #include <Windows.h>

     

     

    int _tmain(int argc, _TCHAR* argv[])

    {

        HANDLE Mailslot;

        DWORD  BytesWritten; 

     

     

        // 打开一个邮槽,获得邮槽句柄

        // .//Mailslot//Myslot 指明了邮槽位于同一台计算机

        // GENERIC_WRITE 以写模式打开

        // FILE_SHARE_READ 读共享是必须的,因为服务端需要进行读操作

        // 参数四用于指定安全特性,对于邮槽是无意义的,所以设为NULL

        //  OPEN_EXISTING 标志指明该邮槽必须已经存在。若一台机器既是客户机又是服务器,这一设置便显得尤其重要

            //如果服务器没有创建邮槽,对CreateFile的调用便会失败.但如果服务器为远程,该参数就无意义.

        // FILE_ATTRIBUTE_NORMAL 指明属性为默认

        // 最后一个参数为NULL,指定该邮槽不复制扩展属性

        if ((Mailslot = CreateFile(TEXT(".//Mailslot//Myslot"), GENERIC_WRITE,

            FILE_SHARE_READ, NULL, OPEN_EXISTING, FILE_ATTRIBUTE_NORMAL,

            NULL)) == INVALID_HANDLE_VALUE)

        {

            printf("邮槽打开失败,错误代码: %d/n", GetLastError());

            return -1;

        }

     

        // 向邮槽服务器发送数据

        if (WriteFile(Mailslot, "This is a test", 14, &BytesWritten,

            NULL) == 0)

        {

            printf("消息发送失败,错误代码: %d/n", GetLastError());

            return -1;

        }

     

        printf("Wrote %d bytes/n", BytesWritten);

     

        CloseHandle(Mailslot); // 关闭之前打开的邮槽句柄

        return 0;

    }

     

    其他邮槽API

     

          GetMailslotInfo 和 SetMailslotInfo 可以在邮槽服务器端调用。

     

          BOOL GetMailslotInfo (           HANDLE     hMailslot,                  //以创建的邮槽句柄           LPDWORD lpMaxMessageSize,   //设置可将多大的一条消息写入邮槽(以字节为单位)           LPDWORD lpNextSize,                //以字节为单位,指出下一条消息的长度           LPDWORD lpMessageCount,      //指定一个缓冲区,用于接收等候读入的消息的总量           LPDWORD lpReadTimeout          //一个缓冲区,以毫秒为单位,返回当前设置的一次读操作最多等候时间       );

     

          如果当前没有消息,lpNextSize 参数的值为常量 MAILSLOT_NO_MESSAGE

     

         BOOL SetMailslotInfo (

              HANDLE     hMailslot,                  //以创建的邮槽句柄

              DWORD     lReadTimeout            //设置一次读操作最多等候时间,以毫秒为单位

                                                               //若将其设为0,在不存在消息的前提下,读操作便会立即返回;

                                                               //若设为MAILSLOT_WAIT_FOREVER,读操作便会永远等待下去

         );


    最新回复(0)