管道和FIFO

pipe()函数：

#include <unistd.h>

// 返回两个文件描述符，前者(fd[0])用来读，后者(fd[1])用来写
// 成功返回0，出错返回-1
int pipe(int fd[2]);

popen()和pclose()函数：

#include <stdio.h>

// 创建一个管道，并启动另外一个进程
// 该进程要么从管道读出标准输入(type为 r)，要么往管道写入标准输出(type为 w)
// 成功返回文件指针，出错返回NULL
FILE *popen(const char *command, const char *type); 
// command是一个shell命令

// 成功返回shell的终止状态，出错返回-1
int pclose(FILE *stream);

mkfifo()函数：

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

// 创建一个FIFO(有名管道)
// 使用 open()函数打开它(pathname)来使用
// 成功返回0，出错返回-1
int mkfifo(const char *pathname, mode_t mode);

此处仅仅给出相关函数说明，有关于pipe的具体信息请自行查找。

示例1：

由子进程读取一个文件，通过管道将读取内容发送给父进程，再由父进程打印到标准输出

#include <stdio.h>
#include <unistd.h>
#include <fcntl.h>
#include <stdlib.h>
#include <string.h>
#include <sys/wait.h>

#define MAXLINE 100

int main(int argc, char *argv[])
{    
    if (argc != 2)
    {
        printf("Need two arguements!
");
    exit(1);
    }

    int fd[2];
    //FILE *fp;
    pid_t pid;
    char readbuff[MAXLINE], writebuff[MAXLINE];
    int n;
    int fd_text;
/*
    if ((fp = fopen(argv[1], "r")) == NULL)
    {
        printf("Error fopen!
");
    exit(1);
    }
*/
    if ((fd_text = open(argv[1], O_RDONLY)) == -1)
    {
        printf("Error open!
");
    exit(1);
    }
    if (pipe(fd) == -1)
    {
        printf("Error pipe!
");
    exit(1);
    }
    
    if ((pid = fork()) < 0)
    {
        printf("Error fork!
");
    exit(1);
    }
    else if (pid == 0)
    {
        close(fd[0]);
    /*
        while (fgets(writebuff, MAXLINE, fp) != NULL)
    {
        n = strlen(writebuff);
        
        if (write(fd[1], writebuff, n) != n)
        {
            printf("Error write!
");
        exit(1);
        }
    }
        */
    while ((n = read(fd_text, readbuff, MAXLINE)) > 0 )
    {
        if (write(fd[1], readbuff, n) == -1)
        {
            printf("Error write!
");
        exit(1);
        }
    }
    close(fd[1]);
        exit(0);
    }
    else
    {
        close(fd[1]);
        
    while (read(fd[0], readbuff, MAXLINE) > 0)
    {
        //write(stdout, readbuff, strlen(readbuff));
        printf("%s
", readbuff);
    }

    if (waitpid(pid, NULL, 0) < 0)
    {
        printf("Error waitpid!
");
        exit(1);
    }
    
    exit(0);
    }

    
    return 0;
}

被读取的文件内容:

[root@bogon IPC_examples]# cat text 
aaaaaaa
bbbbbbb
ccccccc

执行情况：

[root@bogon IPC_examples]# ./pipe_ep text
aaaaaaa
���
bbbbbbb
���
ccccccc
���

cccccc
���
[root@bogon IPC_examples]# vim pipe_ep
[root@bogon IPC_examples]# vim pipe_ep.c 
[root@bogon IPC_examples]# gcc pipe_ep.c -o pipe_ep
[root@bogon IPC_examples]# ./pipe_ep text
aaaaaaa
bbbbbbb
ccccccc

第一次执行时，子进程读取文本文件用的是标准I/O库的函数，然后输出出现乱码(代码中被注释掉的部分)

第二次执行时，子进程读取文本文件用的是文件I/O相关函数，输出正常