开发者社区> ghost丶桃子> 正文

Linux 进程间通信-管道

简介:
+关注继续查看

  进程是一个独立的资源分配单位,不同进程之间的资源是相互独立的,没有关联,不能在一个进程中直接访问另一个进程中的资源。但是,进程不是孤立的,不同的进程之间需要信息的交换以及状态的传递,因此需要进程间数据传递、同步与异步的机制。

  此篇博文记录管道。

管道pipe

  管道是进程间通信的主要手段之一。一个管道实际上就是个只存在于内存中的文件,对这个文件的操作要通过两个已经打开文件进行,它们分别代表管道的两端。管道是一种特殊的文件,它不属于某一种文件系统,而是一种独立的文件系统,有其自己的数据结构。根据管道的适用范围将其分为:无名管道和命名管道。

管道分类

●     无名管道

  主要用于父进程与子进程之间,或者两个兄弟进程之间。在linux系统中可以通过系统调用建立起一个单向的通信管道,且这种关系只能由父进程来建立。因此,每个管道都是单向的,当需要双向通信时就需要建立起两个管道。管道两端的进程均将该管道看做一个文件,一个进程负责往管道中写内容,而另一个从管道中读取。这种传输遵循“先入先出”(FIFO)的规则。

●     命名管道

  命名管道是为了解决无名管道只能用于近亲进程之间通信的缺陷而设计的。命名管道是建立在实际的磁盘介质或文件系统(而不是只存在于内存中)上有自己名字的文件,任何进程可以在任何时间通过文件名或路径名与该文件建立联系。为了实现命名管道,引入了一种新的文件类型——FIFO文件(遵循先进先出的原则)。实现一个命名管道实际上就是实现一个FIFO文件。命名管道一旦建立,之后它的读、写以及关闭操作都与普通管道完全相同。虽然FIFO文件的inode节点在磁盘上,但是仅是一个节点而已,文件的数据还是存在于内存缓冲页面中,和普通管道相同。

管道的读写

  写入管道的数据按到达次序排列。如果管道满,则对管道的写被阻塞,直到管道的数据被读操作读取。对于写操作,如果一次write调用写的数据量小于管道容量,则写必须一次完成,即如果管道所剩余的容量不够,write被阻塞直到管道的剩余容量可以一次写完为止。如果write调用写的数据量大于管道容量,则写操作分多次完成。如果用fcntl设置管道写端口为非阻塞方式,则管道满不会阻塞写,而只是对写返回0。

  读操作按数据到达的顺序读取数据。已经被读取的数据在管道内不再存在,这意味着数据在管道中不能重复利用。如果管道为空,且管道的写端口是打开状态,则读操作被阻塞直到有数据写入为止。一次read调用,如果管道中的数据量不够read指定的数量,则按实际的数量读取,并对read返回实际数量值。如果读端口使用fcntl设置了非阻塞方式,则当管道为空时,read调用返回0。

  如果管道的读端口关闭,那么在该管道上的发出写操作调用的进程将接收到一个SIGPIPE信号。关闭写端口是给读端口一个文件结束符的唯一方法。对于写端口关闭后,在该管道上的read调用将返回0。

无名管道

  用于父进程与子进程之间,或者两个兄弟进程之间。

函数说明

复制代码
/* 管道 */

#include <unistd.h>

/* 建立管道 */
int pipe(int filedes[2]);

/*
filedes[0]为管道里的读取端    
filedes[1]为管道里的写入端

返回值: 成功返回-1,错误返回-1,错误存于errno中

错误代码:
EMFILE 进程已用完文件描述词最大量
ENFILE 系统已无文件描述符可用
EFAULT 参数filedes数组地址不合法
*/

/* 阻塞设置 */
fcntl(filedes[0], F_SETFL, O_NONBLOCK);
fcntl(filedes[1], F_SETFL, O_NONBLOCK);

/* 读写 */
read(fd, buf, sizeof(buf));
write(fd, buf, sizeof(buf));
复制代码

实例

复制代码
#include <unistd.h>
#include <stdio.h>

int main()
{
    int   p[2];
    char  buf[20];
    char  buf0[20];
    pid_t pid;

    strcpy(buf,"Hello World!");

    pipe(p);

    if((pid = fork()) > 0){
        printf("This is father process.\n\n");
        write(p[1], buf, strlen(buf));
        close(p[1]);
        close(p[2]);
    }
    else{
        printf("This is child process.\n");
        read(p[0], buf0, sizeof(buf0));
        printf("%s\n", buf0);
        close(p[0]);
        close(p[1]);
    }

    return 0;
}
复制代码

 命名管道

  能用于近亲进程之间通信。

函数说明

复制代码
/* 命名管道 */

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

/* 建立管道 */
int mkfifo(const  char  *  pathname, mode_t mode);
/*
pathname 路径,创建管道的位置
mode        打开函数open中的Mode
*/

/* 打开管道 */
int open(const char *pathname,int oflag,... /* mode_t mode */);
/*
mode 可选:O_RDONLY | O_WRONLY | O_NONBLOC
*/

/* 读写 */
int read(int fd, void *buf, int nbyte)
int write(int fd, void *buf, int nbyte)

/* 关闭 */
close(int handle)
复制代码

实例

复制代码
/* fifo_write.c */
#include <sys/types.h>
#include <sys/stat.h>
#include <string.h>
#include <stdio.h>
#include <unistd.h>
#include <fcntl.h>

int main()
{
    const char* pathname = "m_fifo";
    int pipe_fd = -1;
    int bytes;
    char buf[20];

    strcpy(buf, "hello world!");

    mkfifo(pathname, 0777);

    pipe_fd = open(pathname, O_WRONLY);

    printf("Process %d result %d\n", getpid(), pipe_fd);

    write(pipe_fd, buf, strlen(buf));

    printf("Process %d finished!\n", getpid());

    return 0;
}
复制代码
复制代码
#include <unistd.h>
#include <stdio.h>
#include <sys/types.h>
#include <sys/stat.h>
#include <fcntl.h>

int main()
{
    const char* pathname = "m_fifo";
    char buf[20];
    int pipe_fd;
    
    pipe_fd = open(pathname, O_RDONLY);

    printf("Process %d result %d\n", getpid(), pipe_fd);

    read(pipe_fd, buf, sizeof(buf));

    close(pipe_fd);

    printf("Process %d finished,\n read content: %s \n", getpid(), buf);

    return 0;
}
复制代码

参考

http://blog.csdn.net/myarrow/article/details/9037135

http://blog.sina.com.cn/s/blog_4e9440910100yihb.html

http://blog.sina.com.cn/s/blog_67b7d7e401018dvz.html

http://blog.csdn.net/guxch/article/details/6828452

知识共享许可协议
本作品采用知识共享署名-非商业性使用-相同方式共享 3.0 未本地化版本许可协议进行许可。欢迎转载,请注明出处:
转载自:cococo点点 http://www.cnblogs.com/coder2012

知识共享许可协议
本文 由 cococo点点 创作,采用 知识共享 署名-非商业性使用-相同方式共享 3.0 中国大陆 许可协议进行许可。欢迎转载,请注明出处:
转载自:cococo点点 http://www.cnblogs.com/coder2012


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

相关文章
阿里云ECS云服务器初始化设置教程方法
阿里云ECS云服务器初始化是指将云服务器系统恢复到最初状态的过程,阿里云的服务器初始化是通过更换系统盘来实现的,是免费的,阿里云百科网分享服务器初始化教程: 服务器初始化教程方法 本文的服务器初始化是指将ECS云服务器系统恢复到最初状态,服务器中的数据也会被清空,所以初始化之前一定要先备份好。
14237 0
阿里云服务器如何登录?阿里云服务器的三种登录方法
购买阿里云ECS云服务器后如何登录?场景不同,阿里云优惠总结大概有三种登录方式: 登录到ECS云服务器控制台 在ECS云服务器控制台用户可以更改密码、更换系.
28495 0
Linux进程通信学习笔记
Linux进程通信学习笔记
2458 0
阿里云服务器端口号设置
阿里云服务器初级使用者可能面临的问题之一. 使用tomcat或者其他服务器软件设置端口号后,比如 一些不是默认的, mysql的 3306, mssql的1433,有时候打不开网页, 原因是没有在ecs安全组去设置这个端口号. 解决: 点击ecs下网络和安全下的安全组 在弹出的安全组中,如果没有就新建安全组,然后点击配置规则 最后如上图点击添加...或快速创建.   have fun!  将编程看作是一门艺术,而不单单是个技术。
20372 0
阿里云服务器怎么设置密码?怎么停机?怎么重启服务器?
如果在创建实例时没有设置密码,或者密码丢失,您可以在控制台上重新设置实例的登录密码。本文仅描述如何在 ECS 管理控制台上修改实例登录密码。
23547 0
使用OpenApi弹性释放和设置云服务器ECS释放
云服务器ECS的一个重要特性就是按需创建资源。您可以在业务高峰期按需弹性的自定义规则进行资源创建,在完成业务计算的时候释放资源。本篇将提供几个Tips帮助您更加容易和自动化的完成云服务器的释放和弹性设置。
20890 0
阿里云服务器如何登录?阿里云服务器的三种登录方法
购买阿里云ECS云服务器后如何登录?场景不同,云吞铺子总结大概有三种登录方式: 登录到ECS云服务器控制台 在ECS云服务器控制台用户可以更改密码、更换系统盘、创建快照、配置安全组等操作如何登录ECS云服务器控制台? 1、先登录到阿里云ECS服务器控制台 2、点击顶部的“控制台” 3、通过左侧栏,切换到“云服务器ECS”即可,如下图所示 通过ECS控制台的远程连接来登录到云服务器 阿里云ECS云服务器自带远程连接功能,使用该功能可以登录到云服务器,简单且方便,如下图:点击“远程连接”,第一次连接会自动生成6位数字密码,输入密码即可登录到云服务器上。
36379 0
1955
文章
0
问答
文章排行榜
最热
最新
相关电子书
更多
JS零基础入门教程(上册)
立即下载
性能优化方法论
立即下载
手把手学习日志服务SLS,云启实验室实战指南
立即下载