實(shí)驗(yàn)9進(jìn)程間管道通信實(shí)驗(yàn)

1、試驗(yàn)9 進(jìn)程間管道通信實(shí)驗(yàn)學(xué)生姓名： 李亞軍 學(xué) 號(hào)： 6100412196 專業(yè)班級(jí)： 卓越計(jì)科121班 1實(shí)驗(yàn)?zāi)康耐ㄟ^(guò)編寫有名管道多路通信實(shí)驗(yàn)，讀者可進(jìn)一步掌握管道的創(chuàng)建、讀寫等操作，同時(shí)，也復(fù)習(xí)使用select()函數(shù)實(shí)現(xiàn)管道的通信。2實(shí)驗(yàn)內(nèi)容（1）畫出流程圖。該實(shí)驗(yàn)流程圖如圖8.9所示。圖8.9 8.6.1實(shí)驗(yàn)流程圖（2）編寫代碼。該實(shí)驗(yàn)源代碼如下所示。/* pipe_select.c*/#include <fcntl.h>#include <stdio.h>#include <unistd.h>#include <stdlib.h>#i

2、nclude <string.h>#include <time.h>#include <errno.h>#define FIFO1 "in1"#define FIFO2 "in2"#define MAX_BUFFER_SIZE 1024 /* 緩沖區(qū)大小*/#define IN_FILES 3 /* 多路復(fù)用輸入文件數(shù)目*/#define TIME_DELAY 60 /* 超時(shí)值秒數(shù) */#define MAX(a, b) (a > b)?(a):(b)int main(void) int fdsIN_FILES

3、; char bufMAX_BUFFER_SIZE; int i, res, real_read, maxfd; struct timeval tv; fd_set inset,tmp_inset; fds0 = 0; /* 創(chuàng)建兩個(gè)有名管道 */ if (access(FIFO1, F_OK) = -1) if (mkfifo(FIFO1, 0666) < 0) && (errno != EEXIST) printf("Cannot create fifo filen"); exit(1); if (access(FIFO2, F_OK) = -1)

4、 if (mkfifo(FIFO2, 0666) < 0) && (errno != EEXIST) printf("Cannot create fifo filen"); exit(1); /* 以只讀非阻塞方式打開兩個(gè)管道文件 */ if(fds1 = open (FIFO1, O_RDONLY|O_NONBLOCK) < 0) printf("Open in1 errorn"); return 1; if(fds2 = open (FIFO2, O_RDONLY|O_NONBLOCK) < 0) printf(&q

5、uot;Open in2 errorn"); return 1; /*取出兩個(gè)文件描述符中的較大者*/ maxfd = MAX(MAX(fds0, fds1), fds2); /*初始化讀集合inset，并在讀文件描述符集合中加入相應(yīng)的描述集*/ FD_ZERO(&inset); for (i = 0; i < IN_FILES; i+) FD_SET(fdsi, &inset); FD_SET(0, &inset); tv.tv_sec = TIME_DELAY; tv.tv_usec = 0; /*循環(huán)測(cè)試該文件描述符是否準(zhǔn)備就緒，并調(diào)用select

6、()函數(shù)對(duì)相關(guān)文件描述符做相應(yīng)操作*/ while(FD_ISSET(fds0,&inset) | FD_ISSET(fds1,&inset) | FD_ISSET(fds2, &inset) /* 文件描述符集合的備份， 免得每次進(jìn)行初始化 */ tmp_inset = inset; res = select(maxfd + 1, &tmp_inset, NULL, NULL, &tv); switch(res) case -1: printf("Select errorn"); return 1; break; case 0: /

7、* Timeout */ printf("Time outn"); return 1; break; default: for (i = 0; i < IN_FILES; i+) if (FD_ISSET(fdsi, &tmp_inset) memset(buf, 0, MAX_BUFFER_SIZE); real_read = read(fdsi, buf, MAX_BUFFER_SIZE); if (real_read < 0) if (errno != EAGAIN) return 1; else if (!real_read) close(fds

8、i); FD_CLR(fdsi, &inset); else if (i = 0) /* 主程序終端控制 */ if (buf0 = 'q') | (buf0 = 'Q') return 1; else /* 顯示管道輸入字符串 */ bufreal_read = '0' printf("%s", buf); /* end of if */ /* end of for */ break; /* end of switch */ /*end of while */ return 0;（3）編譯并運(yùn)行該程序。（4）另外打開

9、兩個(gè)虛擬終端，分別鍵入“cat > in1”和“cat > in2”，接著在該管道中鍵入相關(guān)內(nèi)容，并觀察實(shí)驗(yàn)結(jié)果。主程序截圖In1管道截圖In2截圖3根據(jù)實(shí)驗(yàn)結(jié)果完成試驗(yàn)報(bào)告（1）在第一個(gè)虛擬終端上運(yùn)行主程序：$ ./pipe_select （必須先運(yùn)行主程序） SELECT CALLselect callTEST PROGRAMMEtest programmeENDendq /* 在終端上輸入q或Q立刻結(jié)束程序運(yùn)行 */（2）在第二個(gè)終端上運(yùn)行 cat>in1后輸入字符串，將在第一個(gè)終端上看到同步輸入情況$ cat > in1 SELECT CALLTEST PROGRAMMEEND（3）在第三個(gè)終端上運(yùn)行 cat>in1后輸入字符串，將在第一個(gè)終端上看到同步輸入情況$ cat > in2select