(十)有名管道通信

(十)有名管道通信

1.核心理论-有名管道

有名管道又称为FIFO文件,因此我们对有名管 道的操作可以采用操作文件的方法,如使用 open,read,write等

FIFO文件对比普通文件

FIFO文件在使用上和普通文件有相似之处,但是也有 不同之处:

1. 读取Fifo文件的进程只能以”RDONLY”方式打开 fifo文件。

2. 写Fifo文件的进程只能以”WRONLY”方式打开fifo 文件。

3. Fifo文件里面的内容被读取后,就消失了。但是普 通文件里面的内容读取后还存在

 

2.函数学习-有名管道

创建管道 mkfifo

 函数原形

int mkfifo(const char *pathname, mode_t mode);

 函数功能

创建fifo文件(有名管道)

 所属头文件

<sys/types.h><sys/stat.h>

 返回值

成功0   失败 -1

 参数说明

要创建的fifo文件的名字(带路径)

 

删除管道 unlink

 函数原形

int unlink(const char*pathname)

 函数功能

删除文件

 所属头文件

<unistd.h>

 返回值

成功 0   失败 -1

 参数说明

3.综合实例编程

/*  fifo_write.c  */

#include <sys/types.h>
#include <sys/stat.h>
#include <errno.h>
#include <fcntl.h>
#include <stdio.h>
#include <stdlib.h>
#include <limits.h>
 
#define MYFIFO   "/tmp/myfifo"    /* 有名管道文件名*/
#define MAX_BUFFER_SIZE   PIPE_BUF   
/*常量PIPE_BUF 定义在于limits.h中*/
 
int main(int argc, char * argv[]) /*参数为即将写入的字符串*/
{
	    int fd;
	    char buff[MAX_BUFFER_SIZE];
	    int nwrite;
	    
	    if(argc <= 1)
	    {
		printf("Usage: ./fifo_write  string\n");
		exit(1);
	    }
	    sscanf(argv[1], "%s", buff);
		/* 以只写阻塞方式打开FIFO管道 */
	    fd = open(MYFIFO, O_WRONLY);
	    if (fd == -1)
	    {
		printf("Open fifo file error\n");
		exit(1);
	    }    
	    /*向管道中写入字符串*/
	    if ((nwrite = write(fd, buff, MAX_BUFFER_SIZE)) > 0)
	    {
		printf("Write '%s' to FIFO\n", buff);
	    }
	    close(fd);
	    exit(0);4
}

/*  fifo_rear.c  */

#include <sys/types.h>
#include <sys/stat.h>
#include <errno.h>
#include <fcntl.h>
#include <stdio.h>
#include <stdlib.h>
#include <limits.h>
#include <string.h>
 
#define MYFIFO   "/tmp/myfifo"    /* 有名管道文件名*/
#define MAX_BUFFER_SIZE   PIPE_BUF   
/*常量PIPE_BUF 定义在于limits.h中*/
 
int main()
{
	 char buff[MAX_BUFFER_SIZE];
	 int  fd;
	 int  nread;
	 /* 判断有名管道是否已存在,若尚未创建,则以相应的权限创建*/
	 if (access(MYFIFO, F_OK) == -1) 
	 {      
		if ((mkfifo(MYFIFO, 0666) < 0) && (errno != EEXIST))
		{   
			 printf("Cannot create fifo file\n");
		         exit(1);
		}
	  }
	/* 以只读阻塞方式打开有名管道 */
	 fd = open(MYFIFO, O_RDONLY);
	 if (fd == -1)
	 {        
		printf("Open fifo file error\n");
		exit(1);    
	 }
	 while (1)
	 {
		memset(buff, 0, sizeof(buff));
		if ((nread = read(fd, buff, MAX_BUFFER_SIZE)) > 0)
		{
			printf("Read '%s' from FIFO\n", buff);
		}		       
		 
	 }    
	 close(fd);    
	 exit(0);
}