1.ipcs命令
IPC机制是一个让人烦恼的问题:编写错误的程序或因为某些原因而执行失败的程序将把它的IPC资源(如消息队列中的数据)遗留在系统里,并且这些资源在程序结束后很长时间让然在系统中游荡,这导致对程序的新调用执行失败,因为程序期望以一个干净的系统来启动,但事实上却发现一些遗留的资源。
状态命令ipcs和删除命令(ipcrm)提供了一种检查和清理IPC机制的方法
ipcs -s只查看信号量
ipcs -m只查看共享
ipcs -q只查看消息队列
ipcrm删除操作
例如:ipcrm -s semid;
重启一下,信号量等自动删除
2.共享内存介绍
共享内存为多个进程之间共享和传递数据提供了一种有效的方式。共享内存是先在物理地址上申请一块空间,多个进程可以将其映射到自己的虚拟地址空间中。所以进程都可以访问共享内存中的地址,就好像它们是由malloc分配的一样。如果某个进程向共享内存写入了数据,所做的改动将立刻被可以访问同一段共享内存的任何其他进程看到。
但是由于它并未提供同步机制,所以我们通常需要用其他的机制来同步对共享内存的访问。
5.共享内存函数介绍
1)shmget
int shmget(key_t key, size_t size, int shmflg);shmget()用于创建或者获取共享内存shmget()成功返回共享内存的 ID, 失败返回-1key: 不同的进程使用相同的 key 值可以获取到同一个共享内存,(这里的值和信号量的值一样也没有关系,因为类型不一样;)size: 创建共享内存时,指定要申请的共享内存空间大小shmflg: IPC_CREAT IPC_EXCL
2)shmat
void* shmat(int shmid, const void *shmaddr, int shmflg);shmat()将申请的共享内存的物理内存映射到当前进程的虚拟地址空间上shmat()成功返回返回共享内存的首地址,失败返回 NULL(像malloc一样给共享空间的起始地址),看帮助手册失败返回的是-1;shmaddr:一般给 NULL,由系统自动选择映射的虚拟地址空间shmflg: 一般给 0(给0就代表的可读可写), 可以给 SHM_RDONLY 为只读模式,其他的为读写
3)shmdt
int shmdt(const void *shmaddr);shmdt()断开当前进程的 shmaddr 指向的共享内存映射shmdt()成功返回 0, 失败返回-1//为什么不是删除共享内存而是断开共享内存呢?因为你不使用了,别的进程可能还在使用这块共享内存;//删除共享内存用shmctl,就是对共享内存做控制,那么可以设置,也可以删除,如下的函数;
4)shmctl
int shmctl(int shmid, int cmd, struct shmid_ds *buf);shmctl()控制共享内存shmctl()成功返回 0,失败返回-1cmd: IPC_RMID//删除的时候如果还有人在使用共享内存,这个函数就会延迟删除,等到最后一个进程断开链接它才会删除共享内存.//第三个参数,buf是一个结构指针,它指向共享内存模式和访问权限的结构。
3.共享内存的使用
代码演示例1:
进程a向共享内存写入数据(写一次hello),进程b从共享内存读取数据(读取hello)并显示.
main.c写入数据
test.c读取数据
//main.c
#include<stdio.h>
#include<stdlib.h>
#include<unistd.h>
#include<sys/shm.h>
#include<assert.h>
#include<string.h>
int main()
{int shmid=shmget((key_t)1234,256,IPC_CREAT|0600);//创建一块动态内存assert(shmid!=-1);char *s=(char*)shmat(shmid,NULL,0);//一般给0,0表示//将申请的共享内存的物理地址映射到当前进程的虚拟空间上//assert(s!=NULL);if(s==(char*)-1){exit(1);}strcpy(s,"hello");//把hello写到s里,即共享内存里写的就是helloshmdt(s);//断开当前进程的映射
}
//test.c
#include<stdio.h>
#include<stdlib.h>
#include<unistd.h>
#include<sys/shm.h>
#include<assert.h>
#include<string.h>
int main()
{int shmid=shmget((key_t)1234,256,IPC_CREAT|0600);//创建一块动态内存assert(shmid!=-1);char *s=(char*)shmat(shmid,NULL,0);//一般给0,0表示//将申请的共享内存的物理地址映射到当前进程的虚拟空间上//assert(s!=NULL);if(s==(char*)-1){exit(1);}printf("%s",s);//打印获取的地址里面的内容shmdt(s);//断开当前进程的映射shmctl(shmid,IPC_RMID,NULL);//删除共享内存exit(0);
}
结果:
代码演示例2:
进程 a 从键盘循环获取数据并拷贝到共享内存中,进程 b 从共享内存中获取并打印数据。要求进程 a 输入一次,进程 b 输出一次,进程 a 不输入,进程 b 也不输出。
我们要了解进程管理的P V操作:
P:代表对资源的申请(-1)
V:代表对资源的释放(+1)
代码如下:
//main.c
#include<stdio.h>
#include<stdlib.h>
#include<unistd.h>
#include<sys/shm.h>
#include<assert.h>
#include<string.h>
int main()
{int shmid=shmget((key_t)1234,256,IPC_CREAT|0600);//创建一块动态内存assert(shmid!=-1);char *s=(char*)shmat(shmid,NULL,0);//一般给0,0表示//将申请的共享内存的物理地址映射到当前进程的虚拟空间上//assert(s!=NULL);if(s==(char*)-1){exit(1);}//strcpy(s,"hello");//把hello写到s里,即共享内存里写的就是hellowhile(1){printf("input:\n");char buff[128]={0};fgets(buff,128,stdin);strcpy(s,buff);//把buff里面的东西拷贝到s里面if(strncmp(buff,"end",3)==0){break;}//输入end表示退出}shmdt(s);//断开当前进程的映射exit(0);}//test.c
#include<stdio.h>
#include<stdlib.h>
#include<unistd.h>
#include<sys/shm.h>
#include<assert.h>
#include<string.h>
int main()
{int shmid=shmget((key_t)1234,256,IPC_CREAT|0600);//创建一块动态内存assert(shmid!=-1);char *s=(char*)shmat(shmid,NULL,0);//一般给0,0表示//将申请的共享内存的物理地址映射到当前进程的虚拟空间上//assert(s!=NULL);if(s==(char*)-1){exit(1);}while(1){if(strncmp(s,"end",3)==0){break;}printf("read:%s\n",s);//打印获取的地址里面的内容sleep(1);}shmdt(s);//断开当前进程的映射shmctl(shmid,IPC_RMID,NULL);//删除共享内存exit(0);
}
这样会出问题, test.c如果没有sleep(1)就会疯狂的打印,所以共享内存必须结合信号量
正确做法:
遇到这类问题我们主要思考三个点:
1.信号量的个数
2.信号量的初始值
3.P V操作
//sem.h
#include<stdio.h>
#include<stdlib.h>
#include<unistd.h>
#include<sys/sem.h>#define SEM1 0
#define SEM2 1
#define SEM_MAX 2
union semun
{int val;
};
void sem_init();
void sem_p(int index);
void sem_v(int index);
void sem_destory();//sem.c
#include"sem.h"static int semid=-1;
void sem_init()
{semid=semget((key_t)1234,SEM_MAX,IPC_CREAT|IPC_EXCL|0600);//全新创建if(semid==-1){semid=semget((key_t)1234,SEM_MAX,0600);//失败了就再获取一下if(semid==-1){printf("sem failed!\n");//真的失败了return;}}else{union semun a;int arr[SEM_MAX]={1,0};for(int i=0;i<SEM_MAX;i++){a.val=arr[i];if(semctl(semid,i,SETVAL,a)==-1){printf("semctl setval failed!\n");}}}
}void sem_p(int index)
{if(index<0||index>=SEM_MAX){return;}struct sembuf a;a.sem_num=index;a.sem_op=-1;a.sem_flg=SEM_UNDO;if(semop(semid,&a,1)==-1){printf("semop p error!\n");}
}void sem_v(int index)
{if(index<0||index>=SEM_MAX){return;}struct sembuf a;a.sem_num=index;a.sem_op=1;a.sem_flg=SEM_UNDO;if(semop(semid,&a,1)==-1){printf("semop v error!\n");}
}void sem_destory()
{if(semctl(semid,0,IPC_RMID)==-1){printf("destory error!\n");}
}//main.c
#include"sem.h"
#include<stdio.h>
#include<stdlib.h>
#include<unistd.h>
#include<sys/shm.h>
#include<assert.h>
#include<string.h>
int main()
{int shmid=shmget((key_t)1234,256,IPC_CREAT|0600);//创建一块动态内存assert(shmid!=-1);char *s=(char*)shmat(shmid,NULL,0);//一般给0,0表示//将申请的共享内存的物理地址映射到当前进程的虚拟空间上//assert(s!=NULL);if(s==(char*)-1){exit(1);}//strcpy(s,"hello");//把hello写到s里,即共享内存里写的就是hellosem_init();while(1){printf("input:\n");char buff[128]={0};fgets(buff,128,stdin);sem_p(SEM1);strcpy(s,buff);//把buff里面的东西拷贝到s里面sem_v(SEM2);if(strncmp(buff,"end",3)==0){break;}//输入end表示退出}shmdt(s);//断开当前进程的映射exit(0);}//test.c
include"sem.h"
#include<stdio.h>
#include<stdlib.h>
#include<unistd.h>
#include<sys/shm.h>
#include<assert.h>
#include<string.h>
int main()
{int shmid=shmget((key_t)1234,256,IPC_CREAT|0600);//创建一块动态内存assert(shmid!=-1);char *s=(char*)shmat(shmid,NULL,0);//一般给0,0表示//将申请的共享内存的物理地址映射到当前进程的虚拟空间上//assert(s!=NULL);if(s==(char*)-1){exit(1);}sem_init();while(1){sem_p(SEM2);if(strncmp(s,"end",3)==0){break;} printf("read:%s\n",s);//打印获取的地址里面的内容sem_v(SEM1);//sleep(1);}shmdt(s);//断开当前进程的映射sem_destory();shmctl(shmid,IPC_RMID,NULL);//删除共享内存exit(0);
}
运行结果: