管道

/*
 * 匿名管道
 * 用于有亲缘关系的进程，单向，自动同步
 * Lzy    2011-6-14
 */

#include <stdio.h>
#include <stdlib.h>
#include <unistd.h>
#include <string.h>

int main(void)
{
    char buf[10];            //自定义缓冲区
    pid_t pid;            //定义进程ID
    int fd[2];            //定义管道句柄

    if(pipe(fd) < 0)        //创建匿名管道
    {
        perror("pipe");
        exit(0);
    }

    pid = fork();            //创建子进程
    if(pid == 0)            //子进程
    {
        close(fd[0]);        //子进程关闭管道读端
        write(fd[1], "hello\n", 6);    //子进程写管道
    }
    else if(pid > 0)
    {
        close(fd[1]);        //父进程关闭管道写端
        read(fd[0], buf, 6);    //父进程读管道
        printf("%s",buf);
    }
    return 0;
}

/*
 * 命名管道(FIFO)
 * 用于任何进程之间通信
 * int mkfifo(const char * pathname, mode_t mode);
 * 命令行命名管道
    mkfifo cmd_fifo
    cat cmd_fifo //tty1
    echo hi > cmd_fifo //tty2
 *Lzy    2011-6-14
 */

#include <stdio.h>
#include <stdlib.h>
#include <sys/types.h>
#include <sys/stat.h>

/*
 * 创建命名管道
 */
int main(int argc, char *argv[])
{
    mode_t mode = 0755;        //定义文件的询问权限

    if(mkfifo(argv[1], mode) < 0)    //创建FIFO文件
    {
        perror("mkfifo");
        exit(0);
    }
    else
        printf("Done!\n");

    return 0;
}

/*
 * 命名管道实现非亲缘关系进程的进程
 * 发送程序
 * 从键盘输入一串字符至管道文件
 * Lzy    2011-6-14
 */

#include <stdio.h>
#include <stdlib.h>
#include <unistd.h>
#include <fcntl.h>
#include <string.h>

int main(void)
{
    int fd;
    char buf[10];        //自定义缓冲区

    fd = open("fifo", O_WRONLY);    //以写方式打开管道文件
    if(fd < 0)
    {
        perror("open");
        exit(0);
    }

    read(0, buf, sizeof(buf));            //从键盘读入
    write(fd, buf,strlen(buf));        //写入管道文件

    return 0;
}

/*
 * 命名管道实现非亲缘关系进程的进程
 * 接收程序
 * 从管道文件读内容至屏幕
 * Lzy    2011-6-14
 */

#include <stdio.h>
#include <stdlib.h>
#include <unistd.h>
#include <fcntl.h>
#include <string.h>

int main(void)
{
    int fd;
    char buf[10];        //自定义缓冲区

    fd = open("fifo", O_RDONLY);    //以读方式打开管道文件
    if(fd < 0)
    {
        perror("open");
        exit(0);
    }

    read(fd, buf, sizeof(buf));        //从管道文件读入
    write(1, buf,strlen(buf));        //写到屏幕

    return 0;
}