有名管道_2
2016-07-29 00:00
232 查看
编程实现双方通信
思路
用户A 用户B写 (管道) 读
读 (管道) 写
在之前有名管道的博文中,实现的双方一发一收即为上图所描述的。建立两条管道,一条负责由A传消息给B,另一条负责由B发消息给A。
当用户A发消息给B时,B可以立即读到消息。此时A的read为阻塞,必须等到用户B发消息给A,A读到消息后,A才可以继续发消息给B。即之前博文的程序,无法实现A连续发送消息给B。
因此在这篇文章中,我们会在每个用户中,fork出一个子进程。使用一个进程负责发消息,一个进程负责收消息。这样就可以实现一方连续发送消息了。
注意,如果A使用子进程进行发送消息(w),那么就把子进程的读端(r)关闭;同理,父进程负责接收消息(r),就把其写端关闭(w)。原因?举例来说,如果不把父进程的写端(w)关上,那么即使关闭了子进程的写端(w),用户B的read还会阻塞,返回不了0,读端(r)就无法关闭。
小结
对于管道间通信而言,每个进程要专心做自己的事情,一定要把自己用不到的端口关闭。注意
针对管道,read的返回值有如下3种情况:1. 读取正常,返回读到的字符个数
2. 对方写端关闭,read返回0
3. 自己的读端关闭,read出错,返回-1。
当往一个读端已关闭的管道里发消息时,系统会挂掉该发消息的进程。
a.c
/************************************************************************* > File Name: send.c > Author: KrisChou > Mail:zhoujx0219@163.com > Created Time: Fri 22 Aug 2014 02:46:06 PM CST ************************************************************************/ #include <stdio.h> #include <sys/types.h> #include <sys/stat.h> #include <fcntl.h> #include <stdlib.h> #include <string.h> int main(int argc, char* argv[])//EXE send_fifo recv_fifo { /* A创建管道1,我们假定其先发消息,再收消息 */ /* 管道2由B创建 */ printf("create a fifo_1...\n"); if(-1 == mkfifo(argv[1], 0666)) { perror("mkfifo"); exit(1); } printf("finish make fifo_1 !\n"); /* A以写方式打开管道1,以读方式打开管道2 */ int fd_send, fd_recv ; printf("open fifo....\n"); fd_send = open(argv[1], O_WRONLY); fd_recv = open(argv[2], O_RDONLY); if(fd_send == -1 || fd_recv == -1) { perror("open"); unlink(argv[1]); /* 如果打开管道失败,删除A自己创建的管道1 */ exit(1); } printf("open fifo sucess ! \n"); char send_buf[1024]; char recv_buf[1024]; /* child负责接收消息 */ if(fork() == 0) { close(fd_send); while(memset(recv_buf,0,1024), read(fd_recv, recv_buf , 1024) > 0) { write(1,recv_buf,strlen(recv_buf)); } close(fd_recv); exit(1); } /* parent负责发送消息 */ close(fd_recv); while(memset(send_buf,0,1024), fgets(send_buf,1024,stdin) != NULL) { write(fd_send, send_buf,strlen(send_buf)); } close(fd_send); wait(NULL); printf("A over ! \n"); unlink(argv[1]); //unlink(argv[2]); return 0 ; }
b.c
/************************************************************************* > File Name: send.c > Author: KrisChou > Mail:zhoujx0219@163.com > Created Time: Fri 22 Aug 2014 02:46:06 PM CST ************************************************************************/ #include <stdio.h> #include <sys/types.h> #include <sys/stat.h> #include <fcntl.h> #include <stdlib.h> #include <string.h> int main(int argc, char* argv[])//EXE send_fifo recv_fifo { /* A创建管道1,我们假定其先发消息,再收消息 */ /* 管道2由B创建 */ printf("create a fifo_1...\n"); if(-1 == mkfifo(argv[2], 0666)) { perror("mkfifo"); exit(1); } printf("finish make fifo_1 !\n"); /* A以写方式打开管道1,以读方式打开管道2 */ int fd_send, fd_recv ; printf("open fifo....\n"); fd_recv = open(argv[1], O_RDONLY); fd_send = open(argv[2], O_WRONLY); if(fd_send == -1 || fd_recv == -1) { perror("open"); unlink(argv[2]); /* 如果打开管道失败,删除A自己创建的管道1 */ exit(1); } printf("open fifo sucess ! \n"); char send_buf[1024]; char recv_buf[1024]; /* child负责接收消息 */ if(fork() == 0) { close(fd_send); while(memset(recv_buf,0,1024), read(fd_recv, recv_buf , 1024) > 0) { write(1,recv_buf,strlen(recv_buf)); } close(fd_recv); exit(1); } /* parent负责发送消息 */ close(fd_recv); while(memset(send_buf,0,1024), fgets(send_buf,1024,stdin) != NULL) { write(fd_send, send_buf,strlen(send_buf)); } close(fd_send); wait(NULL); printf("A over ! \n"); unlink(argv[1]); //unlink(argv[2]); return 0 ; }
相关文章推荐
- Linux进程管理(3):总结
- Linux多线程之同步
- Aggregate类型以及值初始化
- Linux系统管理实践(4):忘记登录密码或账号
- Cpp多重继承会产生的问题
- [LeetCode 3] Longest Substring Without Repeating Characters
- 百度面试题——top K算法
- 非递归方法的堆排序实现
- DFS遍历中forward、backward以及cross边的界定
- Python线程指南
- [LeetCode] Search in Rotated Sorted Array II
- Dynamic Programming | Set 1 (Overlapping Subproblems Property)
- 服务器设计系列:架构综述
- 算法之美---100幅由程序生成的图像,总有一幅让你感到惊艳[上]
- dbm数据库源代码分析(17):Makefile文件和其他文件
- 我的C++实践(6):模板与继承相结合的威力
- Linux系统管理实践(5):Samba文件共享配置
- Internetworking
- Introduction to Machine Learning
- B样条