父子进程间通信模型实现（popen）

 

0、FILE *popen(const char *command, const char *type);

popen 函数相当于做了以下几件事：

1、创建一个无名管道文件

2、 fork()

3、在子进程里， exec command

4、 在子进程里，

若 type == “r” ，  相当于进行：

int fd_new =  fopen("Pipe_Name",O_WRONLY); 
dup2(0,fd_new);

若 type == “w” ，  相当于进行：

int fd_new =  fopen("Pipe_Name",O_RDONLY); 
dup2(0,fd_new);

5、返回值 为 对管道文件 type类型操作的 文件指针

 

1、以读的方式popen

P1中：

fp_in = popen(cmd, "r") ;

popen的返回值  fp_in 文件指针 是管道文件的读文件指针

P2中：

popen（，“r”）把P2中的标准输出重定向到 管道文件 ，printf 相当于向管道文件 fputs

printf("%s
", src );

具体代码：

p1：

#include<stdio.h>
#include<string.h>
#include<stdlib.h>
int main(int argc, char* argv[])// ./my_reverse
{    
    printf("pid: %d
", getpid());
    FILE* fp_in ;
    char cmd[1024] ;
    char str[1024] ;
    while(memset(str, 0, 1024), fgets(str, 1024, stdin) != NULL)
    {
        memset(cmd, 0, 1024);
        sprintf(cmd, "%s %s", argv[1], str);
        fp_in = popen(cmd, "r") ;
        if(fp_in == NULL)
        {
            perror("popen");
            exit(1);
        }
        memset(str, 0, 1024) ;
        fscanf( fp_in, "%s", str );
        printf("res: %s
", str);

    }
    return 0 ;
}

p2：

#include<stdio.h>
#include<string.h>
#include<stdlib.h>
void handle(char* str)
{
    int bg, end ;
    int tmp ;
    bg = 0; 
    end = strlen(str) - 1;
    while(bg < end)
    {
        tmp = str[bg] ;
        str[bg] = str[end] ;
        str[end] = tmp ;
        bg ++ ;
        end -- ;
    }
}
int main(int argc, char* argv[])//argv[1]
{    
    char src[1024] ;
    strcpy(src, argv[1]);
    handle(src);
    printf("%s
", src );
    return 0 ;
}

2、以写的方式popen

P1中：

fp_out = popen(argv[1], "w") ;

popen 的返回值 为 管道文件的 写文件指针

P2中：

popen（，“w”）把P2中的标准输入重定向到 管道文件 ，gets 相当于从管道文件 fgets

gets(src) 

具体代码：

p1：

#include<stdio.h>
#include<string.h>
#include<stdlib.h>
int main(int argc, char* argv[])// ./my_reverse
{    
    printf("pid: %d
", getpid());
    FILE* fp_out ;
    char cmd[1024] ;
    char str[1024] ;
    fp_out = popen(argv[1], "w") ;
    if(fp_out == NULL)
    {
        perror("popen");
        exit(1);
    }
    while(memset(str, 0, 1024), fgets(str, 1024, stdin) != NULL)
    {
        fputs(str, fp_out);
        fflush(fp_out);

    }
    pclose(fp_out);
    return 0 ;
}

P2：

#include<stdio.h>
#include<string.h>
#include<stdlib.h>
void handle(char* str)
{
    int bg, end ;
    int tmp ;
    bg = 0; 
    end = strlen(str) - 1;
    while(bg < end)
    {
        tmp = str[bg] ;
        str[bg] = str[end] ;
        str[end] = tmp ;
        bg ++ ;
        end -- ;
    }
}
int main(int argc, char* argv[])
{    
    char src[1024] ;
    while(memset(src, 0, 1024), gets(src) != NULL )
    {
        handle(src);
        printf("pid: %d  %s
", getpid() ,src );
    }
    return 0 ;
}