管道同步通信

管道通信，一对一通信例子。

服务端：

#include <stdio.h>
#include <Windows.h>

int main(void)
{
    HANDLE hPipe = NULL;
    char buf[255] = { 0 };
    DWORD dwLen = 0;

    // 创建命名管道
    hPipe = CreateNamedPipe("\\.\Pipe\biaoge",  // 管道名字
        PIPE_ACCESS_DUPLEX,                            // 可读写
        PIPE_TYPE_MESSAGE | PIPE_WAIT,                // 消息类型 阻塞模式
        PIPE_UNLIMITED_INSTANCES,                    // 最大实例 该常量代表255
        NULL,                                        // 默认输出缓存大小
        NULL,                                        // 默认输入缓存大小
        NULL,                                        // 默认客户端超时
        NULL                                        // 默认安全属性
        );
    if (hPipe == INVALID_HANDLE_VALUE)
    {
        printf("CreateNamedPipe failed:%d.
", GetLastError());
        return 0;
    }

    printf("Wait client connect...
");
    // 等待客户端连接
    if (ConnectNamedPipe(hPipe, NULL) == 0)
    {
        printf("ConnectNamedPipe failed:%d.
", GetLastError());
        return 0;
    }
    printf("Client in
");
    // 客户端进入,读取客户端发送的数据
    if (ReadFile(hPipe, buf, sizeof(buf), &dwLen, NULL))
    {
        printf("Recv:[%s]
", buf);
        // 向客户端发送数据
        if (WriteFile(hPipe, "Hello Client!", 15, &dwLen, NULL))
        {
            printf("Send client data success!
");
        }
        else
        {
            printf("Send client data failed!
");
        }
    }
    // 关闭管道
    CloseHandle(hPipe);
    system("pause");
    return 0;
}

客户端：

#include <stdio.h>
#include <Windows.h>

int main(void)
{
    HANDLE hPipe = NULL;
    DWORD dwLen = 0;
    char str[255] = "Hello Biaoge,Testing Pipe!";

    // 连接管道
    hPipe = CreateFile("\\.\Pipe\biaoge", GENERIC_READ | GENERIC_WRITE, 0, NULL, OPEN_EXISTING, 0, NULL);
    if (hPipe == INVALID_HANDLE_VALUE)
    {
        printf("Connect server pipe failed:%d.
", GetLastError());
        return 0;
    }
    printf("Connect server success!
");
    // 连接成功,向服务端发送一条数据
    if (WriteFile(hPipe,str , lstrlen(str)+1, &dwLen, NULL))
    {
        printf("Send data success!
");
    }
    else
    {
        printf("Send data failed:%d.
", GetLastError());
        return 0;
    }
    // 接收服务端数据
    if (ReadFile(hPipe, str, sizeof(str), &dwLen, NULL))
    {
        printf("Recv server data:[%s]
", str);
    }
    else
    {
        printf("Recv server data failed!
");
    }
    // 关闭管道
    CloseHandle(hPipe);
    system("pause");
    return 0;
}

效果图