Linux进程通信(System V)第一节------>管道pipe
来源:岁月联盟
编辑:exp
时间:2012-03-20
简介: 一.#include <unistd.h> int pipe(int fd[2]); //!>注意参数是fd[0]是读的文件描述符,fd[1]是用来写的文件描述符 一般用于 “父子进程” 之间的通信!因为pipe是没有标志的,所以只能在一个进程集中运作! “单向pipe”: 父进程创建好 pipe 后,同时通过 fork() 创建一个子进程,然后父进程就可以关闭自己这端的“读进程”,因为 父进程就是将数据写入子进程的,所以无须 “读”,然后子进程就关闭自己的“写”,这样就形成一个 “单向” 的 pipe。 “双向pie”:( 可以用于CS ) 创建两个pipe就可以了,其实也就是相当于加一个 “单向”pipe 二. 关于 fork函数 对于fork的返回值:对于父进程返回的是子进程的ID号(肯定是大于0的),对于子进程返回的是0所以可以通过 if( pid = fork() > 0 ) 和 if( pid == 0 )来判断是父进程还是子进程在执行 三. 其他 对于 pipe而言,创建 ok后,在子进程和父进程中都会有一个此管道(pipe)的读和写的接口!操作value是相同的fd[0]和fd[1] 对于 test.c 中的为例: 由于是多进程编程,那么对于test.c代码而言,应该是有“子进程”和“父进程”都可以执行的!也就是说在fork后程序就是分成两部分,主进程和子进程。 我们可以测试: 如果是printf("on ");那么可以输出两次 on,分别是父进程和子进程输出的,但是if是printf(" on /n");那么只输出一次。 原因:printf的机制是:遇到"/n"就会直接输出,if没有,那么只是储存在缓存中,然后一起输出。 所以if有"/n",那么就是父进程先让其输出了,那么在父进程的空间空就没有保存printf中的缓存数据了!!!所以子进程就没有继承到,所以就不会输出!!! 也就是说:父进程的printf 空间缓存区也被继承!!!!!!!!!!!!!!!!!!!!! getpid():获得本进程的ID getppid():获得父进程的ID 四.参考代码: //!>//!> 单向 pipe实例 //!> #include <stdlib.h>#include <unistd.h>#include <sys/types.h>#include <stdio.h> int g_num =0; //!> 全局变量:用来测试父进程和子进程的独立空间 //!> 我们可以知道全局变量在子进程和父进程中是有自己的独立空间的!int main(){ int n,fd[2]; //!> fd 是描述符 pid_tpid; //!> 保存的是创建的进程的 ID charline[100]; //!> 相当于是一个缓存 int num = 0; //!> 也是独立的~~~ printf(" on"); //!> ATTENTION printf(" on/n"); if( pipe( fd) < 0) //!> 此处就是创建pipe,成功则返回0,if失败则返回-1 { exit(0); } if( ( pid =fork() ) < 0) //!> 创建子进程 { exit(0); } else if( pid> 0 ) { close(fd[0]); write(fd[1],"I am your father.../n", 19); g_num++; num++; printf("/nFather g_num:%d num: %d/n", g_num,num); printf("/nMYID : %d Parent ID : %d /n", getpid(), getcpid()); } else //!> == 0 当前进程(也就是刚刚创建的子进程) { close( fd[1]); n = read(fd[0], line, 100 ); write(STDOUT_FILENO, line, n ); // g_num++; num++; printf("/nChild g_num:%d num: %d/n", g_num, num); printf("/nMYID : %d Parent ID : %d /n", getpid(), getppid()); } printf(" ok"); return0;} //!>//!> 双向 pipe 实例//!> #include <sys/types.h>#include <stdlib.h>#include <stdio.h>#include <unistd.h>#include <string.h> int main(){ int fd_1[2],fd_2[2]; //!> 双向 pipe 的 values、 charcData[100]; pid_tpid; if( pipe(fd_1 ) < 0) //!> create the pipe_1 { printf("/n创建第一个 pipe 失败!/n"); exit( 0); } if( pipe(fd_2 ) < 0) //!> create the pipe_2 { printf("/n创建第二个 pipe 失败!/n"); exit( 0); } if( ( pid =fork() ) < 0) //!> false to create a new process { printf("/n创建进程失败!/n"); exit( 0); } else if( pid== 0 ) //!> 也就是fork返回的子进程... { //!> 子进程也需要发送 data 到 pipe close(fd_2[0] ); char str[30]= "I am your child!"; write(fd_2[1], str, strlen( str )); //!> 第二个pipe是子进程发送data,父进程接受data //!> 子进程也需要接受父进程的 data close(fd_1[1] ); int n =read( fd_1[0], cData, 100); //!> 第一个pipe是父进程发送data,子进程接受data write(STDOUT_FILENO, cData, n ); } else //!> fork 返回的是子进程的ID,肯定是大于0的,所以此处执行的是父进程的code { //!> 父进程也需要发送 data 到 pipe close(fd_1[0] ); char str[30]= "I am your father!"; write(fd_1[1], str, strlen( str )); //!> 第二个pipe是子进程发送data,父进程接受data //!> 父进程也需要接受父进程的 data` close(fd_2[1] ); int n =read( fd_2[0], cData, 100); //!> 第一个pipe是父进程发送data,子进程接受data write(STDOUT_FILENO, cData, n ); } return0;} 摘自shanshanpt的专栏