进程间通信方式(共享内存、信号灯集、消息队列)

2024-09-04 22:28

本文主要是介绍进程间通信方式(共享内存、信号灯集、消息队列),希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

共享内存

特点

1)共享内存是一种最为高效的进程间通信方式,进程可以直接读写内存,而不需要任何数据的拷贝。

2)为了在多个进程间交换信息,内核专门留出了一块内存区,可以由需要访问的进程

将其映射到自己的私有地址空间。进程就可以直接读写这一内存区而不需要进行数据的拷贝,从而大大提高的效率。

3) 由于多个进程共享一段内存,因此也需要依靠某种同步机制,如互斥锁和信号量等

使用步骤

(1) 创建key值: ftok

(2) 创建或打开共享内存: shmget

(3) 映射共享内存到用户空间: shmat

(4) 撤销映射: shmdt

(5) 删除共享内存: shmctl

进程间通信:

命令

ipcs -m: 查看系统中的共享内存

ipcrm -m shmid:删除共享内存

ps: 可能不能直接删除掉还存在进程使用的共享内存,这时候可以用ps -ef对进程进行查看,kill掉多余的进程后,再使用ipcs查看。 

练习:两个进程实现通信,一个进程循环从终端输入,另一个进程循环打印,当输入quit时结束

这两个标志在两个进程里,是不共享的,所以为了共享标志位可以和buf封装到一个结构体里作为共享内存。

struct msg

{

int flag;

char buf[32];

};

头文件

typedef struct shared
{int flag;char buf[32];
} shared_t, *shared_p;

输入端

#include <stdio.h>
#include <sys/types.h>
#include <sys/ipc.h>
#include <sys/shm.h>
#include <errno.h>
#include <string.h>
#include "shared.h"
int main(int argc, char const *argv[])
{key_t key;key = ftok("bus.c", 'a');if (key < 0){perror("key err");return -1;}printf("key:%#x\n", key);int shmid = shmget(key, sizeof(shared_t), IPC_CREAT | IPC_EXCL | 0777);if (shmid <= 0){if (errno == EEXIST){shmid = shmget(key, sizeof(shared_t), 0777);}else{perror("shmget err");return -1;}}printf("shmid:%d\n", shmid);shared_p p = (shared_p)shmat(shmid, NULL, 0);if (p == (shared_p)-1){perror("shmat err");return -1;}p->flag = 0;while (1){if (p->flag == 0){scanf("%s", p->buf);if (strcmp(p->buf, "quit") == 0)break;p->flag++;}}shmdt(p);shmctl(shmid, IPC_RMID, NULL);return 0;
}

输出端

#include <stdio.h>
#include <sys/types.h>
#include <sys/ipc.h>
#include <sys/shm.h>
#include <errno.h>
#include <string.h>
#include <unistd.h>
#include <stdlib.h>
#include "shared.h"
int main(int argc, char const *argv[])
{key_t key;key = ftok("bus.c", 'a');if (key < 0){perror("key err");return -1;}printf("key:%#x\n", key);int shmid = shmget(key, sizeof(shared_t), IPC_CREAT | IPC_EXCL | 0777);if (shmid <= 0){if (errno == EEXIST){shmid = shmget(key, sizeof(shared_t), 0777);}else{perror("shmget err");return -1;}}printf("shmid:%d\n", shmid);shared_p p = (shared_p)shmat(shmid, NULL, 0);if (p == (shared_p)-1){perror("shmat err");return -1;}while (1){sleep(1);if (strcmp(p->buf, "quit") == 0)exit(0);if (p->flag == 1){printf("%s\n", p->buf);p->flag--;}}shmdt(p);shmctl(shmid, IPC_RMID, NULL);return 0;
}

信号灯集

特点

信号灯(semaphore),也叫信号量,信号灯集是一个信号灯的集合。它是不同进程间或一个给定进程内部不同线程间同步的机制;

而Posix信号灯指的是单个计数信号灯:无名信号灯、有名信号灯。(咱们学的是无名信号灯)

System V的信号灯是一个或者多个信号灯的一个集合。其中的每一个都是单独的计数信号灯。

通过信号灯集实现共享内存的同步操作

使用步骤

(1) 创建键值:ftok

(2) 创建或打开信号灯集:semget

(3) 初始化信号灯:semctl

(4) pv操作:semop

(5) 删除信号灯集:semctl

命令

ipcs -s:查看信号灯集

ipcrm -s semid:删除信号灯集

注意:有时候可能会创建失败,或者semid为0,所以用命令看看,删了重新创建就可以了。

练习:两个进程实现通信,一个进程循环从终端输入,另一个进程循环打印,把信号灯集加到共享内存实现同步,输入输出quit结束

头文件

union semun
{int val;
};
key_t keyfun(char buf[32], char ch);
int shmcreate(key_t key);
int semcreate(key_t key, int num);
void seminit(int semid, int val, int num);
void sempv(int semid, int num, int op);

功能函数

#include <stdio.h>
#include <stdlib.h>
#include <sys/types.h>
#include <sys/ipc.h>
#include <sys/sem.h>
#include <sys/shm.h>
#include <errno.h>
#include <string.h>
#include "sem.h"key_t keyfun(char buf[32], char ch)
{key_t key;key = ftok(buf, ch);if (key < 0){perror("ftok err");return -1;}printf("key:%#x\n", key);return key;
}int shmcreate(key_t key)
{int shmid = shmget(key, sizeof(str), IPC_CREAT | IPC_EXCL | 0777);if (shmid <= 0){if (errno == EEXIST)shmid = shmget(key, sizeof(str), 0777);else{perror("shmget err");return -1;}}printf("shmid: %d\n", shmid);return shmid;
}int semcreate(key_t key, int num)
{int semid = semget(key, num, IPC_CREAT | IPC_EXCL | 0777);if (semid <= 0){if (errno == EEXIST){semid = semget(key, num, 0777);}else{perror("semget err");return -1;}}else{seminit(semid, 0, 0);seminit(semid, 1, 1);}printf("semid:%d\n", semid);return semid;
}void seminit(int semid, int num, int val)
{union semun mysem;mysem.val = val;semctl(semid, num, SETVAL, mysem);
}void sempv(int semid, int num, int op)
{struct sembuf buf; // sembuf结构体人家写好的直接拿来用就可以// PV操作buf.sem_num = num;buf.sem_op = op;buf.sem_flg = 0;       // 阻塞semop(semid, &buf, 1); // 对num号灯进行op操作申请资源
}

输入端

#include <stdio.h>
#include <stdlib.h>
#include <sys/types.h>
#include <sys/ipc.h>
#include <sys/sem.h>
#include <sys/shm.h>
#include <errno.h>
#include <string.h>
#include "sem.h"
int main(int argc, char const *argv[])
{key_t key = keyfun("sem.h", 'a');int semid = semcreate(key, 2);int shmid = shmcreate(key);// 映射共享内存char *p = (char *)shmat(shmid, NULL, 0);if (p == (char *)-1){perror("shmat err");return -1;}while (1){sempv(semid, 1, -1);scanf("%s", p);sempv(semid, 0, 1);if (strcmp(p, "quit") == 0)break;}printf("0:%d\n", semctl(semid, 0, GETVAL));printf("1:%d\n", semctl(semid, 1, GETVAL));shmdt(p);// semctl(semid, 0, IPC_RMID);return 0;
}

输出端

#include <stdio.h>
#include <stdlib.h>
#include <sys/types.h>
#include <sys/ipc.h>
#include <sys/sem.h>
#include <sys/shm.h>
#include <errno.h>
#include <string.h>
#include "sem.h"
int main(int argc, char const *argv[])
{key_t key = keyfun("sem.h", 'a');int semid = semcreate(key, 2);int shmid = shmcreate(key);// 映射共享内存char *p = (char *)shmat(shmid, NULL, 0);if (p == (char *)-1){perror("shmat err");return -1;}while (1){sempv(semid, 0, -1);if (strcmp(p, "quit") == 0)break;printf("%s\n", p);sempv(semid, 1, 1);}printf("0:%d\n", semctl(semid, 0, GETVAL));printf("1:%d\n", semctl(semid, 1, GETVAL));shmdt(p);// semctl(semid, 0, IPC_RMID);return 0;
}

消息队列

特点

消息队列是IPC对象(活动在内核级别的一种进程间通信的工具)的一种

一个消息队列由一个标识符 (即队列ID)来标识

消息队列就是一个消息的列表。用户可以在消息队列中添加消息、读取消息等

消息队列可以按照类型(自己设一个值作为类型)来发送/接收消息

使用步骤

(1) 创建key值:ftok

(2) 创建或打开消息队列:msgget

(3) 添加消息:按照消息的类型把消息添加到已经打开的消息队列末尾msgsnd

(4) 读取消息:可以按照消息类型把消息从消息队列中取走msgrcv

(5) 删除消息队列:msgctl

命令

ipcs -q:查看消息队列

ipcrm -q msgid:删除消息队列

这篇关于进程间通信方式(共享内存、信号灯集、消息队列)的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



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

相关文章

Linux kill正在执行的后台任务 kill进程组使用详解

《Linuxkill正在执行的后台任务kill进程组使用详解》文章介绍了两个脚本的功能和区别,以及执行这些脚本时遇到的进程管理问题,通过查看进程树、使用`kill`命令和`lsof`命令,分析了子... 目录零. 用到的命令一. 待执行的脚本二. 执行含子进程的脚本,并kill2.1 进程查看2.2 遇到的

Java AOP面向切面编程的概念和实现方式

《JavaAOP面向切面编程的概念和实现方式》AOP是面向切面编程,通过动态代理将横切关注点(如日志、事务)与核心业务逻辑分离,提升代码复用性和可维护性,本文给大家介绍JavaAOP面向切面编程的概... 目录一、AOP 是什么?二、AOP 的核心概念与实现方式核心概念实现方式三、Spring AOP 的关

Linux挂载linux/Windows共享目录实现方式

《Linux挂载linux/Windows共享目录实现方式》:本文主要介绍Linux挂载linux/Windows共享目录实现方式,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地... 目录文件共享协议linux环境作为服务端(NFS)在服务器端安装 NFS创建要共享的目录修改 NFS 配

Vue3视频播放组件 vue3-video-play使用方式

《Vue3视频播放组件vue3-video-play使用方式》vue3-video-play是Vue3的视频播放组件,基于原生video标签开发,支持MP4和HLS流,提供全局/局部引入方式,可监听... 目录一、安装二、全局引入三、局部引入四、基本使用五、事件监听六、播放 HLS 流七、更多功能总结在 v

Java发送SNMP至交换机获取交换机状态实现方式

《Java发送SNMP至交换机获取交换机状态实现方式》文章介绍使用SNMP4J库(2.7.0)通过RCF1213-MIB协议获取交换机单/多路状态,需开启SNMP支持,重点对比SNMPv1、v2c、v... 目录交换机协议SNMP库获取交换机单路状态获取交换机多路状态总结交换机协议这里使用的交换机协议为常

k8s admin用户生成token方式

《k8sadmin用户生成token方式》用户使用Kubernetes1.28创建admin命名空间并部署,通过ClusterRoleBinding为jenkins用户授权集群级权限,生成并获取其t... 目录k8s admin用户生成token创建一个admin的命名空间查看k8s namespace 的

uni-app小程序项目中实现前端图片压缩实现方式(附详细代码)

《uni-app小程序项目中实现前端图片压缩实现方式(附详细代码)》在uni-app开发中,文件上传和图片处理是很常见的需求,但也经常会遇到各种问题,下面:本文主要介绍uni-app小程序项目中实... 目录方式一:使用<canvas>实现图片压缩(推荐,兼容性好)示例代码(小程序平台):方式二:使用uni

Pandas处理缺失数据的方式汇总

《Pandas处理缺失数据的方式汇总》许多教程中的数据与现实世界中的数据有很大不同,现实世界中的数据很少是干净且同质的,本文我们将讨论处理缺失数据的一些常规注意事项,了解Pandas如何表示缺失数据,... 目录缺失数据约定的权衡Pandas 中的缺失数据None 作为哨兵值NaN:缺失的数值数据Panda

java读取excel文件为base64实现方式

《java读取excel文件为base64实现方式》文章介绍使用ApachePOI和EasyExcel处理Excel文件并转换为Base64的方法,强调EasyExcel适合大文件且内存占用低,需注意... 目录使用 Apache POI 读取 Excel 并转换为 Base64使用 EasyExcel 处

Spring Boot中获取IOC容器的多种方式

《SpringBoot中获取IOC容器的多种方式》本文主要介绍了SpringBoot中获取IOC容器的多种方式,包括直接注入、实现ApplicationContextAware接口、通过Spring... 目录1. 直接注入ApplicationContext2. 实现ApplicationContextA