msgrcv()函数详解

函数原型

ssize_t msgrcv(int msqid, void *msgp, size_t msgsz, long msgtyp,int msgflg);

//从一个消息队列中获取消息

参数：

msgid:消息队列的ID

msgp:要接收消息的缓冲区

size:要接收的消息的字节数

msgtype:

0:接收消息队列中第一个消息

大于0：接收消息队列中第一个类型为msgtyp的消息

小于0：接收消息队列中类型值不大于msgtyp的绝对值且类型值又最小的消息。

flag:

0:若无消息函数一直阻塞

IPC_NOWAIT：若没有消息，进程会立即返回ENOMSG。

返回值：

成功：接收到的消息i长度

出错：‐1

#include #include #include #include #include #include struct msgbuf{long mtype;char mtest[128];char ID[4];};int main(){struct msgbuf sendbuf,readbuf;int msgid;int readret;msgid = msgget(IPC_PRIVATE,0755);if(msgid == -1){printf("create message queue failed!\n");return -1;}system("ipcs -q");printf("create message success msgid = %d\n",msgid);sendbuf.mtype = 100;printf("please input to message queue:\n"); fgets(sendbuf.mtest,128,stdin);msgsnd(msgid,(void *)&sendbuf,strlen(sendbuf.mtest),0);//while(1);//msgctl(32769,IPC_RMID,NULL);//system("ipcs -q");memset(readbuf.mtest,0,128);readret = msgrcv(msgid,(void *)&readbuf,128,100,0);printf("message is : %s\n",readbuf.mtest);printf("total have %d byth\n",readret);return 0;}

编译结果：

可以看到，当我们输入“hello world”时，通过我们的msgrcv()函数，成功从消息队列中读出。