dup重定向匿名管道父进程子进程的一些坑包含execvp调用ffmepg

本文说明再用dup做重定向的时候遇到的一些坑做一些总结。

1：FFMPEG的所有输出信息,都为错误输出流,用STDOUT_FILENO是捕获不到任何消息，必须用STDERR_FILENO,这里是个大坑;

2：子进程pid == 0 这一段代码走完返回后还会将主进程调用本函数之后的代码走一遍；

3：循环sleep要刷新fflush(stdout);才能在标准输出中输出到管道否则失败；

4：传入execvp的第二个参数argv类型为,char * execargv[LVSM_DEFAULT_STRING_LEN]；当把前面的各个参数写入后 ，必须这样写execargv[pos] = NULL;否则失败，不能sprintf(execargv[pos],"%s",(char*)(0));或者，sprintf(execargv[pos],"%d",0);

5：代码中有匿名管道改成非阻塞的，否则read会卡住不返回。

下面是具体的代码对比看下：

//main.cpp

#include <unistd.h>  
#include <stdio.h>  
#include <sys/wait.h>  
#include <sys/prctl.h>
#include <signal.h>
#include <fcntl.h>
#include <string.h>
#include <memory.h>
#include<stdlib.h>

int child_processing_transcode(int pipe_id[2],int * pchild_pid, char *execpathname,char * execargv[])
{
	int ret = 0;
	int pid = 0;                            //创建子进程的pid

	pid = fork();                           //第一次返回就是子进程的pid
	*pchild_pid = pid;                      //拷贝子进程的pid

	if(pid< 0)
	{  
		printf("error fork\n");
		*pchild_pid = -1;
		return -1;
	}  
	else if(pid == 0)                       //子进程负责写  
	{  
		prctl(PR_SET_PDEATHSIG, SIGKILL, 0, 0, 0);  //Linux下让父进程结束后，子进程自动结束

		close(pipe_id[0]);                  //关闭匿名管道读
		close(STDOUT_FILENO);               //关闭标准输出
		close(STDERR_FILENO);               //关闭标准错误输出
		dup2(pipe_id[1], STDOUT_FILENO);    //将标准输出的输出重定向到匿名管道写中STDIN_FILENO == 0,STDOUT_FILENO == 1,STDERR_FILENO == 2;
		dup2(pipe_id[1], STDERR_FILENO);    //FFMPEG的所有输出信息,都为错误输出流,用STDOUT_FILENO是捕获不到任何消息，必须用STDERR_FILENO,这里是个大坑;

		//char *argv[] = {(char *)"ls",(char *)"-l",(char *)"/etc",(char *)0}; 
		//execvp("ls",argv);

		//printf ("Hello\n");
		//printf ("123\n");
		//printf ("ooppqq\n");

		//执行外挂的ffmpeg
		execvp(execpathname,execargv);
		//这有个大坑，子进程pid == 0 这一段代码走完返回后还会将主进程调用本函数之后的代码走一遍。
		//循环sleep要刷新fflush(stdout);才能在标准输出中输出到管道否则失败.
		exit(0);               
	}  
	else                                    //父进程负责读  
	{  
		int father_pid = getpid();
		printf("father_pid ;%d\n",father_pid);
		printf("*pchild_pid : %d\n",*pchild_pid); 
		close(pipe_id[1]);                  //关闭匿名管道的写
	}
	return ret;
}


int main()
{
	int ret = 0;
	int npipe_id[2] = {0};                 //匿名管道，读npipe_id[0],写npipe_id[1]  
	int nchild_pid = 0;                    //子进程pid
	int nreadlen = 0;                      //管道中读取的内存长度
	char sreadbuf[10240] = {0};            //管道中读取的内存

	if(pipe(npipe_id) < 0)  
	{
		printf("error pipe\n");
		return 0;
	}

	//将读取fd设置成无阻塞
	int flag = fcntl(npipe_id[0],F_GETFL,0);
	flag |= O_NONBLOCK;
	if(fcntl(npipe_id[0],F_SETFL,flag) < 0)
	{   
		perror("error fcntl(npipe_id[0],F_SETFL,flag)");   
		return 0;
	}

	//如果文件存在删除文件
	remove("out.flv");

	//转码 
	//ffmpeg -i 22.flv -acodec copy -vcodec h264 -s 352x288  -f flv out.flv
	//char execpathname[] = {"ffmpeg"};
	//char * execargv[] ={(char *)"ffmpeg",
	//	(char *)"-i",(char *)"22.flv",
	//	(char *)"-acodec", (char *)"copy", 
	//	(char *)"-vcodec", (char *)"h264", 
	//	(char *)"-s", (char *)"352x288"  ,(char *)"-f" ,(char *)"flv", 
	//	(char *)"out.flv",0};

	//遮标
	char execpathname[] = {"cover_standard"};
	char * execargv[] ={(char *)"cover_standard",0};

	ret = child_processing_transcode(npipe_id,&nchild_pid,execpathname,execargv);
	printf("nchild_pid : %d\n",nchild_pid);


	usleep(1000* 1000);

	//第一次调用waitpid时：此时尚未有子进程，所以waitpid出错，返回-1；
	//第二次调用waitpid时：此时有子进程，但子进程尚未结束，由于waitpid设置为非阻塞的，所以waitpid返回0；
	//第三次调用waitpid时：此时有子进程，所以waitpid返回子进程id；
	int stat = 0;
	int wpid = waitpid(nchild_pid, &stat, WNOHANG);   //pid=-1 等待任何子进程,相当于 wait()。 //设置成WNOHANG非阻塞父进程状态
	printf("first-pchild_pid: %d\n", wpid);  

	for (;;)
	{
		nreadlen = read(npipe_id[0],sreadbuf,10240); 
		if (nreadlen > 0)
		{
			printf( "*********************************[nreadlen] : [%d] %s\n",nreadlen,sreadbuf); 
		}
		memset(sreadbuf,0,10240);

		usleep(1000 * 1000);
		wpid = waitpid(-1, &stat, WNOHANG);   //pid=-1 等待任何子进程,相当于 wait()。 //设置成WNOHANG非阻塞父进程状态
		printf("second-pchild_pid: %d\n", wpid); 
		//printf("getpid : %d\n",getpid());
	}

	//如果子进程执行完关闭
	close( npipe_id[0] );  
	close( npipe_id[1] ); 
	//杀死子进程
	kill(nchild_pid, SIGKILL);    

	return 1;
}

#include <stdio.h>
#include <unistd.h> 

int main()
{
	int ret = 0;

	for (int i = 0; i <100; i++)
	{
		printf("*****************cover_standard i : %d\n",i);
		usleep(1000*1000);
		//循环sleep要刷新fflush(stdout);才能在标准输出中输出到管道否则失败.
		fflush(stdout);
	}
	return 1;
}

如有错误请指正：

交流请加QQ群：62054820
QQ：379969650.