目录
一、消息队列的定义
二、相关函数
2.1 msgget 函数
2.2 msgsnd 函数
2.3 msgrcv 函数
2.4 msgctl 函数
三、消息队列的操作
3.1 创建消息队列
3.2 获取消息队列并发送消息
3.3 从消息队列接收消息recv
四、 删除消息队列
4.1 ipcrm
4.2 msgctl函数
一、消息队列的定义
消息队列是一种用于在应用程序之间传递和存储数据的通信机制。它允许应用程序将消息发送到队列中，然后由另一个应用程序从队列中接收和处理这些消息。消息队列可以有效地实现异步通信、解耦应用程序之间的依赖关系，以及实现消息的持久化和顺序处理。常见的消息队列系统包括RabbitMQ、Kafka、ActiveMQ等。消息队列在现代分布式系统和微服务架构中被广泛应用。
二、相关函数
2.1 msgget 函数
msgget()创建或者获取一个消息队列
函数模型：
int msgget(key_t key,int msqflg);函数参数：
1.msqflg： IPC_CREAT
返回值：msgget()成功返回消息队列 ID，失败返回-1
2.2 msgsnd 函数
函数模型：
int msgsnd(int msqid, const void *msqp, size_t msqsz, int msqflg);msgsnd()发送一条消息，消息结构为：struct msgbuf{long mtype; // 消息类型， 必须大于 0char mtext[1]; // 消息数据}
函数参数：1.msqsz： 指定 mtext 中有效数据的长度2.msqflg：一般设置为 0 可以设置 IPC_NOWAIT返回值：msgsnd()成功返回 0， 失败返回-1
2.3 msgrcv 函数
msgrcv() 接收一条消息
函数模型：
ssize_t msgrcv(int msqid, void *msgp, size_t msqsz, long msqtyp, int msqflg);函数参数：
1.msqtyp： 指定接收的消息类型，类型可以为 02.msqflg： 一般设置为 0 可以设置 IPC_NOWAIT返回值：msgrcv()成功返回 mtext 中接收到的数据长度， 失败返回-1
2.4 msgctl 函数
msgctl() 控制消息队列
函数模型：
int msgctl(int msqid, int cmd, struct msqid_ds *buf);函数参数：
cmd： IPC_RMID返回值：
msgctl()成功返回 0，失败返回-1
三、消息队列的操作
3.1 创建消息队列
#include<stdio.h>
#include<stdlib.h>
#include<unistd.h>
#include<string.h>
#include<sys/msg.h>int main()
{int msgid=msgget((key_t)1234,IPC_CREAT|0600);if(msgid==-1){printf("msgid err\n");exit(1);}}
通过ipcs 命令查看是否已经创建好了消息队列
3.2 获取消息队列并发送消息
#include<stdio.h>
#include<stdlib.h>
#include<unistd.h>
#include<string.h>
#include<sys/msg.h>struct mess
{long type;char buff[32];
};int main()
{int msgid=msgget((key_t)1234,IPC_CREAT|0600);if(msgid==-1){printf("msgid err\n");exit(1);}struct mess dt;dt.type=1;//1类型消息strcpy(dt.buff,"hello1");msgsnd(msgid,(void*)&dt,32,0);}
ipcs -q 只显示消息队列
ipcs -m 只显示共享内存
ipcs -s 只显示信号量
msgsnd 函数 发送消息：
msgsnd(msgid, &dt, 32, 0); 使用 msgsnd 函数向消息队列发送消息。msgid 是之前通msgget 获取的消息队列标识符；
msgid是往哪个消息队列中添加；
&dt 是指向要发送的消息结构体的指针；
32 是要发送的消息数据的长度；
0 是消息发送的标志，这里使用默认值。
3.3 从消息队列接收消息recv
#include<stdio.h>
#include<stdlib.h>
#include<unistd.h>
#include<string.h>
#include<sys/msg.h>struct mess
{long type;char buff[32];
};int main()
{int msgid=msgget((key_t)1234,IPC_CREAT|0600);if(msgid==-1){printf("msgid err\n");exit(1);}struct mess dt;msgrcv(msgid,&dt,32,1,0);printf("recv:%s\n",dt.buff);
}
运行此文件，会发现消息队列数会随执行的次数增加而减少
并且运行三次之后消息读完了再运行会堵塞
四、 删除消息队列
4.1 ipcrm
删除消息队列中的消息用 ipcrm -q msqid 的号。
4.2 msgctl函数
#include <stdio.h>
#include <stdlib.h>
#include <unistd.h>
#include <string.h>
#include <sys/msg.h>struct mess
{long type; char buff[32];
};int main()
{int msgid = msgget((key_t)1234, IPC_CREAT|0600);if (msgid == -1) {printf("msgget err\n");exit(1);}struct mess dt;msgrcv(msgid, &dt, 32, 2, 0);//意思读2号消息printf("read msg:%s\n", dt.buff);//打印消息msgctl(msgid,IPC_RMID,NULL);
}
