标签：pp int pipe av 进程 close

pipe

linux中的bash可以使用管道，如ls | sort | head -4。通过管道机制，我们能够进行输入和输出流的重定位，即前一个命令的输出就是下一个命令的输入，从而实现很多信息过滤的功能。

1. 创建pipe

int pps[2];			     // 管道文件描述符
int pipe(pipe)		// 创建管道

一般来说，管道创建以后，该进程的文件描述符3、4分别连接到pp[0]（pipe读取端）、pp[1]（pipe写入端）。这样我们可以从pipe[0]读取数据，也能向pipe[1]写入数据。

2. 父子进程通信

在父进程创建管道后，如果此时fork出一个子进程，子进程向当于是父进程的一个副本（只有少数数据是不一样的），子进程也拥有和父进程相同的管道，他们是共享此管道的。这样，父子进程具有可以通过pipe进行通信了。具体如下图：

PS: 当父子进程通信时，如果父进程写，子进程读，那必须关闭父进程的读端，关闭子进程的写端。具体原因见下文读写规则。

3. 读写规则

4. shell中pipe命令的实现

在shell中，类似ls | sort | head -4是如何实现的呢？当然是通过pipe，具体实现如下下图：

1. parent进程先创建pipe1，然后fork出cmd1进程。在cmd1进程中负责处理cmd，从stdin读取输入，将结果写入pipe1，结束进程cmd1
2. parent进程再创建pipe2，fork出cmd2进程。cmd2从pipe1中读取（因为parent和cmd2是父子进程，所以也是可以从pipe1中读取数据），写入pipe2，结束进程cmd2
3. parent进程再创建pipe3，fork出cmd3进程。cmd3从pipe2中读取，处理后写入stdout，结束进程cmd3
4. 结束parent进程

代码实现：

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

#define oops(x, m)	{perror(x); exit(m);}

void do_pipe(char *av[], int i, int cmdnum);

int main(int ac, char *av[])
{
	int i;

	if (ac < 3) {
		fprintf(stderr, "Usage: pipecmds cmd1 cmd2 ...\n");
		return -1;
	}
    
	do_pipe(av, 1, ac - 1);

	return 0;
}

/* purpose : 执行终端命令
 * details : 1. make a pipe 															<-----------
 *																								   |
 *			 2. fork --------------> child: close(p[0]), dup2(p[1], 1), close(p1), execlp 		   |
 *					|																			   |
 *					 --------------> parent: close(p[1]), dup2(p[0], 0), close(p0), 进一步递归 ------
 */
void do_pipe(char *av[], int i, int cmdnum)
{
	int pp[2];
	int pid;

	if (i > cmdnum)
		return;

	if (pipe(pp) == -1)
		oops("can't make pipe", 1);

	if ((pid = fork()) == -1) {
		oops("can't fork", 2);
	} else if (pid == 0) {
		/* child do cmds 
		   close read end, dup write end, close write end, execlp
		 */
		close(pp[0]);
		if (i < cmdnum)
			if (dup2(pp[1], 1) != 1) {
				oops("Child: can't dup2 pp[1]", 3);
			}
		close(pp[1]);
		execlp(av[i], av[i], NULL);
		oops(av[i], 4);
	} else if (pid > 0) {
		/* parent recursive 
		   close write end, dup read end, close read end, recursive !
		*/
		close(pp[1]);
		if (i < cmdnum)
			if (dup2(pp[0], 0) != 0) {
				oops("Parent: can't dup2 pp[0]", 3);
			}
		close(pp[0]);
		wait(NULL);

		do_pipe(av, i + 1, cmdnum);

	}

标签：pp,int,pipe,av,进程,close
来源： https://www.cnblogs.com/rogerg6/p/16582832.html

本站声明： 1. iCode9 技术分享网（下文简称本站）提供的所有内容，仅供技术学习、探讨和分享；
2. 关于本站的所有留言、评论、转载及引用，纯属内容发起人的个人观点，与本站观点和立场无关；
3. 关于本站的所有言论和文字，纯属内容发起人的个人观点，与本站观点和立场无关；
4. 本站文章均是网友提供，不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属；如您发现该文章侵犯了您的权益，可联系我们第一时间进行删除；
5. 本站为非盈利性的个人网站，所有内容不会用来进行牟利，也不会利用任何形式的广告来间接获益，纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。