在linux中,管道也是一种文件,只不过比较特殊,我们可以用pipe函数创建一个管道,其原型声明如下:
#inlcude <unistd.h>
int pipe(int fields[2]);
其实它相当于一个通信缓冲区,fields[0]用来读,fields[1]用来写。下面的例子中,创建一个管道作为通信缓冲区,父进程创建了一个子进程,子进程通过管道的fields[1]描述符想管道中写入一个字符串,而父进程则利用管道的fields[0] 从管道中读取这个字串并显示出来:
#include <stdio.h>
#include <stdlib.h>
#include <unistd.h>
#include <string.h>
#include <errno.h>
#include <sys/types.h>
#include <sys/wait.h>
#define buf_siz 255 // message buffer size
int main(int argc, char **argv)
{
char buffer[buf_siz + 1];
int fd[2];
// receive a string as parameter
if ( argc != 2)
{
fprintf(stderr, usage: %s string\n\a, argv[0]);
exit(1);
}
// create pipe for communication
if ( pipe(fd) != 0 )
{
fprintf(stderr, create pipe error: %s\n\a, strerror(errno));
exit(1);
}
if ( fork() == 0 ) // in child process write msg to pipe
{
close(fd[0]);
printf(child %ld write to pipe\n\a, getpid());
snprintf(buffer, buf_siz, %s, argv[1]);
write(fd[1], buffer, strlen(buffer));
printf(child %ld quit.\n\a, getpid());
}
else // in parent process, read msg from pipe
{
close(fd[1]);
printf(parent %ld read from pipe\n\a, getpid());
memset(buffer, '\0', buf_siz + 1);
read(fd[0], buffer, buf_siz);
printf(parent %ld read : \n%s\n, getpid(), buffer);
exit(1);
}
return 0;
}