windows 命名管道

个人感觉，windows 下的命名管道忒难用。

每一个命名管道都有一个唯一的名字以区分于存在于系统的命名对象列表中的其他命名管道。管道服务器在调用CreateNamedPipe（）函数创建命名管道的一个或多个实例时为其指定了名称。对于管道客户机，则是在调用CreateFile（）或CallNamedPipe（）函数以连接一个命名管道实例时对管道名进行指定。命名管道的命名规范与邮槽有些类似，对其标识也是采用的UNC格式：

\ServerPipe[Path]Name  

其中，第一部分\Server指定了服务器的名字，命名管道服务即在此服务器创建，其字串部分可表示为一个小数点（表示本机）、星号（当前网络字段）、域名或是一个真正的服务；第二部分Pipe与邮槽的Mailslot一样是一个不可变化的硬编码字串，以指出该文件是从属于NPFS；第三部分[Path]Name则使应用程序可以唯一定义及标识一个命名管道的名字，而且可以设置多级目录。

服务端使用函数：

CreateNamedPipe(); // 创建管道
ConnectNamedPipe(); // 阻塞，等待客户端连接

  客户端使用函数：

CreateFile(); // 打开(连接)管道

双方共用函数：

WriteFile();
ReadFile(); // 阻塞，使用方便
CloseHandle(); // 关闭管道，断开连接

服务端例程：

#include <stdio.h>
#include <windows.h>

#define PIPE_NAME L"\\.\Pipe\test"

HANDLE g_hPipe = INVALID_HANDLE_VALUE;

int main()
{
    char buffer[1024];
    DWORD WriteNum;

    printf("test server.
");
    g_hPipe = CreateNamedPipe(PIPE_NAME, PIPE_ACCESS_DUPLEX, 
            PIPE_TYPE_BYTE|PIPE_READMODE_BYTE , 1, 0, 0, 1000, NULL);
    if(g_hPipe == INVALID_HANDLE_VALUE)
    {
        printf("Create name pipe failed!
");
        goto out;
    }
    
    printf("Wait for connect...
");
    if(ConnectNamedPipe(g_hPipe, NULL) == FALSE)
    {
        printf("Connect failed!
");
        goto out;
    }
    printf("Connected.
");

    while(1)
    {
        scanf("%s", &buffer);
        if(WriteFile(g_hPipe, buffer, (DWORD)strlen(buffer), &WriteNum, NULL) == FALSE)
        {
            printf("Write failed!
");
            break;
        }
    }

out:
    printf("Close pipe.
");
    CloseHandle(g_hPipe);
    system("pause");
    return 0;
}

客户端例程：

#include <stdio.h>
#include <windows.h>

#define PIPE_NAME L"\\.\Pipe\test"

HANDLE g_hPipe = INVALID_HANDLE_VALUE;

int main()
{
    char buffer[1024];
    DWORD ReadNum;

    printf("test client.
");

    g_hPipe = CreateFile(PIPE_NAME, GENERIC_READ | GENERIC_WRITE, 
            0, NULL, OPEN_EXISTING, FILE_ATTRIBUTE_NORMAL, NULL);
    if (g_hPipe == INVALID_HANDLE_VALUE)
    {
        printf("Connect pipe failed!
");
        goto out;
    }
    printf("Connected.
");

    while(1)
    {
        if(ReadFile(g_hPipe, buffer, sizeof(buffer), &ReadNum, NULL) == FALSE)
        {
            break;
        }
        buffer[ReadNum] = 0;
        printf("%s
", buffer);
    }
out:
    printf("Close pipe.
");
    CloseHandle(g_hPipe);
    system("pause");
    return 0;
}