当前位置:   article > 正文

linux进程间通信之管道_linux创建管道

linux创建管道

目录

一,管道原理

1,首先父进程调用pipe函数创建管道:

2,父进程创建子进程:

3,然后就是根据需求关闭对应的读写

4,由第三步可以知道,

二,匿名管道

1,创建管道pipe

2,写一段父子通信的代码

3,运行结果

三,命名管道

1,创建命名管道

2,进一步理解

原理展示:

1,服务端先跑起来,创建好命名管道

2,客户端服务端俩个进程,客户端发数据,服务端接收

3,客户端退出,服务端也退出

四,代码链接


一,管道原理

 进程具有独立性,所以要通信首先就是俩个进程要看到同一份资源,围绕这一点理解进程间通信

1,首先父进程调用pipe函数创建管道:

2,父进程创建子进程:

fork();此时子进程实惠拷贝父进程的pcd内容数据的,也就相当于他和父进程都知道了同一个资源,这很重要,因为进程之间是有独立性的,只要写就会发生写实拷贝,所以来个进程要想交互就必须要有同一份资源。

3,然后就是根据需求关闭对应的读写

这里因为是管道是单项通信的,它里面比我话的要复杂一点,是由同步互斥机制的,但是原理就是这样。

我们假设父进程给子进程发消息,那么父进程写,子进程读。

4,由第三步可以知道,

父进程可以发消息给子进程了,但是子进程如何发消息给父进程呢,答案就是关系关闭文件对调一下,但是如果父子进程都想发消息,还邮箱收到消息呢,那么此时我们就可以创建俩个管道。注意这里的管道只能是由父进程创建的,只要这样才可以把文件指向"继承给子进程" ,所以,匿名管道也可以理解为血缘间的通信,一般是父子,兄弟之间。

二,匿名管道

1,创建管道pipe

俩个函数,第二个多了一个参数,看文档正确使用就好了。

pipe是一个输出线参数,打开的俩个文件描述符由一个数组待会来。

2,写一段父子通信的代码

我们假设由父进程发送命令,子进程接收命令,模拟这样一个简单的通信。

主要有以下及部分组成:

父进程创建管道

创建子进程

父进程发送消息

子进程接收消息

代码:

  1. #include <iostream>
  2. #include <unistd.h>
  3. #include <fcntl.h>
  4. #include <cstring>
  5. #include <cstdio>
  6. #include <cstdlib>
  7. #include <sys/types.h>
  8. #include <sys/wait.h>
  9. #include <sys/stat.h>
  10. using namespace std;
  11. // pipe通信的基本过程,匿名管道。
  12. int main()
  13. {
  14. int pipnum[2] = {0};
  15. // 1,创建管道。
  16. if (pipe(pipnum) != 0)
  17. {
  18. cerr << "pipe fail" << endl;
  19. return 2;
  20. }
  21. // 2,创建子进程
  22. pid_t id = fork();
  23. //我们这次让子进程读,父进程去写,子进程去执行读到的命令。
  24. if (id < 0)
  25. {
  26. cout << "创建失败" << endl;
  27. return 3;
  28. }
  29. else if (id == 0)
  30. {
  31. #define NUM 1024
  32. //子进程 读取父进程发送的任务
  33. char buffer[NUM];
  34. close(pipnum[1]);
  35. while (true)
  36. {
  37. sleep(1);
  38. // 注意这里不要傻傻的写成了strlen();显然不对的啊。
  39. ssize_t tmp = read(pipnum[0], buffer, sizeof(buffer) - 1);
  40. if (tmp > 0)
  41. {
  42. buffer[tmp] = '\0';
  43. cout << "我是子进程任务: S " << buffer << endl;
  44. buffer[0] = '\0';
  45. }
  46. else if (tmp == 0)
  47. {
  48. cout << "父进程发布完任务退出了"
  49. << "我也要退出了" << endl;
  50. break;
  51. }
  52. else
  53. {
  54. cout << "出现bug了" << endl;
  55. break;
  56. };
  57. };
  58. close(pipnum[0]);
  59. exit(0);
  60. }
  61. else if (id > 0)
  62. {
  63. //父进程
  64. close(pipnum[0]);
  65. const char *msg = "你好子进,这次任务是打击小日子,你这次的任务编号是 ";
  66. char seetchar[128];
  67. memset(seetchar, 0, sizeof(seetchar));
  68. int count = 5;
  69. while (count)
  70. {
  71. //格式化输入。printf格式话输出。 注意要加 " ";
  72. sprintf(seetchar, "%s : %d", msg, count);
  73. sleep(1);
  74. cout << "我是父进程,我发送的任务编号是" << count << endl;
  75. write(pipnum[1], seetchar, strlen(seetchar));
  76. count--;
  77. };
  78. cout << "父进程发完任务了,要退出了" << endl;
  79. close(pipnum[1]);
  80. };
  81. //等待子进程,回收资源。
  82. pid_t pi = waitpid(id, nullptr, 0);
  83. if (pi > 0)
  84. cout << "等待子进程成功" << endl;
  85. return 0;
  86. }

3,运行结果

我们发现父子进程确实是可以通信的,

三,命名管道

1,创建命名管道

他的原理其实就是俩个完全不同的进程如何访问同一份资源么,答案就是路径相同,我们可以把文件的路径放在头文件中,俩个完全不相同的进程都包这个头文件,那么俩个进程就都知道这个文件的路径,名字,再有其中一个进程去创建,这样来个进程就可以通过路径找到同一份资源了。

一下是官方文档对mkfifo:命名管道解释: 

2,进一步理解

我们同归一段带码来进一步具体的理解命名管道为什么可以相比匿名管道突破亲缘关系传输数据。

首先准备一个头文件,这个都文件是用户端可客户端都包的,里面保存一个路径这个是不同的俩个进程访问同一份资源的关键。

接下里就比较正常了,代码中都有详细的注释,这里就不细说了。

服务端代码:

 

客户端代码:

 

原理展示:

1,服务端先跑起来,创建好命名管道

2,客户端服务端俩个进程,客户端发数据,服务端接收

我们就使用命名管道实现了俩个完全独立的进程直接的通信,

3,客户端退出,服务端也退出

四,代码链接

lyh_linux-test: linux代码练习。 - Gitee.com

lyh_linux-test: linux代码练习。 - Gitee.com

 

 

 

 

声明:本文内容由网友自发贡献,不代表【wpsshop博客】立场,版权归原作者所有,本站不承担相应法律责任。如您发现有侵权的内容,请联系我们。转载请注明出处:https://www.wpsshop.cn/w/你好赵伟/article/detail/211990
推荐阅读
相关标签
  

闽ICP备14008679号