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

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。

相关文章

gradle第三方Jar包依赖统一管理方式

gradle第三方Jar包依赖统一管理方式

《gradle第三方Jar包依赖统一管理方式》：本文主要介绍gradle第三方Jar包依赖统一管理方式,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教... 目录背景实现1.顶层模块build.gradle添加依赖管理插件2.顶层模块build.gradle添加所有管理依赖包
阅读更多...
Linux之systemV共享内存方式

Linux之systemV共享内存方式

《Linux之systemV共享内存方式》：本文主要介绍Linux之systemV共享内存方式,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教... 目录一、工作原理二、系统调用接口1、申请共享内存（一）key的获取（二）共享内存的申请2、将共享内存段连接到进程地址空间3、将
阅读更多...
Maven中引入 springboot 相关依赖的方式(最新推荐)

Maven中引入 springboot 相关依赖的方式(最新推荐)

《Maven中引入springboot相关依赖的方式(最新推荐)》：本文主要介绍Maven中引入springboot相关依赖的方式(最新推荐),本文给大家介绍的非常详细,对大家的学习或工作具有... 目录Maven中引入 springboot 相关依赖的方式1. 不使用版本管理（不推荐）2、使用版本管理（推
阅读更多...
C#使用StackExchange.Redis实现分布式锁的两种方式介绍

C#使用StackExchange.Redis实现分布式锁的两种方式介绍

《C#使用StackExchange.Redis实现分布式锁的两种方式介绍》分布式锁在集群的架构中发挥着重要的作用,：本文主要介绍C#使用StackExchange.Redis实现分布式锁的... 目录自定义分布式锁获取锁释放锁自动续期StackExchange.Redis分布式锁获取锁释放锁自动续期分布式
阅读更多...
Java对象转换的实现方式汇总

Java对象转换的实现方式汇总

《Java对象转换的实现方式汇总》：本文主要介绍Java对象转换的多种实现方式,本文通过实例代码给大家介绍的非常详细,对大家的学习或工作具有一定的参考借鉴价值,需要的朋友参考下吧... 目录Java对象转换的多种实现方式1. 手动映射（Manual Mapping）2. Builder模式3. 工具类辅助映
阅读更多...
Spring Boot读取配置文件的五种方式小结

Spring Boot读取配置文件的五种方式小结

《SpringBoot读取配置文件的五种方式小结》SpringBoot提供了灵活多样的方式来读取配置文件,这篇文章为大家介绍了5种常见的读取方式,文中的示例代码简洁易懂,大家可以根据自己的需要进... 目录1. 配置文件位置与加载顺序2. 读取配置文件的方式汇总方式一：使用 @Value 注解读取配置方式二
阅读更多...
JAVA保证HashMap线程安全的几种方式

JAVA保证HashMap线程安全的几种方式

《JAVA保证HashMap线程安全的几种方式》HashMap是线程不安全的,这意味着如果多个线程并发地访问和修改同一个HashMap实例,可能会导致数据不一致和其他线程安全问题,本文主要介绍了JAV... 目录1. 使用 Collections.synchronizedMap2. 使用 Concurren
阅读更多...
Python如何精准判断某个进程是否在运行

Python如何精准判断某个进程是否在运行

《Python如何精准判断某个进程是否在运行》这篇文章主要为大家详细介绍了Python如何精准判断某个进程是否在运行,本文为大家整理了3种方法并进行了对比,有需要的小伙伴可以跟随小编一起学习一下... 目录一、为什么需要判断进程是否存在二、方法1：用psutil库（推荐）三、方法2：用os.system调用
阅读更多...
Java的栈与队列实现代码解析

Java的栈与队列实现代码解析

《Java的栈与队列实现代码解析》栈是常见的线性数据结构,栈的特点是以先进后出的形式,后进先出,先进后出,分为栈底和栈顶,栈应用于内存的分配,表达式求值,存储临时的数据和方法的调用等,本文给大家介绍J... 目录栈的概念（Stack）栈的实现代码队列（Queue）模拟实现队列(双链表实现)循环队列（循环数组
阅读更多...
C# foreach 循环中获取索引的实现方式

C# foreach 循环中获取索引的实现方式

《C#foreach循环中获取索引的实现方式》：本文主要介绍C#foreach循环中获取索引的实现方式,本文给大家介绍的非常详细,对大家的学习或工作具有一定的参考借鉴价值,需要的朋友参考下吧... 目录一、手动维护索引变量二、LINQ Select + 元组解构三、扩展方法封装索引四、使用 for 循环替代
阅读更多...

Copyright China编程 23002807@qq.com

沪ICP备2023033072号-2