阅读量:0
一、相关练习
1.使用有名管道实现，一个进程用于给另一个进程发消息，另一个进程收到消息后，展示到终端上，并且将消息保存到文件上一份
1.1> 01homework.c
#include <myhead.h> int main(int argc, const char *argv[]) { //创建一个有名管道 if(mkfifo("./pipe", 0664) == -1) { perror("mkfifo error"); return -1; } //定义通信容器 char buf[128] = ""; //创建父子进程 pid_t pid = fork(); if(pid < 0) { perror("fork error"); return -1; }else if(pid > 0) { //子进程 //以读的形式打开文件 int rfd = open("./pipe", O_RDONLY); if(rfd == -1) { perror("open error"); return -1; } //已追加形式打开要写入文件 int dfd = open("./test.txt", O_WRONLY|O_APPEND|O_CREAT, 0664); if(dfd == -1) { perror("open dfd error"); return -1; } printf("管道文件读端打开\n"); while(1) { bzero(buf, sizeof(buf)); //读取数据 read(rfd, buf, sizeof(buf)); if(strcmp(buf, "quit") == 0) { break; } printf("收到消息为：%s\n", buf); //将读取到的数据写入目标文件 write(dfd, buf, strlen(buf)); write(dfd, "\n", sizeof("\n")); } //关闭文件 close(rfd); close(dfd); //退出进程 exit(EXIT_SUCCESS); } //以写的形式打开管道文件 int wfd = open("./pipe", O_WRONLY); if(wfd == -1) { perror("open wfd error"); return -1; } printf("管道文件写端打开\n"); usleep(10); while(1) { usleep(10); bzero(buf, sizeof(buf)); printf("请输入>>>"); fgets(buf, sizeof(buf), stdin); buf[strlen(buf)-1] = 0; //写入数据 write(wfd, buf, strlen(buf)); //终止判断 if(strcmp(buf, "quit") == 0) { break; } } //回收进程资源 wait(NULL); //关闭写端 close(wfd); //删除管道文件 system("rm pipe"); return 0; } 1.2> 程序运行效果
2.使用有名管道实现两个进程间相互通信
2.1> creat.c
#include <myhead.h> int main(int argc, const char *argv[]) { //创建管道文件 if(mkfifo("./pipe1", 0664) == -1) { perror("mkfifo pipe1 error"); return -1; } if(mkfifo("./pipe2", 0664) == -1) { perror("mkfifo pipe2 error"); } getchar(); //删除管道文件 system("rm pipe1"); system("rm pipe2"); return 0; } 2.2> fork_a.c
#include <myhead.h> int main(int argc, const char *argv[]) { //创建通信中间变量 char buf[128] = ""; //创建父子进程 pid_t pid = fork(); if(pid < 0) { perror("fork error"); return -1; }else if(pid == 0) { //子进程 //以只读的形式打开管道文件2 int rfd = open("./pipe2", O_RDONLY); if(rfd == -1) { perror("pipe2 open error"); return -1; } //读取管道文件2中的数据 while (1) { bzero(buf, sizeof(buf)); read(rfd, buf, sizeof(buf)); if(strcmp(buf, "quit") == 0) { //退出聊天 printf("B已经退出聊天，请输入“quit”退出聊天\n"); break; } printf("收到B的消息：%s\n", buf); } //关闭文件描述符 close(rfd); //退出子进程 exit(EXIT_SUCCESS); } //以只写的形式打开管道文件1 int wfd = open("./pipe1", O_WRONLY); if(wfd == -1) { perror("pipe1 open error"); return -1; } //向管道文件1中写入数据 while(1) { bzero(buf, sizeof(buf)); //清空容器 printf("向B发送消息："); fgets(buf, sizeof(buf), stdin); //从标准输入中读取数据 putchar(10); buf[strlen(buf)-1] = 0; //去掉换行符 write(wfd, buf, strlen(buf)); //向管道文件1中写入数据 if(strcmp(buf, "quit") == 0) //如果输入的是quit，则退出聊天 { break; } } //回收子进程 wait(NULL); //关闭文件描述符 close(wfd); return 0; } 2.3> fork_b.c
#include <myhead.h> int main(int argc, const char *argv[]) { //创建通信中间变量 char buf[128] = ""; //创建父子进程 pid_t pid = fork(); if(pid < 0) { perror("fork error"); return -1; }else if(pid == 0) { //子进程 //以只读的形式打开管道文件2 int rfd = open("./pipe1", O_RDONLY); if(rfd == -1) { perror("pipe2 open error"); return -1; } //读取管道文件2中的数据 while (1) { bzero(buf, sizeof(buf)); read(rfd, buf, sizeof(buf)); if(strcmp(buf, "quit") == 0) { //退出聊天 printf("A已经退出聊天，请输入“quit”退出聊天\n"); break; } printf("收到A的消息：%s\n", buf); } //关闭文件描述符 close(rfd); //退出子进程 exit(EXIT_SUCCESS); } //以只写的形式打开管道文件1 int wfd = open("./pipe2", O_WRONLY); if(wfd == -1) { perror("pipe1 open error"); return -1; } //向管道文件1中写入数据 while(1) { bzero(buf, sizeof(buf)); //清空容器 printf("向A发送消息："); fgets(buf, sizeof(buf), stdin); //从标准输入中读取数据 putchar(10); buf[strlen(buf)-1] = 0; //去掉换行符 write(wfd, buf, strlen(buf)); //向管道文件1中写入数据 if(strcmp(buf, "quit") == 0) //如果输入的是quit，则退出聊天 { break; } } //回收子进程 wait(NULL); //关闭文件描述符 close(wfd); return 0; } 2.4> 程序运行效果
二、思维导图
