?

8.7??實(shí)驗(yàn)內(nèi)容

8.7.1??管道通信實(shí)驗(yàn)

1．實(shí)驗(yàn)?zāi)康?/h4>

通過(guò)編寫(xiě)有名管道多路通信實(shí)驗(yàn)，讀者可進(jìn)一步掌握管道的創(chuàng)建、讀寫(xiě)等操作，同時(shí)，也復(fù)習(xí)使用select()函數(shù)實(shí)現(xiàn)管道的通信。

2．實(shí)驗(yàn)內(nèi)容

讀者還記得在6.3.3小節(jié)中，通過(guò)mknod命令創(chuàng)建兩個(gè)管道的實(shí)例嗎？本實(shí)例只是在它的基礎(chǔ)上添加有名管道的創(chuàng)建，而不用再輸入mknod命令。

3．實(shí)驗(yàn)步驟

（1）畫(huà)出流程圖。

該實(shí)驗(yàn)流程圖如圖8.9所示。

圖8.9??8.6.1實(shí)驗(yàn)流程圖

（2）編寫(xiě)代碼。

該實(shí)驗(yàn)源代碼如下所示。

/*?pipe_select.c*/

#include?<fcntl.h>

#include?<stdio.h>

#include?<unistd.h>

#include?<stdlib.h>

#include?<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?fds[IN_FILES];

?????char?buf[MAX_BUFFER_SIZE];

?????int?i,?res,?real_read,?maxfd;

?????struct?timeval?tv;

?????fd_set?inset,tmp_inset;

????

?????fds[0]?=?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)?

?????{

????????if?((mkfifo(FIFO2,?0666)?<?0)?&&?(errno?!=?EEXIST))

????????{

????????????printf("Cannot?create?fifo?filen");

????????????exit(1);

????????}

?????}

????????

?????/*?以只讀非阻塞方式打開(kāi)兩個(gè)管道文件?*/

?????if((fds[1]?=?open?(FIFO1,?O_RDONLY|O_NONBLOCK))?<?0)

?????{

????????printf("Open?in1?errorn");

????????return?1;

?????}

????if((fds[2]?=?open?(FIFO2,?O_RDONLY|O_NONBLOCK))?<?0)

????{

????????printf("Open?in2?errorn");

????????return?1;

?????}

?????/*取出兩個(gè)文件描述符中的較大者*/

????maxfd?=?MAX(MAX(fds[0],?fds[1]),?fds[2]);

????/*初始化讀集合inset，并在讀文件描述符集合中加入相應(yīng)的描述集*/

????FD_ZERO(&inset);?

????for?(i?=?0;?i?<?IN_FILES;?i++)

????{

????????FD_SET(fds[i],?&inset);

????}

????FD_SET(0,?&inset);

????tv.tv_sec?=?TIME_DELAY;

????tv.tv_usec?=?0;

????/*循環(huán)測(cè)試該文件描述符是否準(zhǔn)備就緒，并調(diào)用select()函數(shù)對(duì)相關(guān)文件描述符做相應(yīng)操作*/

????while(FD_ISSET(fds[0],&inset)?

?????????????||?FD_ISSET(fds[1],&inset)?||?FD_ISSET(fds[2],?&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:?/*?Timeout?*/

??????????????{

??????????????????printf("Time?outn");

??????????????????return?1;

???????????}

????????????break;

????????????default:

????????????{

??????????????????for?(i?=?0;?i?<?IN_FILES;?i++)

??????????????????{

??????????????????????if?(FD_ISSET(fds[i],?&tmp_inset))

??????????????????????{

??????????????????????????memset(buf,?0,?MAX_BUFFER_SIZE);

??????????????????????????real_read?=?read(fds[i],?buf,?MAX_BUFFER_SIZE);

??????????????????????????if?(real_read?<?0)

??????????????????????????{

??????????????????????????????if?(errno?!=?EAGAIN)

??????????????????????????????{

??????????????????????????????????return?1;

??????????????????????????????}

?????????????????????? ?????}

???????????????????????????else?if?(!real_read)

???????????????????????????{

???????????????????????????????close(fds[i]);

???????????????????????????????FD_CLR(fds[i],?&inset);

??????????????????????????}

??????????????????????????else

??????????????????????????{

???????????????????????????????if?(i?==?0)

???????????????????????????????{/*?主程序終端控制?*/

??????????????????????????????????if?((buf[0]?==?'q')?||?(buf[0]?==?'Q'))

???? ??????????????????????????????{

?????????? ???????? ??????????????????return?1;

???????????????????????????????}

???????????????????????????????}

???????????????????????????????else

???????????????????????????????{/*?顯示管道輸入字符串?*/

???????????????????????????????????buf[real_read]?=?'

江城| 云霄县| 荥阳市| 苗栗市| 凤阳县| 乌恰县| 磴口县| 江阴市| 尚志市| 安福县| 乌兰浩特市| 德格县| 宜昌市| 逊克县| 廉江市| 嘉峪关市| 太康县| 阜阳市| 綦江县| 凌云县| 宁武县| 潮州市| 绥芬河市| 宜州市| 新干县| 南投市| 方山县| 工布江达县| 江口县| 泽州县| 灵武市| 浦北县| 曲沃县| 临汾市| 澄城县| 苏州市| 博湖县| 扶余县| 阳东县| 罗平县| 曲周县|