linux 进程间通信-有名管道(FIFO)

有名管道(FIFO)

命名管道也被称为FIFO文件,是一种特殊的文件。由于linux所有的事物都可以被视为文件,所以对命名管道的使用也就变得与文件操作非常统一。

(1)创建命名管道

用如下两个函数中的其中一个,可以创建命名管道。

#include <sys/types.h>
#include <sys/stat.h>
int mkfifo(const char *filename, mode_t mode);
int mknod(const char *filename, mode_t mode | S_IFIFO, (dev_t)0);

filname是指文件名,而mode是指定文件的读写权限。mknod是比较老的函数,而使用mkfifo函数更加简单和规范,所以建议用mkfifo。

open(const char *path, O_RDONLY);//1
open(const char *path, O_RDONLY | O_NONBLOCK);//2
open(const char *path, O_WRONLY);//3
open(const char *path, O_WRONLY | O_NONBLOCK);//4

(2)打开命名管道

和打开其他文件一样,可以用open来打开。通常有四种方法:

有两点要注意:

1、就是程序不能以O_RDWR(读写)模式打开FIFO文件进行读写操作,而其行为也未明确定义,因为如一个管道以读/写方式打开,进程就会读回自己的输出,同时我们通常使用FIFO只是为了单向的数据传递。

2、就是传递给open调用的是FIFO的路径名,而不是正常的文件。(如:const char *fifo_name = "/tmp/my_fifo"; )

3、第二个参数中的选项O_NONBLOCK,选项O_NONBLOCK表示非阻塞,加上这个选项后,表示open调用是非阻塞的,如果没有这个选项,则表示open调用是阻塞的。

(3)阻塞问题

对于以只读方式(O_RDONLY)打开的FIFO文件,如果open调用是阻塞的(即第二个参数为O_RDONLY),除非有一个进程以写方式打开同一个FIFO,否则它不会返回;如果open调用是非阻塞的的(即第二个参数为O_RDONLY | O_NONBLOCK),则即使没有其他进程以写方式打开同一个FIFO文件,open调用将成功并立即返回。

对于以只写方式(O_WRONLY)打开的FIFO文件,如果open调用是阻塞的(即第二个参数为O_WRONLY),open调用将被阻塞,直到有一个进程以只读方式打开同一个FIFO文件为止;如果open调用是非阻塞的(即第二个参数为O_WRONLY | O_NONBLOCK),open总会立即返回,但如果没有其他进程以只读方式打开同一个FIFO文件,open调用将返回-1,并且FIFO也不会被打开。

(4)使用FIFO实现进程间的通信

管道的写入端从一个文件读出数据,然后写入写管道。管道的读取端从管道读出后写到文件中。

写入端代码:fifowrite.c

#include <unistd.h>

#include <stdlib.h>

#include <fcntl.h>

#include <limits.h>

#include <sys/types.h>

#include <sys/stat.h>

#include <stdio.h>

#include <string.h>

int main()

{

    const char *fifo_name = "/tmp/my_fifo";

    int pipe_fd = -1;

    int data_fd = -1;

    int res = 0;

    const int open_mode = O_WRONLY;

    int bytes_sent = 0;

    char buffer[PIPE_BUF + 1];

    int bytes_read = 0;

    if(access(fifo_name, F_OK) == -1)

    {

        printf ("Create the fifo pipe.\n");

        res = mkfifo(fifo_name, 0777);

        if(res != 0)

        {

            fprintf(stderr, "Could not create fifo %s\n", fifo_name);

            exit(EXIT_FAILURE);

        }

    }

    printf("Process %d opening FIFO O_WRONLY\n", getpid());

    pipe_fd = open(fifo_name, open_mode);

    printf("Process %d result %d\n", getpid(), pipe_fd);

    if(pipe_fd != -1)

    {

        bytes_read = 0;

        data_fd = open("Data.txt", O_RDONLY);

        if (data_fd == -1)

        {

            close(pipe_fd);

            fprintf (stderr, "Open file[Data.txt] failed\n");

            return -1;

        }

        bytes_read = read(data_fd, buffer, PIPE_BUF);

        buffer[bytes_read] = ‘\0‘;

        while(bytes_read > 0)

        {

            res = write(pipe_fd, buffer, bytes_read);

            if(res == -1)

            {

                fprintf(stderr, "Write error on pipe\n");

                exit(EXIT_FAILURE);

            }

            bytes_sent += res;

            bytes_read = read(data_fd, buffer, PIPE_BUF);

            buffer[bytes_read] = ‘\0‘;

        }

        close(pipe_fd);

        close(data_fd);

    }

    else

        exit(EXIT_FAILURE);

    printf("Process %d finished\n", getpid());

    exit(EXIT_SUCCESS);

}

管道读取端: fiforead.c

#include <unistd.h>

#include <stdlib.h>

#include <stdio.h>

#include <fcntl.h>

#include <sys/types.h>

#include <sys/stat.h>

#include <limits.h>

#include <string.h>

int main()

{

    const char *fifo_name = "/tmp/my_fifo";

    int pipe_fd = -1;

    int data_fd = -1;

    int res = 0;

    int open_mode = O_RDONLY;

    char buffer[PIPE_BUF + 1];

    int bytes_read = 0;

    int bytes_write = 0;

    memset(buffer, ‘\0‘, sizeof(buffer));

    printf("Process %d opening FIFO O_RDONLY\n", getpid());

    pipe_fd = open(fifo_name, open_mode);

    data_fd = open("DataFormFIFO.txt", O_WRONLY|O_CREAT, 0644);

    if (data_fd == -1)

    {

        fprintf(stderr, "Open file[DataFormFIFO.txt] failed\n");

        close(pipe_fd);

        return -1;

    }

    printf("Process %d result %d\n",getpid(), pipe_fd);

    if(pipe_fd != -1)

    {

        do

        {

            res = read(pipe_fd, buffer, PIPE_BUF);

            bytes_write = write(data_fd, buffer, res);

            bytes_read += res;

        }while(res > 0);

        close(pipe_fd);

        close(data_fd);

    }

    else

        exit(EXIT_FAILURE);

     printf("Process %d finished, %d bytes read\n", getpid(), bytes_read);

     exit(EXIT_SUCCESS);

}

(5)命名管道的安全问题

有一种情况是:一个FIFO文件,有多个进程同时向同一个FIFO文件写数据,而只有一个读FIFO进程在同一个FIFO文件中读取数据时,会发生数据块的相互交错。不同进程向一个FIFO读进程发送数据是很普通的情况。这个问题的解决方法,就是让写操作的原子化。系统规定:在一个以O_WRONLY(即阻塞方式)打开的FIFO中, 如果写入的数据长度小于等待PIPE_BUF,那么或者写入全部字节,或者一个字节都不写入。如果所有的写请求都是发往一个阻塞的FIFO的,并且每个写记请求的数据长度小于等于PIPE_BUF字节,系统就可以确保数据决不会交错在一起。

时间: 2024-08-06 18:33:02

linux 进程间通信-有名管道(FIFO)的相关文章

linux进程间通信-有名管道(FIFO)

有名管道(FIFO) 命名管道也被称为FIFO文件,是一种特殊的文件.由于linux所有的事物都可以被视为文件,所以对命名管道的使用也就变得与文件操作非常统一. (1)创建命名管道 用如下两个函数中的其中一个,可以创建命名管道. #include <sys/types.h> #include <sys/stat.h> int mkfifo(const char *filename, mode_t mode); int mknod(const char *filename, mode

linux进程间通信--有名管道

有名管道 只有当一个库函数失败时,errno才会被设置.当函数成功运行时,errno的值不会被修改.这意味着我们不能通过测试errno的值来判断是否有错误存在.反之,只有当被调用的函数提示有错误发生时检查errno的值才有意义. 查看错误代码errno是调试程序的一个重要方法.当linux C api函数发生异常时,一般会将errno变量(需include errno.h)赋一个整数值,不同的值表示不同的含义,可以通过查看该值推测出错的原因.在实际编程中用这一招解决了不少原本看来莫名其妙的问题.

Linux进程间通信之管道(pipe)、命名管道(FIFO)与信号(Signal)

整理自网络 Unix IPC包括:管道(pipe).命名管道(FIFO)与信号(Signal) 管道(pipe) 管道可用于具有亲缘关系进程间的通信,有名管道克服了管道没有名字的限制,因此,除具有管道所具有的功能外,它还允许无亲缘关系进程间的通信: 实现机制: 管道是由内核管理的一个缓冲区,相当于我们放入内存中的一个纸条.管道的一端连接一个进程的输出.这个进程会向管道中放入信息.管道的另一端连接一个进程的输入,这个进程取出被放入管道的信息.一个缓冲区不需要很大,它被设计成为环形的数据结构,以便管

Linux 进程间通信之管道(pipe),(fifo)

 无名管道(pipe) 管道可用于具有亲缘关系进程间的通信,有名管道克服了管道没有名字的限制,因此,除具有管道所具有的功能外,它还允许无亲缘关系进程间的通信: 定义函数: int pipe(int filedes[2]) filedes[0]为管道里的读取端 filedes[1]则为管道的写入端. 实现机制: 管道是由内核管理的一个缓冲区,相当于我们放入内存中的一个纸条.管道的一端连接一个进程的输出.这个进程会向管道中放入信息.管道的另一端连接一个进程的输入,这个进程取出被放入管道的信息.一个缓

Linux进程间通信之管道

1,进程间通信 (IPC ) Inter-Process Communication 比较好理解概念的就是进程间通信就是在不同进程之间传播或交换信息. 2,linux下IPC机制的分类:管道.信号.共享内存.消息队列.信号量.套接字 3,这篇主要说说管道:本质是文件,其他理论什么的网上已经有一大堆了,我就只写一点用法吧. 3.1 特点 1)管道是最古老的IPC,但目前很少使用     2)以文件做交互的媒介,管道分为有名管道和无名管道     3)历史上的管道通常是指半双工管道 3.2 管道:有

linux之有名管道

有名管道1.查看命令:man 3 mkfifo 2.头文件:#include <sys/types.h> #include <sys/stat.h> 3.函数原型:int mkfifo(const char *pathname, mode_t mode);a.*pathname:有名管道的名字 例如:/home/gec/myfifob. mode:八进制的权限, 例如:0777 4.返回值: 成功:0 失败-1 5.函数特点:有名管道存在于文件系统中,提供写入原子性特征,共享内存效

进程间通信-有名管道

有名管道:无名管道的一个扩展,无名管道是程序运行时存在,有名管道是持久的,一旦创建,所有权限进程都可以访问. 有名管道是单向通道,只能以只读或者只写方式打开.如果要实现双向通信,必须打开两个管道. 有名管道创建:os.mkfifo(path),读写和操作文件一样,open('path', 'w'),open('path', 'r'). 有名管道示例: Process 1 import os P_Name = './pipe' if(os.access(P_Name,os.F_OK) == Fal

Linux进程间通信:管道

提到进程间通信,我们需要先了解一下进程是什么: 其实在Linux下,早期的Linux为了实现多个程序之间的交替操作,出现了进程的概念.为的就是维护操作系统整个的运行逻辑.并发就是进程间的交替执行. 进程是程序的动态实例. 进程并发运行的环境中,多个进程之间存在如下竞争和合作的关系: -          进程中的资源争用(间接作用) 当并发进程竞争使用同一个资源时,它们之间就会发生冲突.为了避免冲突,当一个进程获得资源时,另一个进程必须等待.这种情况需要通过互斥机制来解决. -         

Linux进程间通信-命名管道

前面我们讲了进程间通信的一种方式,匿名管道.我们知道,匿名管道只能用于父子关系的进程之间.那么没有这种关系的进程之间该如何进行数据传递呢? 1.什么是命名管道 匿名管道是在缓存中开辟的输出和输入文件流的空间,只能用于父子关系的进程之间.因为父子进程的输入和输出文件描述符是一致的.命名管道是一种实际存在的FIFO文件,称作“管道文件”,用于不同进程之间,命名管道进程间打开同一个FIFO文件,进行数据传递.我们可以像普通文件一样操作FIFO文件.不同进程,引用同一个FIFO文件,进行数据传递. 2.