自己如何实现消息队列
1、使用步骤：
1）创建：key_t key=ftok(PATH,proj); int msgid=msgget(key,IPC_CREAT | 0600)
2)发送：msgsnd(msgid,&msg,strlen(msg.mtext),0)
3)接收：msgrcv(msgid,&msg,strlen(msg.mtext),msg.mtype,0)
4)回收：msgctl(msgid,IPC_RMID,NULL)
2、实现读消息的代码：
#include <stdio.h>
#include <unistd.h>
#include <string.h>
#include <stdlib.h>
#include <fcntl.h>
#include <sys/ipc.h>
#include <sys/msg.h>
#define TXT_SIZE 100
struct msgbuf
{
long type;
char txt[TXT_SIZE];
};
int main()
{
key_t key; //生成KEY
key=ftok("/home/lbh",10);
int msgid;
if(-1 == (msgid=msgget(key,IPC_CREAT | 0660)))//创建消息队列
{
perror("msgget");
exit(-1);
}
struct msgbuf msg;
bzero(&msg,sizeof(msg));
msgrcv(msgid,&msg,sizeof(msg.txt),1,0);//接收消息
printf("I get msg:%s\n",msg.txt);
return 0;
}
3、实现写消息的代码：
#include <stdio.h>
#include <unistd.h>
#include <string.h>
#include <stdlib.h>
#include <fcntl.h>
#include <sys/ipc.h>
#include <sys/msg.h>
#define TXT_SIZE 100
struct msgbuf
{
long type;
char txt[TXT_SIZE];
};
int main()
{
key_t key; //生成KEY
key=ftok("/home/lbh",10);
int msgid;
if(-1 == (msgid=msgget(key,IPC_CREAT | 0660)))//创建
{
perror("msgget");
exit(-1);
}
struct msgbuf msg;
bzero(&msg,sizeof(msg));
msg.type=1;
strcpy(msg.txt,"hello");
msgsnd(msgid,&msg,strlen(msg.txt),0);//发送消息
return 0;
}
4、在终端窗口中使用命令“gcc msgq_read.c -o read”和 “gcc msgq_write.c -o write”编译，使用命令“./read”和“./write”执行，效果如下：
