消息隊列是将消息按隊列的方式組織成的連結清單,每個消息都是其中的一個節點。
消息隊列的操作函數有一下幾個:
int msgget(key_t key, int msgflg) //建立1個消息隊列
int msgsnd(int msqid, const void *msgptr, int msgsz , int msgflg) //發送消息到消息隊列中
int msgrcv (int msqid,void *msgptr, int msgsz ,long msgtyp, int msgflag) //從消息隊列中讀取一個消息
int msgctl (int msqid, int cmd ,struct msqid_ds *buf) //消息隊列控制函數
示例如下:
#include <string.h>
#include <sys/types.h>
#include <sys/msg.h>
#include <unistd.h>
#include <stdlib.h>
#include <stdio.h>
int main(void)
{
int msg_id,msg_flags;
int reval;
char send_msg[64];
msg_flags = IPC_CREAT | 0666;
msg_id = msgget((key_t)456,msg_flags); //建立消息隊列并傳回消息隊列id
if(-1 == msg_id) //判斷是否建立成功(傳回-1 為失敗)
{
printf("msg create error.\n");
exit(EXIT_FAILURE);
}
memset(send_msg,0,64);
sprintf(send_msg,"hi, I'm %d.\n",getpid()); // 列印字元串到send_msg 中
reval = msgsnd(msg_id,send_msg,sizeof(send_msg),0);//将send_msg中的消息發送到消息隊列中,消息隊列的id為msg_id
if(-1 == reval) //發送消息失敗傳回-1
{
printf("message send error.\n");
exit(EXIT_FAILURE);
}
else
printf("Send message:%s\n",send_msg);
return 0;
}
#include <string.h>
#include <sys/types.h>
#include <sys/msg.h>
#include <unistd.h>
#include <stdlib.h>
#include <stdio.h>
int main(void)
{
int msg_id,msg_flags;
int reval;
char send_msg[64];
msg_flags = IPC_CREAT | 0666;
msg_id = msgget((key_t)456,msg_flags);
if(-1 == msg_id) //判斷是否建立成功(傳回-1 為失敗)
{
printf("msg create error.\n");
exit(EXIT_FAILURE);
}
memset(send_msg,0,64);
reval = msgrcv(msg_id,send_msg,64,0,0);//從消息隊列中讀取一個消息
if(-1 == reval) //發送消息失敗傳回-1
{
printf("message send error.\n");
exit(EXIT_FAILURE);
}
else
printf("Received message:%s\n",send_msg);
reval = msgctl(msg_id,IPC_RMID,0);
if(-1 == reval)
{
printf("remove msg queue error\n");
exit(EXIT_FAILURE);
}
return 0;
}