前面我们说了无名管道,下面我们来说说有名管道,请看下面一段代码:

fifo_write.c:

#include#include#include#include#include#include#include#define FIFO "/tmp/myfifo"

void main(int argc,char **argv)//参数为即将写入的字节数

{

int fd;

char w_buf[100];

int nwrite;

if(fd==-1)

{

if(errno==ENXIO)

{

printf("open error;no reading process \n");

}

}

//fd=open(FIFO_SERVER,O_WRONLY|O_NONBLOCK,0);//打开FIFO管道,并设置非阻塞状态

fd=open(FIFO,O_WRONLY|O_NONBLOCK,0);

if(argc==1)

{

printf("please send something \n");

}

strcpy(w_buf,argv[1]);

if((nwrite=write(fd,w_buf,100))==-1)//向管道中写入字符串

{

if(errno==EAGAIN)

{

printf("the fifo has not been read yet.please try later\n");

}

}

else

{

printf("write %s to the fifo \n",w_buf) ;

}

}

/*------------------------------------------------------------

1.有名管道说明

它可以使互不相关的两个进程实现彼此通信.该管道可以通过路径名来指出,并且在文件系

统中是可见的.在建立管道之后,两个进程就可以把它当作普通文件一样进行读写操作,使用

方便.不过值得注意的是,FIFO是严格地遵循先进先出规则的,对管道及FIFO的读总是从开始处

返回数据,对它们的写则把数据添加到末尾,它们不支持如lseek()等文件定位操作.

2.有名管道的创建可以使用函数mkfifo(),该函数类似文件中的open()操作,可以指定管道的

路径和打开的模式.

在创建管道成功之后,就可以使用open,read,write这些函数了.与普通文件的开发设置一样,

对于为读而开的管道可在open中设置O_RDONLY,对于为写而打开的管道可在open中设置O_WRONLY,

在这里与普通文件不同的是阻塞的可能.由于普通文件的读写时不会出现阻塞问题,而

在管道的读写中却有阻塞的可能,这里的非阻塞标志可以在open函数中设定为O_NONBLOCK.

对于读进程

.若该管道是阻塞打开,且当前FIFO内没有数据,则对读进程而言将一直阻塞直到有数据写入.

.若该管道是非阻塞打开,则无论FIFO内是否有数据,读进程都会立即执行读操作.

对于写进程

.若该管道是阻塞打开,则写进程而言将一直阻塞直到有读进程读出数据.

.若该管道是非阻塞打开,则当前FIFO内没有读操作,写进程都会立即执行读操作.

3.mkfifo函数格式

1)所需要的头文件

#include#include2)函数原型

int mkfifo(const char *filename,mode_t mode)

3)函数输入参数

filename:要创建的管道

mode:

O_RDONLY:读管道

O_WRONLY:写管道

O_RDWR:读写管道

O_NONBLOCK:非阻塞

O_CREAT:如果该文件不存在,那么就创建一个新的文件,并用第三的参数为其设置权限.

O_EXCL:如果使用O_CREAT时文件存在,那么可返回错误消息.这一参数可测试文件是否

存在.

4)函数返回值

成功:0

出错:-1

4.实验

本实例需要两个程序,一个用于读管道,另一个用于写管道.其中在写管道的程序里创建

管道,并且作为main函数里的参数由用户输入要写入的内容.读管道读出了用户写入管道

的内容.

1)[root@localhost the_eight_step]# gcc  fifo_write.c -o fifo_write

2)[root@localhost the_eight_step]# ./fifo_write hello

write hello to the fifo

3)[root@localhost the_eight_step]# gcc fifo_read.c -o fifo_read

4)[root@localhost the_eight_step]# ./fifo_read

perparing for reading bytes ...

read  from fifo

read  from fifo

read  from fifo

read  from fifo

read hello from fifo

5)注意:要打开两个终端去观察两个程序的运行情况.

----------------------------------------------------------*/

fifo_read.c:

#include#include#include#include#include#include#include#define FIFO "/tmp/myfifo"

void main(int argc,char **argv)

{

char buf_r[100];

int fd;

int nread;

if((mkfifo(FIFO,O_CREAT|O_EXCL)<0)&&(errno!=EEXIST))//创建有名管道,并

//设置相应的权限

{

printf("cannot create fifoserver \n");

}

printf("perparing for reading bytes ... \n");

memset(buf_r,0,sizeof(buf_r));

fd=open(FIFO,O_RDONLY|O_NONBLOCK,0);//打开有名管道,并设置为非阻塞方式

if(fd==-1)

{

perror("open");

exit(1);

}

while(1)

{

memset(buf_r,0,sizeof(buf_r));

if((nread=read(fd,buf_r,100))==-1)

{

if(errno==EAGAIN)

{

printf("no data yet \n");

}

}

printf("read %s from fifo \n",buf_r);

sleep(1);

}

pause();

unlink(FIFO);

}

/*--------------------------------------------

notes:

1.unlink(删除文件)

1)所需要的头文件:#include2)函数原型:int unlink(const char *pthname)

3)函数说明:unlink()会删除参数pthbame指定的文件,如果该文件名为最后连接点,但有其他进程

打开此文件,则在所有关于此文件的文件描述词皆关闭后才会删除.如果参数pathname为一符号连

接,则此连接会被删除.

4)返回值

成功则返回0

失败返回-1

错误原因存于errno

2.pause(让进程暂停直到信号出现)

1)所需要的头文件:#include2)函数原型:int pause(void)

3)函数说明:pause()会令目前的进程暂停(进入睡眠状态),直到被信号(signal)所中断.

4)返回值

只返回-1

错误代码EINTR有信号到达中断了此函数

------------------------------------------------*/