linux系统进程间通信方式(一):共享内存

 

前言

        linux系统可以创建多个用户进程,进程之间有多种通信方式,可以使用system-V的IPC对象进行通信;从本文开始,首先介绍system-V IPC之一的共享内存。

一、了解system-V IPC

(一)什么是SYSTEM-V IPC?

        linux系统的内核可以创建一些对象(共享内存、消息队列、信号量),这些对象拥有它们自己的标识符(ID),并且每一个对象都是通过一个唯一的key来绑定(识别)它;多个进程可以这些对象来通信,这些内核中的对象被人们称为system-V IPC。

        上面讲的这些IPC对象它是存在于内核中,和进程是相互独立的;进程想使用这些IPC对象,那它怎么知道现在用的是哪一个对象呢?所以需要提供一个唯一的值来识别(绑定)这些IPC对象。那么在linux系统里面怎么获取一个唯一的值呢?我们都知道,对于linux系统来说,一切都是文件,文件是唯一的,那么它的inode节点也是唯一的,所以可以利用它来创建一个唯一的值,也就是上面提到的key。

        linux提供了一个api函数ftok,它可以帮我们创建一个唯一的key,来绑定一个IPC对象。(创建key的原理这里简述一下:就是通过文件的inode号和一个用户指定的工程id(proj_id)来制作key,具体怎么生成这里不详细展述)

        那么多个进程使用这个相同的key,就可以获取到同一个IPC对象的ID,从而使用同一个IPC对象来进行通信。

        下面展示一下linux系统中的IPC对象的有关信息(使用命令ipcs)

注意:输入ipcs -m只显示共享内存;输入ipcs -q只显示消息队列;输入ipcs -s只显示信号量

        上述的IPC 对象在内核内部使用链表维护,不同的对象使用 IPC 标识符来标识,如消息队列标识符 msqid、共享内存标识符 shmid,信号量标识符 semid。对于用户来说,内核提供了简洁的接口,不同的进程通过指定的key 就可以访问具体的对象。

(二)system-V IPC的特点

1.独立于进程
2.没有文件名和文件描述符
3.IPC对象具有key和ID

 

二、使用共享内存实现进程间通信(示例)

1.设计意图

实现两个进程通信,一个进程往共享内存写数据,另一个从共享内存读取数据

2.设计思路

1、首先有两个程序:p1.c、p2.c;

2、这两个程序先后运行之后系统会创建两个进程(下面统称为p1、p2);

3、p1创建一块共享内存、创建两个信号量

4、p2获取这块共享内存、打开信号量

5、p1从键盘获取字符串,然后往共享内存写入数据

6、p2从共享内存读取数据,并打印出数据

7、通信过程使用posix有名信号量实现同步(即p1写完数据p2才能读取数据)

3.代码实现

程序p1.c

#include <stdio.h> #include <string.h> #include <stdlib.h> #include <error.h>  #include <sys/types.h> #include <sys/ipc.h> #include <sys/ipc.h> #include <sys/shm.h>  #include <fcntl.h>           /* For O_* constants */ #include <sys/stat.h>        /* For mode constants */ #include <semaphore.h>  static void free_resource(char *shmaddr, int shmid, sem_t *sem1, sem_t *sem2) { 	int ret;  	ret = shmdt(shmaddr); 	if(ret < 0) 	{ 		perror(shm detach fail); 	} 	 	if(shmctl(shmid, IPC_RMID, NULL)<0) 	{ 		perror(remove a shm fail); 	} 	 	if(sem_close(sem1) < 0) 	{ 		perror(close sem1 fail); 	}  	if(sem_close(sem2) < 0) 	{ 		perror(close sem2 fail); 	}  	if(sem_unlink(sem1) < 0) 	{ 		perror(remove sem1 fail); 	}  	if(sem_unlink(sem2) < 0) 	{ 		perror(remove sem2 fail); 	} }  int main(int argc, char **argv) { 	key_t key; 	int shmid; 	char *shmaddr = NULL; 	sem_t *sem1 = NULL; 	sem_t *sem2 = NULL; 	int ret;  #if 1 	//首先通过ftok申请一个IPC的key 	key = ftok(./1, 4); 	if((int)key < 0) 	{ 		perror(creat a ipc key fail); 		return -1; 	} 	printf(key value:%d\n, (int)key); #endif  	//申请一块共享内存 	shmid = shmget(key, 100, IPC_CREAT|0666);	 	if(shmid < 0) 	{ 		perror(creat a shm fail); 		return -1; 	}  	//映射到本用户进程 	shmaddr = shmat(shmid, NULL, 0); 	if((long)shmaddr < 0) 	{ 		perror(shm attach fail); 		return -1; 	}  	//创建一个posix有名信号量 	sem1 = sem_open(sem1, O_CREAT|O_RDWR, 0666, 1); 	if(sem1 == SEM_FAILED) 	{ 		perror(sem1 open fail); 		return -1; 	} 	 	//创建一个posix有名信号量 	sem2 = sem_open(sem2, O_CREAT|O_RDWR, 0666, 0); 	if(sem2 == SEM_FAILED) 	{ 		perror(sem2 open fail); 		return -1; 	} 	 	while(1) 	{ 		//P操作,等待信号量有效 		sem_wait(sem1);  		if(fgets(shmaddr, 11, stdin) != shmaddr) 		{ 			perror(get char from stdin fail); 			return -2; 		}  		//V操作,释放信号量 		sem_post(sem2);  		if(strncmp(quit, shmaddr, 4) == 0) 		{ 			printf(p1 ready toquit\n); 			break; 		} 	} 	 	//释放资源 	free_resource(shmaddr, shmid, sem1, sem2); 	 	return 0; }

程序p2.c

#include <stdio.h> #include <string.h> #include <stdlib.h> #include <error.h>  #include <sys/types.h> #include <sys/ipc.h> #include <sys/ipc.h> #include <sys/shm.h>  #include <fcntl.h>           /* For O_* constants */ #include <sys/stat.h>        /* For mode constants */ #include <semaphore.h>   int main(int argc, char **argv) { 	key_t key; 	int shmid; 	char *shmaddr = NULL; 	sem_t *sem1 = NULL; 	sem_t *sem2 = NULL; 	char read_buf[100] = {0};  #if 1 	//首先通过ftok申请一个IPC的key 	key = ftok(./1, 3); 	if((int)key < 0) 	{ 		perror(creat a ipc key fail); 		return -1; 	} #endif 	 	//申请一块共享内存 	shmid = shmget(key, 100, IPC_CREAT|0666);	 	if(shmid < 0) 	{ 		perror(creat a shm fail); 		return -1; 	}  	//映射到本用户进程 	shmaddr = shmat(shmid, NULL, 0); 	if((long)shmaddr < 0) 	{ 		perror(shm attach fail); 		return -1; 	}  	//创建一个posix有名信号量 	sem1 = sem_open(sem1, O_CREAT|O_RDWR, 0666, 1); 	if(sem1 == SEM_FAILED) 	{ 		perror(sem1 open fail); 		return -1; 	} 	 	//创建一个posix有名信号量 	sem2 = sem_open(sem2, O_CREAT|O_RDWR, 0666, 0); 	if(sem2 == SEM_FAILED) 	{ 		perror(sem2 open fail); 		return -1; 	} 	 	while(1) 	{ 		//P操作,等待信号量有效 		sem_wait(sem2);  		strncpy(read_buf, shmaddr, 10); 		printf(read info from shm:%s\n, read_buf); 		 		//V操作,释放信号量 		sem_post(sem1);  		if(strncmp(quit, read_buf, 4) == 0) 		{ 			printf(p2 ready toquit\n); 			break; 		} 	} 	 	//释放资源 	 	return 0; }

4.调试过程

新建一个普通文件,用于产生key

touch 1

 

编译程序:

gcc p1.c -o p1 -pthread
gcc p2.c -o p2 -pthread

打开两个终端,先运行p1,再运行p2

在p1所在终端输入数据,回车,效果如下:

 ​​​

 从上图可以看出,p1发送了数据,p2接收到了数据并打印出来。

最后在p1终端输入“quit”,退出进程;p2收到“quit”也退出进程,如下图:

5.参考资料

 关于共享内存的api函数如何使用,可以参考下面博主的文章:

版权声明:本文为CSDN博主「艾特号」的原创文章,遵循CC 4.0 BY-SA版权协议,转载请附上原文出处链接及本声明。
原文链接:https://blog.csdn.net/lpwsw/article/details/121932268

总结

以上就是今天要讲的内容,本文介绍了system-V的IPC对象和它的特点,并简要介绍了共享内存实现进程通信的案例。

关于共享内存操作的内容,今后再补充。