当前位置：首页 > news >正文

linux学习：进程通信管道

news 2025/6/27 8:04:04

例子1 父进程向子进程发送一条消息，子进程读取这条消息

例子2 mkfifo 函数创建一个命名管道

例子3 mkfifo 函数创建一个命名管道处理可能出现的错误

例子4 管道文件是否已存在

例子5 除了“文件已存在”进行处理

例子6 创建一个命名管道，并尝试打开它以进行读取

例子7 创建一个命名管道（FIFO），打开它用于读取数据，并循环读取来自管道的数据，直到程序被手动终止

例子8 持续写入特定消息到命名管道中直到达到指定次数后终止

例子9 打开一个已存在的命名管道（FIFO）以进行写操作

例子1 父进程向子进程发送一条消息，子进程读取这条消息

#include <stdio.h>  // 包含标准输入输出函数库
#include <unistd.h>  // 包含各种系统调用和基本的函数声明，如fork(), pipe(), read(), write()
#include <string.h> // 包含字符串处理函数库
#include <stdlib.h> // 包含标准库函数，如exit()int main()
{int fd[2];  // 用于存储管道的文件描述符，fd[0]用于读，fd[1]用于写int pid;  // 用于存储进程IDchar buf[128];  // 缓冲区，用于存储从管道读取的数据// 创建管道if(pipe(fd) == -1){printf("create pipe failed\n");return -1;  // 管道创建失败时，打印错误信息并退出程序}pid = fork();  // 创建子进程if(pid < 0){  // fork失败printf("create child failed\n");return -1;  // 进程创建失败时，打印错误信息并退出程序}else if(pid > 0){  // 父进程执行的分支sleep(3);  // 父进程等待3秒，确保子进程准备好接收数据printf("this is father\n");close(fd[0]);  // 父进程关闭管道的读端write(fd[1], "hello from father", strlen("hello from father"));  // 向管道写入数据wait();  // 等待子进程结束} else {  // 子进程执行的分支printf("this is child\n");close(fd[1]);  // 子进程关闭管道的写端read(fd[0], buf, 128);  // 从管道读取数据printf("read from father: %s\n", buf);  // 打印从父进程读取的数据exit(0);  // 子进程正常退出}return 0;  // 主程序正常结束
}

例子2 `mkfifo` 函数创建一个命名管道

#include <sys/types.h>  // 包含数据类型定义，如pid_t、mode_t
#include <sys/stat.h>   // 包含文件状态定义，用于文件操作，如mkfifo// 主函数入口
int main()
{// 使用mkfifo系统调用创建一个名为"./file"的命名管道// 参数 "./file" 是命名管道的路径和名称// 参数 0600 是设置文件的权限，表示只有所有者有读写权限// 0600 对应于八进制，实际权限是 -rw------- mkfifo("./file", 0600);return 0;  // 返回0，正常结束程序
}

例子3 `mkfifo` 函数创建一个命名管道处理可能出现的错误

#include <sys/types.h>  // 包含数据类型定义，如pid_t、mode_t
#include <sys/stat.h>   // 包含文件状态定义，用于文件操作，如mkfifo
#include <stdio.h>      // 包含标凈输入输出库函数// 主函数入口
int main()
{// 尝试创建一个名为"./file"的命名管道，设置权限为0600（只有所有者有读写权限）int ret = mkfifo("./file", 0600);// 判断mkfifo函数的返回值if(ret == 0){  // 如果返回值为0，说明命名管道创建成功printf("mkfifo success\n");  // 输出成功消息}if(ret == -1){  // 如果返回值为-1，说明命名管道创建失败printf("mkfifo failure\n");  // 输出失败消息perror("why");  // 使用perror输出错误原因，它会根据全局变量errno来描述错误详情}		return 0;  // 程序正常结束，返回0
}