11、fifo,pipe简介-阿里云开发者社区

11、fifo,pipe简介

2011-09-10 793

版权

本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。

简介： 1、IPC的持久性 1）进程相关的：IPC中数据一直存在到最后一个关联进程关闭时 pipe、fifo等 2）内核相关的IPC：IPC中数据一直存在，除非内核重启或删除消息队列，共享内存等 3）文件系统相关的IPC：IPC中数据一直存在，除非显式删除文件 2、管道匿名管道(p...

1、IPC的持久性

1）进程相关的：IPC中数据一直存在到最后一个关联进程关闭时

pipe、fifo等

2）内核相关的IPC：IPC中数据一直存在，除非内核重启或删除

消息队列，共享内存等

3）文件系统相关的IPC：IPC中数据一直存在，除非显式删除

文件

2、管道

匿名管道(pipe)：只能用于同一个祖先的进程组

有名管道(fifo)：不相关的进程也可以使用

3、匿名管道

int pipe(int filedes[2]);

fildes[0] 用于从管道中读取数据

fildes[1] 用于将数据写入管道

不需要open，直接read/write 等系统调用

系统自动删除，进程不需要考虑

示例

View Code

#include "stdio.h"
#include "stdlib.h"
#include "unistd.h"
#include "string.h"
int  main(void)  
{
int n, fd[2];
    pid_t pid;
char line[512];
        memset(line, 0, 512);
if (pipe(fd) < 0)   
    {
        printf("pipe error");
    }

if ((pid = fork()) < 0) 
    {  
        printf("fork error"); 
    } 
else if (pid > 0) 
    {       
/* parent */
        close(fd[0]);
        write(fd[1], "hello\n", 13);
    } 
else 
    {                
/* child */
        close(fd[1]);
        n = read(fd[0], line, 215);
        printf("%s", line);
    }
}

4、有名管道

int mkfifo(const char *pathname, mode_t mode);

pathname等参数和open类似

需要open，open必须只能是只读或只写。

open阻塞模式：阻塞到有进程以相对应方式打开相同的fifo。

open非阻塞式：只读打开立刻返回；只写时，如果没有对应的进程已经只读打开相同的fifo，返回错误。

open之后才能read/write，操作与文件类似。

FIFO必须显式删除（调用unlink），但fifo中保存的数据是进程相关的

示例

View Code

#include "stdio.h"
#include "stdlib.h"
#include "unistd.h"
#include "sys/types.h"
#include "sys/stat.h"
#include "fcntl.h"
#include "string.h"
#define MAXLINE 256
int  main(void)  
{
int rfd, wfd;
    pid_t pid;
char line[MAXLINE];

if (mkfifo("./fifo1", 0666) < 0)  
        {
                printf("mkfifo error");
        }

if ((pid = fork()) < 0) 
        {  
                printf("fork error"); 
    } 
else if (pid > 0) 
        {       
/* parent */
if((wfd = open("./fifo1", O_WRONLY)) > 0 )
                { 
                        write(wfd, "hello\n", 13);
                        close(wfd);
                } 
        }
else 
        {                /* child */
if((rfd = open("./fifo1", O_RDONLY)) > 0 )
                { 
int n = read(rfd, line, MAXLINE);
                        printf("%s", line);
                        close(rfd);
                }
        }
}