同一个父进程的多个子进程之间的通信

2024-06-22 19:48

本文主要是介绍同一个父进程的多个子进程之间的通信,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

对于父子进程之间的通信, 或者是没有亲缘关系的进程之间的通信, 之前都有过多多少少的了解, 就不作说明了.
这里想要讨论的是多个子进程之间的通信.
以前若是有多个子进程之间通信的需要, 那么我可能会选择使用共享内存? 使用消息队列? 或者使用一系列进程间通信机制
但这些同样适用于没有亲缘关系的进程之间的通信. 这样做似乎没有必要.

这里将要实现的子进程之间的通信, 使用了两个技术:
        一个是子进程继承父进程的描述符特性(这里是socketpair产生的管道描述符)
        一个是利用socketpair传递描述符特性.


大致步骤如下:
父进程调用sokcetpair, 产生一个管道, fork产生第一个子进程, 这样, 父子进程就能通过这个管道进行通信了
父进程再次调用socketpair, 之后fork出第二个子进程, 父进程与第二个子进程也能通过这个管道进行通信了
        第二个子进程同时继承了父进程与第一个子进程之间通信的管道, 说明此时第二个子进程能透过这个管道口向第一个子进程发送消息
        只是这是单向的. 第一个子进程却完全不了解第二个子进程的管道口, 甚至其是否存在都一无所知
        父进程 通过 其与第一个子进程之间的管道口 将 父进程与第二个子进程通信的管道口 传递给第一个子进程
        这时子进程记录下这个管道口, 就能向第二个子进程发送数据了
       (要注意的是, 描述符并不是一个单纯的数字, 其在内核中对应着一组信息, 所以传递描述符需要特殊的方法)
第三个子进程被fork出来, 同样, 它知道如何向第一和第二个子进程发送数据, 父进程则需要分别告诉第一和第二个子进程与第三个子进程通信的描述符
这样, 产生的多个子进程之间就能两两通信了.

要注意的是, 每个新fork出来的子进程都要关闭不使用的之前进程的另一个管道描述符.


下面就给出实现:
头文件:
#include <stdio.h>
#include <string.h>
#include <stdlib.h>
#include <sys/epoll.h>
#include <unistd.h>
#include <sys/types.h>
#include <sys/socket.h>#ifndef CPC_H
#define CPC_H#define DEBUG
#define MAX_EVENT 64
//消息分两种, 一种是传递描述符; 一种在验证的时候我们会发送字符串验证
enum message_type{FD_TRANS = 0, MSG_TRANS};//做个规定, socketpair的数组, 0给父进程用. 1给子进程用
//所需的关于每个进程的结构体
typedef struct {pid_t pid;int index;int channel[2];
}process_t;typedef struct {enum message_type type;//消息是来自哪个进程的int sourceIndex;
}info_t;typedef struct{//传递描述符用这个int fd;//传递字符串用这个char str[64];
}content_t;typedef struct {info_t info;content_t data;
}message_t;//每个子进程主函数体
void child_run(int index, process_t *processes);
//消息读写函数
int write_channel_fd(int fd, message_t *data);
int recv_channel(int fd, message_t *data);
//添加事件到epoll中
void add_fd_to_epoll_in(int epollfd, int fd);#endif

这篇关于同一个父进程的多个子进程之间的通信的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/1085247

相关文章

使用SQL语言查询多个Excel表格的操作方法

《使用SQL语言查询多个Excel表格的操作方法》本文介绍了如何使用SQL语言查询多个Excel表格,通过将所有Excel表格放入一个.xlsx文件中,并使用pandas和pandasql库进行读取和... 目录如何用SQL语言查询多个Excel表格如何使用sql查询excel内容1. 简介2. 实现思路3

python多进程实现数据共享的示例代码

《python多进程实现数据共享的示例代码》本文介绍了Python中多进程实现数据共享的方法,包括使用multiprocessing模块和manager模块这两种方法,具有一定的参考价值,感兴趣的可以... 目录背景进程、进程创建进程间通信 进程间共享数据共享list实践背景 安卓ui自动化框架,使用的是

C#如何优雅地取消进程的执行之Cancellation详解

《C#如何优雅地取消进程的执行之Cancellation详解》本文介绍了.NET框架中的取消协作模型,包括CancellationToken的使用、取消请求的发送和接收、以及如何处理取消事件... 目录概述与取消线程相关的类型代码举例操作取消vs对象取消监听并响应取消请求轮询监听通过回调注册进行监听使用Wa

day-51 合并零之间的节点

思路 直接遍历链表即可,遇到val=0跳过,val非零则加在一起,最后返回即可 解题过程 返回链表可以有头结点,方便插入,返回head.next Code /*** Definition for singly-linked list.* public class ListNode {* int val;* ListNode next;* ListNode() {}*

系统架构师考试学习笔记第三篇——架构设计高级知识(20)通信系统架构设计理论与实践

本章知识考点:         第20课时主要学习通信系统架构设计的理论和工作中的实践。根据新版考试大纲,本课时知识点会涉及案例分析题(25分),而在历年考试中,案例题对该部分内容的考查并不多,虽在综合知识选择题目中经常考查,但分值也不高。本课时内容侧重于对知识点的记忆和理解,按照以往的出题规律,通信系统架构设计基础知识点多来源于教材内的基础网络设备、网络架构和教材外最新时事热点技术。本课时知识

[Linux]:进程(下)

✨✨ 欢迎大家来到贝蒂大讲堂✨✨ 🎈🎈养成好习惯,先赞后看哦~🎈🎈 所属专栏:Linux学习 贝蒂的主页:Betty’s blog 1. 进程终止 1.1 进程退出的场景 进程退出只有以下三种情况: 代码运行完毕,结果正确。代码运行完毕,结果不正确。代码异常终止(进程崩溃)。 1.2 进程退出码 在编程中,我们通常认为main函数是代码的入口,但实际上它只是用户级

【STM32】SPI通信-软件与硬件读写SPI

SPI通信-软件与硬件读写SPI 软件SPI一、SPI通信协议1、SPI通信2、硬件电路3、移位示意图4、SPI时序基本单元(1)开始通信和结束通信(2)模式0---用的最多(3)模式1(4)模式2(5)模式3 5、SPI时序(1)写使能(2)指定地址写(3)指定地址读 二、W25Q64模块介绍1、W25Q64简介2、硬件电路3、W25Q64框图4、Flash操作注意事项软件SPI读写W2

【每日一题】LeetCode 2181.合并零之间的节点(链表、模拟)

【每日一题】LeetCode 2181.合并零之间的节点(链表、模拟) 题目描述 给定一个链表,链表中的每个节点代表一个整数。链表中的整数由 0 分隔开,表示不同的区间。链表的开始和结束节点的值都为 0。任务是将每两个相邻的 0 之间的所有节点合并成一个节点,新节点的值为原区间内所有节点值的和。合并后,需要移除所有的 0,并返回修改后的链表头节点。 思路分析 初始化:创建一个虚拟头节点

vue2 组件通信

props + emits props:用于接收父组件传递给子组件的数据。可以定义期望从父组件接收的数据结构和类型。‘子组件不可更改该数据’emits:用于定义组件可以向父组件发出的事件。这允许父组件监听子组件的事件并作出响应。(比如数据更新) props检查属性 属性名类型描述默认值typeFunction指定 prop 应该是什么类型,如 String, Number, Boolean,

java 进程 返回值

实现 Callable 接口 与 Runnable 相比,Callable 可以有返回值,返回值通过 FutureTask 进行封装。 public class MyCallable implements Callable<Integer> {public Integer call() {return 123;}} public static void main(String[] args