首页
学习
活动
专区
工具
TVP
发布
精选内容/技术社群/优惠产品,尽在小程序
立即前往

Linux进程间通信(上)之管道、消息队列实践

管道Linux支持的最初Unix IPC形式之一,管道管道之间通信其实就是一个文件,但它不是一个普通的文件,它不属于某种文件系统,而是自立门户,单独构成一种文件系统而且只存在内存中。...我们可以通过发送消息来避免命名管道的同步和阻塞问题。但是消息队列与命名管道一样,每个数据块都有一个最大长度的限制。...int msgsnd(int msqid, const void *msgp, size_t msgsz, int msgflg); 将发送的消息存储在msgp指向的msgbuf结构中,消息大小由msgsz...造成msgsnd()等待的条件有两种:当前消息的大小与当前消息队列中的字节数之和超过了消息队列的总容量;当前消息队列的消息数不小于消息队列的总容量,此时,虽然消息队列中的消息数目并不多,但基本上都只有一个字节...消息队列克服了信号传递信息少、管道只能承载无格式字节流以及缓冲区大小受限等缺点,相对于管道通信有很大的改观,而且消息队列对数据的顺序处理也是非常有条理性的不会产生混杂性。

2.3K10

Linux 下的进程间通信:使用管道和消息队列

本篇是 Linux 下进程间通信(IPC)系列的第二篇文章。第一篇文章 聚焦于通过共享文件和共享内存段这样的共享存储来进行 IPC。这篇文件的重点将转向管道,它是连接需要通信的进程之间的通道。...管道有两种类型,命名管道和无名管道,都可以交互式的在命令行或程序中使用它们;相关的例子在下面展示。这篇文章也将介绍内存队列,尽管它们有些过时了,但它们不应该受这样的待遇。...自然地我们也会考虑基于管道的 IPC 的安全并发问题,这个也将在本文中提及。针对管道和内存队列的例子将会使用 POSIX 推荐使用的 API,POSIX 的一个核心目标就是线程安全。...在 Linux 系统中, PIPE_BUF 的大小是 4096 字节。对于管道我更喜欢只有一个写入方和一个读取方,从而绕过这个问题。...输出也显示消息队列是持久的,即便 sender 进程在完成创建队列、向队列写数据、然后退出的整个过程后,该队列仍然存在。

1.2K20
  • 您找到你想要的搜索结果了吗?
    是的
    没有找到

    Linux: linux 匿名管道

    相信很多在linux平台工作的童鞋, 都很熟悉管道符 '|', 通过它, 我们能够很灵活的将几种不同的命令协同起来完成一件任务.就好像下面的命令: echo 123 | awk '{print $0+123...1: print '1111' * 4096 time.sleep(3) print '2222' * 4096 time.sleep(3) # 方式2: 手动刷入写队列.....然而管道也是有大小的~ 具体可以去看posix标准, 所以我们得出结论是: 只要COMMAND1的输出写入管道的写端(不管是缓冲区满还是手动flush), COMMAND2都将立刻得到数据并且马上处理...,则read返回0 如果所有管道读端对应的文件描述符被关闭,则write操作会产生信号SIGPIPE 当要写入的数据量不大于PIPE_BUF时,linux将保证写入的原子性。...当要写入的数据量大于PIPE_BUF时,linux将不再保证写入的原子性。

    34K41

    Linux】进程间通信 --- 管道 共享内存 消息队列 信号量

    进程等待管道文件,PCB会被放在文件的等待队列中,有数据之后会重新投入运行队列 ssize_t s = read(fds[0], buffer, sizeof buffer - 1);...进程等待管道文件,此时PCB会被放在管道文件的等待队列中,当管道中重新出现数据时,PCB会被重新投入到运行队列中,将数据从内核拷贝到用户层,只要没有数据,该进程就会一直阻塞等待 如果一直不写入,则父进程一直阻塞等待...3.命名管道 3.1 命名管道实现IPC的原理(文件名标定唯一性的管道文件,linux文件系统只是一棵多叉树,不是森林,不允许存在同名文件。) 1....下面是不能存在两个文件名相同的文件的,否则在查找文件时,linux是不知道该去哪条路径找这个文件的)这也是问什么叫做命名管道的原因,我们是通过命名+路径来标识当前这个唯一性的命名管道文件的!...所以不是linux抄袭C++的多态,而是先有的linux后有的C++,linux才是爹。

    1.4K40

    Linux管道命令

    grep [-cinv] [--color=auto] '关键词' 待查找的文件名 -c:统计关键词出现的次数 -i:关键词忽略大小写 -n:输出行号 -v:反向选择,即查找不包含该关键词的行 --color...sort [-参数] 文件 -t:指定分隔符 -k:选取分隔后的第几个字段进行排序 -f:排序时忽略选取字段的大小写 -b:去除选取字段前的空格 -M:将选取的字段按照月份来排序(前提是选取字段就是月份...uniq [-参数] -i:忽略大小写 -c:进行重复行的统计 3.4.2 uniq使用方式 该命令只能用于管道,如统计当前系统所有用户的登录次数: last | cut -d ' ' -f 1 | uniq...3.7.2 join命令的用法 join [-参数] 文件1 文件2 -t:两个文件的字段分隔符 -1:第一个文件的字段 -2:第二个文件的字段 -i:忽略选取字段的大小写 3.8 切割文件:split...3.8.2 命令用法 split [-参数] 大文件 小文件名字前缀 -b:指定小文件的大小,需要加上单位:b、k、m -l:指定每个小文件中的行数。

    4.5K70

    linux——管道详解

    从本质上说,管道也是一种文件,但它又和一般的文件有所不同,管道可以克服使用文件进行通信的两个问题,具体表现为: 限制管道大小。实际上,管道是一个固定大小的缓冲区。...在Linux中,该缓冲区的大小为1页,即4K字节,使得它的大小不象文件那样不加检验地增长。...当然,内核必须利用一定的机制同步对管道的访问,为此,内核使用了锁、等待队列和信号。      ...但是,进程可以在没有数据或内存被锁定时立即返回错误信息,而不是阻塞该进程,这依赖于文件或管道的打开模式。反之,进程可 以休眠在索引节点的等待队列中等待写入进程写入数据。...errno=%d",errno); return 1; } Linux 管道对阻塞之前一次写操作的大小有限制。

    3K20

    Linux】进程间通信>管道&&共享内存&&消息队列&&信号量详解

    System V进程间通信 POSIX进程间通信 1.3 进程间通信分类 1.3.1 管道 匿名管道pipe 命名管道 1.3.2 System V IPC System V 消息队列...System V 共享内存 System V 信号量 1.3.3 POSIX IPC 消息队列 共享内存 信号量 互斥量 条件变量 读写锁 2.管道 2.1 什么是管道 管道是Unix...管道的使用和文件一致,迎合了“Linux一切皆文件思想” #include #include #include #include <errno.h...当要写入的数据量不大于PIPE_BUF时,linux将保证写入的原子性 6....当要写入的数据量大于PIPE_BUF时,linux将不再保证写入的原子性 2.2.8 匿名管道特点 只能用于具有共同祖先的进程(具有亲缘关系的进程)之间进行通信;通常,一个管道由一个进程创建,然后该进程调用

    14210

    数组实现循环队列(增设队列大小size)

    一、前言利用数组实现循环队列,重点要解决的问题有三个:1.如何实现循环?由于数组大小k是确定的,要实现队列循环就需要让数组下标循环,利用两个下标front、back分别指向首元素和尾元素的下一个位置。...两种解决方法:一是:循环队列结构中新增队列大小 size ,当size=0且front = back时,队列为空;当size≠0且front = back时,队列为满。...本文仅讲解方法一,方法二详解:数组实现循环队列(新增一个空间)-CSDN博客二、循环队列的结构定义循环队列的结构中包含数组、头指针、尾指针、队列容量、队列大小队列大小用于区分队列空与满的情况)//方法一...back;//尾指针,指向队尾元素的下一个位置 int size;//队列大小 int k;//队列容量} MyCircularQueue;三、循环队列的创建及其初始化为循环队列动态申请一个内存空间...,再将头指针、尾指针、队列大小都初始化为0,队列容量为k//方法一//循环队列创建及其初始化MyCircularQueue* myCircularQueueCreate(int k) { MyCircularQueue

    16710

    Linux进程通信——管道

    管道 进程通信概念 管道 匿名管道 创建匿名管道的过程 管道读写的特性 管道本身的特征 基于管道的进程池设计 命名管道 让两个无血缘关系的进程通信 进程通信概念 什么是进程通信 首先我们清楚,进程是具有独立性的...这说明如果管道没有数据了,读端在读,默认会直接阻塞当前正在读取的进程,只有管道有数据,操作系统识别到,读端才会去读取数据。 2. 管道是一个固定大小的缓冲区。...endl; } close(fds[1]); n = waitpid(id,nullptr,0); assert(n == id); return 0; } 管道是按照指定大小读取的...管道本身的特征 1.管道的生命周期是进程的生命周期 2.管道可以用来进行具有血缘关系的进程之间进行通信,常用于父子通信。...这个就是命名管道,P开头。 注意:这里大小都没变。 本来应该打印在左侧的通过管道文件传到了右边。此时这里就完成了命令行式的打印。 但是这里还是大小不变。这是为什么呢?

    4K70

    Linux进程通信 管道

    简介 管道是Unix系统IPC的最古老形式,所有Unix系统都提供这种形式。管道有以下两种局限性: (1)历史上,通信方式为半双工。现在某些系统提供全双工管道。...(2)管道只能在具有公共祖先的两个进程之间使用。通常,一个管道由一个进程创建,在进程调用fork后,这个管道就能在父进程和子进程之间使用了。(FIFO无此局限)。       ...--《Unix环境高级编程》 通俗理解: Linux管道通信,通讯方式正如其名一样,如同一个大管道,一端流入,一端流出。...PIPE PIPE是一种半双工管道,其中,fd[1]用来向管道写入数据,fd[0]用来从管道读出数据。若两个进程需要利用PIPE通信,就要保证一个进程使用fd[0],另一个进程使用fd[1]。...Code: //参考Linux man手册 #include #include #include #include <stdlib.h

    3.1K10

    Linux管道那些事儿

    管道的本质是内核维护了一块缓冲区与管道文件相关联,对管道文件的操作,被内核转换成对这块缓冲区内存的操作。...Linux下创建管道函数: int pipe(int pipefd[2]) 成功调用pipe函数之后,会返回两个打开的文件描述符,一个是管道的读取端描述符pipefd[0],另一个是管道的写入端描述符pipefd...管道没有文件名与之关联,因此程序没有选择,只能通过文件描述符来访问管道,只有那些能看到这两个文件描述符的进程才能够使用管道。如果进程执行了fork操作,那么管道就变成如下所示: ?...单向使用管道,也就是说,如果没有用到管道的进程应该尽早释放管道文件fd,这么做不仅仅是为了让数据的流向更加清晰,也不仅仅是为了节省文件描述符,更重要的原因是:关闭未使用的管道文件描述符对管道的正确使用影响重大...当所有的读取端和写入端都关闭后,管道才能被销毁。 管道的本质是一片内存区域,默认大小是65536字节,不过可以调用fcntl来获取和修改这个值的大小

    2.7K50

    Linux管道扩展 — 开始使用命名管道

    命名管道的功能实现 1 命名管道的原理 2 代码实现 2.1 系统调用 2.2 命名管道的封装 2.3 开始使用 3回归概念 Thanks♪(・ω・)ノ谢谢阅读!!! 下一篇文章见!!!...1 命名管道的原理 命名管道时进程间通信的一种,那么原理也就是类似的:先让不同的进程看到同一份(操作系统)资源(“一段内存”)。 匿名管道是通过父子进程的继承关系来满足:父子进程可以看到同一段内存!...这个文件就是命名管道!!!...2.2 命名管道的封装 首先我们来认识一下创建管道的系统调用: MKFIFO(3) Linux...接下来我们进行打开文件函数的书写: 首先,命名管道是文件,打开文件需要open接口,管理管道由操作者来控制。

    8010

    聊聊 Linux 的匿名管道

    相信很多在linux平台工作的童鞋, 都很熟悉管道符 '|', 通过它, 我们能够很灵活的将几种不同的命令协同起来完成一件任务.就好像下面的命令: echo 123 | awk '{print $0+...1: print '1111' * 4096 time.sleep(3) print '2222' * 4096 time.sleep(3) # 方式2: 手动刷入写队列.....然而管道也是有大小的~ 具体可以去看posix标准, 所以我们得出结论是: 只要COMMAND1的输出写入管道的写端(不管是缓冲区满还是手动flush), COMMAND2都将立刻得到数据并且马上处理...,则read返回0 如果所有管道读端对应的文件描述符被关闭,则write操作会产生信号SIGPIPE 当要写入的数据量不大于PIPE_BUF时,linux将保证写入的原子性。...当要写入的数据量大于PIPE_BUF时,linux将不再保证写入的原子性。

    2.6K20

    Linux好用的管道命令

    Linux好用的管道命令 1. 选取命令 grep cut「分割」 2. 排序命令 sort wc uniq 3. 划分命令 split 4. 参数代换xargs 5....-i 或 --ignore-case : 忽略字符大小写的差别。 -l 或 --file-with-matches : 列出文件内容符合指定的样式的文件名称。...-f 【忽略大小写】排序时,将小写字母视为大写字母。 -i 排序时,除了040至176之间的ASCII字符外,忽略其他的字符。 -m 将几个排序好的文件进行合并。...-n 依照数值的大小排序(默认是以文字形式排序的)。 -u 意味着是唯一的(unique),输出的结果是去完重了的。(仅出现一行代表) -o 将排序后的结果存入指定的文件。...9)直接修改文件内容(危险动作) sed可以直接修改文件的内容,不必使用管道命令或数据流重导向! 不过,由于这个动作会直接修改到原始的文件,所以请你千万不要随便拿系统配置来测试!

    9.3K20

    linux 命名管道实例详解

    linux进程间通信——命名管道 FIFO(命名管道)不同于匿名管道之处在于它提供⼀个路径名与之关联,以FIFO的⽂件形式存储于⽂件系统中。...命名管道是⼀个设备⽂件,因此,即使进程与创建FIFO的进程不存在亲缘关系,只要可以访问该路径,就能够通过FIFO相互通信。...值得注意的是,FIFO(first input first output)总是按照先进先出的原则⼯作,第⼀个被写⼊的数据将⾸先从管道中读出。 创建命名管道的系统函数有两个:mknod和mkfifo。...:mod为创建的命名管道的模式,指明其存取权限;dev为设备值,该值取决于⽂件创建的种类,它只在创建设备⽂件时才会⽤到。...下⾯使⽤mknod函数创建了⼀个命名管道: umask(0); if (mknod("/tmp/fifo",S_IFIFO | 0666) == -1) { perror("mkfifo error

    4K21

    Linux命名管道及函数

    管道(pipe)应用的一大局限是没有名字,只能用于具有亲缘关系进程之间的通信。而命名管道,也称FIFO,实质是一种文件类型,通过FIFO可以用于任何两个进程间的通信。...命名管道的创建 命令方式 在shell中可以使用mkfifo命令创建一个命名管道,格式为: mkfifo [option] name 其中option选项用于选择创建FIFO的模式,使用形式为-m mode...函数方式 FIFO管道可通过mkfifo()函数创建,函数原型为: #include #include int mkfifo(const char...编程示例 创建一个命名管道,create_FIFO.c: #include #include #include #include...命名管道的读写 一般的文件I/O函数均可用于FIFO操作,如open、close、read、write等,若要删除一个命名管道,则使用系统调用unlink。

    2.7K10

    Linux匿名管道及实例

    匿名管道,也称管道,是Linux下最常见的进程间通信方式之一。匿名管道在系统中没有实名,它只是进程的一种资源,会随着进程的结束而被系统清除。...管道的创建与关闭 Linux中使用pipe()函数创建一个匿名管道,其函数原型为: #include int pipe(int fd[2]); 创建成功返回0,出错返回1。...进程间管道的读写 单独对一个进程进行管道的读写是没有实际意义的,管道的应用体现在父子进程或兄弟进程之间的通信。...上述程序中父进程分别建立了两个子进程,在子进程1中关闭了管道的读出端,在子进程2中关闭了管道的输入端,并在父进程中关闭了管道的两端,从而构成了从子进程1到子进程2的管道。...参考:《精通Linux C编程》- 程国钢 附:fork()函数的使用示例,参考:https://blog.csdn.net/jason314/article/details/5640969 #include

    2.3K30
    领券