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

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。

相关文章

spring-boot-starter-thymeleaf加载外部html文件方式

spring-boot-starter-thymeleaf加载外部html文件方式

《spring-boot-starter-thymeleaf加载外部html文件方式》本文介绍了在SpringMVC中使用Thymeleaf模板引擎加载外部HTML文件的方法,以及在SpringBoo... 目录1.Thymeleaf介绍2.springboot使用thymeleaf2.1.引入spring
阅读更多...
Debezium 与 Apache Kafka 的集成方式步骤详解

Debezium 与 Apache Kafka 的集成方式步骤详解

《Debezium与ApacheKafka的集成方式步骤详解》本文详细介绍了如何将Debezium与ApacheKafka集成,包括集成概述、步骤、注意事项等,通过KafkaConnect,D... 目录一、集成概述二、集成步骤1. 准备 Kafka 环境2. 配置 Kafka Connect3. 安装 D
阅读更多...
Springboot中分析SQL性能的两种方式详解

Springboot中分析SQL性能的两种方式详解

《Springboot中分析SQL性能的两种方式详解》文章介绍了SQL性能分析的两种方式：MyBatis-Plus性能分析插件和p6spy框架,MyBatis-Plus插件配置简单,适用于开发和测试环... 目录SQL性能分析的两种方式:功能介绍实现方式:实现步骤:SQL性能分析的两种方式:功能介绍记录
阅读更多...
如何通过Python实现一个消息队列

如何通过Python实现一个消息队列

《如何通过Python实现一个消息队列》这篇文章主要为大家详细介绍了如何通过Python实现一个简单的消息队列,文中的示例代码讲解详细,感兴趣的小伙伴可以跟随小编一起学习一下... 目录如何通过 python 实现消息队列如何把 http 请求放在队列中执行1. 使用 queue.Queue 和 reque
阅读更多...
SQL 中多表查询的常见连接方式详解

SQL 中多表查询的常见连接方式详解

《SQL中多表查询的常见连接方式详解》本文介绍SQL中多表查询的常见连接方式,包括内连接（INNERJOIN）、左连接（LEFTJOIN）、右连接（RIGHTJOIN）、全外连接（FULLOUTER... 目录一、连接类型图表（ASCII 形式）二、前置代码（创建示例表）三、连接方式代码示例1. 内连接（I
阅读更多...
Android里面的Service种类以及启动方式

Android里面的Service种类以及启动方式

《Android里面的Service种类以及启动方式》Android中的Service分为前台服务和后台服务,前台服务需要亮身份牌并显示通知,后台服务则有启动方式选择,包括startService和b... 目录一句话总结：一、Service 的两种类型：1. 前台服务（必须亮身份牌）2. 后台服务（偷偷干
阅读更多...
Java深度学习库DJL实现Python的NumPy方式

Java深度学习库DJL实现Python的NumPy方式

《Java深度学习库DJL实现Python的NumPy方式》本文介绍了DJL库的背景和基本功能,包括NDArray的创建、数学运算、数据获取和设置等,同时,还展示了如何使用NDArray进行数据预处理... 目录1 NDArray 的背景介绍1.1 架构2 JavaDJL使用2.1 安装DJL2.2 基本操
阅读更多...
最长公共子序列问题的深度分析与Java实现方式

最长公共子序列问题的深度分析与Java实现方式

《最长公共子序列问题的深度分析与Java实现方式》本文详细介绍了最长公共子序列（LCS）问题,包括其概念、暴力解法、动态规划解法,并提供了Java代码实现,暴力解法虽然简单,但在大数据处理中效率较低,... 目录最长公共子序列问题概述问题理解与示例分析暴力解法思路与示例代码动态规划解法DP 表的构建与意义动
阅读更多...
JS 实现复制到剪贴板的几种方式小结

JS 实现复制到剪贴板的几种方式小结

《JS实现复制到剪贴板的几种方式小结》本文主要介绍了JS实现复制到剪贴板的几种方式小结,包括ClipboardAPI和document.execCommand这两种方法,具有一定的参考价值,感兴趣的... 目录一、Clipboard API相关属性方法二、document.execCommand优点：缺点：
阅读更多...
Python创建Excel的4种方式小结

Python创建Excel的4种方式小结

《Python创建Excel的4种方式小结》这篇文章主要为大家详细介绍了Python中创建Excel的4种常见方式,文中的示例代码简洁易懂,具有一定的参考价值,感兴趣的小伙伴可以学习一下... 目录库的安装代码1——pandas代码2——openpyxl代码3——xlsxwriterwww.cppcns.c
阅读更多...

Copyright China编程 23002807@qq.com

沪ICP备2023033072号-2