本文共 2710 字,大约阅读时间需要 9 分钟。
消息队列就是一个消息的链表。而一条消息则可看作一个记录,具有特定的格式。进程可以按照一定的规则往消息队列中添加新消息;另一些进程则可以从消息队列中读走消息。
消息的格式结构为:struct msgbuf{ long mtype; /*消息类型,大于0;如果等于或者小于0则无法写入消息队列中*/ char mtext[1]; /*消息主体数据*/}
常用到的函数有:
原型:int msgget(key_t key,int msgflg)头文件:功能:创建/获取一个消息队列,成功返回消息队列id,失败返回-1参数:key:键值 msgflg:打开标志,如为IPC_CREAT表示若不存在与键值key对应的消息队列则创建一个新的消息队列
原型:int msgsnd(int msgid,const void *msgp,size_t msgsz,int msgflg)头文件:功能:往消息队列写入消息,成功返回0,失败返回-1参数:msgid:消息队列id msgp:一个struct msgbuf结构指针,指向的结构存储着要发送的消息 msgsz:发送的消息的大小,只包括主体数据mtext[1],不包括消息类型 msgflg:标志
原型:ssize_t msgrcv(int msgid,void *msgp,size_t msgsz,long msgtyp,int msgflg)头文件:功能:从消息队列读取消息。成功返回读取到的数据量大小,只包括主体数据mtext[1];失败返回-1参数:msgid:消息队列id msgp:一个struct msgbuf结构指针,用来存储读取到的消息 msgsz:希望读取的数据长度 msgtyp:若为0,则读取消息队列中第一条消息;若大于0,则取消息队列中第一条消息类型等于msgtyp的消息;若小于0,则取消息类型小于或等于msgtyp的绝对值的消息,若有多条消息符合条件,则取类型最小的一条 msgflg:标志
msgflg原型:int msgctl(int msgid,int cmd,struct msgid_ds *buf)头文件:功能:控制消息队列,成功返回0,失败返回-1参数:msgid:消息队列idcmd:操作命令,IPC_RMID用于删除消息队列buf:用于读取Linux系统中关于该消息队列的msqid_ds,一般不用。
进程A:
#include#include #include #include #include void main(){ /*创建消息队列*/ key_t key=ftok("/home/jx/processA",1);/*指定键值*/ int msgid=msgget(key,IPC_CREAT); /*构造消息*/ typedef struct { long mtype; char mtext[1024]; }msgp,*msgp_ptr; msgp msgpa; msgp_ptr msgpa_ptr=&msgpa; while(1) { printf("please enter the type of message,9 for exit:"); scanf("%d",&msgpa.mtype); if(msgpa.mtype==9) { strcpy(msgpa_ptr->mtext,"exit"); msgsnd(msgid,msgpa_ptr,sizeof(msgp),0); break; } printf("please enter the text of message:"); scanf("%s",msgpa.mtext); /*发送消息*/ msgsnd(msgid,msgpa_ptr,sizeof(msgp),0); }}
进程B:
#include#include #include #include #include void main(){ /*获取消息队列*/ key_t key=ftok("/home/jx/processA",1); int msgid=msgget(key,IPC_CREAT); /*读取消息*/ typedef struct { long mtype; char mtext[1024]; }msgp,*msgp_ptr; msgp msgpa; msgp_ptr msgpa_ptr=&msgpa; while(1) { msgrcv(msgid,msgpa_ptr,sizeof(msgp),0,0); if((msgpa_ptr->mtype==9)&&(strcmp(msgpa_ptr->mtext,"exit")==0)) break; else { printf("the message is:%s\n",msgpa_ptr->mtext); } } /*删除消息队列*/ struct msqid_ds *buf; msgctl(msgid,IPC_RMID,buf);}
转载地址:http://lmigi.baihongyu.com/