151-Linux消息队列

以你之姓@ 2023-01-11 03:42 146阅读 0赞

## Linux消息队列 ##

是在内存中创建的，读取效率非常高  
**分为添加消息，读取消息两个动作**  
**消息是一个结构体。第一个成员是类型（大于等于1的值）。**  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L0xJTlpFWVU2NjY_size_16_color_FFFFFF_t_70_pic_center]  
**发送消息，需要设置消息类型。读取的时候要指定消息类型**  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L0xJTlpFWVU2NjY_size_16_color_FFFFFF_t_70_pic_center 1]  
**如：1号消息，2号消息**  
**由程序员去确定消息的类型。**

## 消息的方法 ##

#include <sys/types.h>
    #include <sys/ipc.h>
    #include <sys/msg.h>
    
    /*
    msgget()创建或者获取一个消息队列
    msgget()成功返回消息队列 ID，失败返回-1
    msqflg： IPC_CREAT
    */
    int msgget(key_t key, int msqflg); 
    
    
    /*
    msgsnd()发送一条消息，消息结构为：
    struct msgbuf
    {
    long mtype; // 消息类型， 必须大于 0 ，必须是long类型
    char mtext[1]; // 消息数据 我们可以自定义类型
    };
    msgsnd()成功返回 0， 失败返回-1
    msqsz： 指定 mtext 中有效数据的长度
    msqflg：一般设置为 0（满了，自动阻塞住） 可以设置 IPC_NOWAIT
    */
    int msgsnd(int msqid, const void *msqp, size_t msqsz, int msqflg); 
    
    
    /*
    msgrcv()接收一条消息
    msgrcv()成功返回 mtext 中接收到的数据长度， 失败返回-1
    msqtyp： 指定接收的消息类型，类型可以为 0
    msqflg： 一般设置为 0 可以设置 IPC_NOWAIT
    msgp 和写入的是同一个类型的结构体
    */
    ssize_t msgrcv(int msqid, void *msgp, size_t msqsz, long msqtyp, int msqflg); 
    
    
    /*
    msgctl()控制消息队列
    msgctl()成功返回 0，失败返回-1
    cmd： IPC_RMID
    设置或者删除消息
    */
    int msgctl(int msqid, int cmd, struct msqid_ds *buf);

**消息添加满了也会阻塞住**  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L0xJTlpFWVU2NjY_size_16_color_FFFFFF_t_70_pic_center 2]  
每运行一次，就添加1次消息

## 进程 a 写入一条消息，进程 b 读取消息 ##

**vi a.c**

#include <stdio.h>
    #include <stdlib.h>
    #include <unistd.h>
    #include <assert.h>
    #include <string.h>
    #include <sys/msg.h>
    
    typedef struct msgdata//定义消息
    {
        
    	long mtype;//类型
    	char buff[128];
    }MsgData;
    
    int main()
    {
        
    	int msgid = msgget((key_t)1234, 0664 | IPC_CREAT);
    	assert(msgid != -1);
    
    	MsgData data;
    	memset(&data, 0, sizeof(data));
    	data.mtype = 1;// >=1
    	strcpy(data.buff, "hello1");
    
    	msgsnd(msgid, &data, 128, 0);//给数据的大小：128 发送消息 把整体结构体都添加到消息队列中，不管你写多少字节，把整个都添加进去
    	exit(0);
    }

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L0xJTlpFWVU2NjY_size_16_color_FFFFFF_t_70_pic_center 3]

**vi b.c**

#include <stdio.h>
    #include <stdlib.h>
    #include <unistd.h>
    #include <assert.h>
    #include <string.h>
    #include <sys/msg.h>
    
    typedef struct msgdata
    {
        
    	long mtype;
    	char buff[128];
    }MsgData;
    
    int main()
    {
        
    	int msgid = msgget((key_t)1234, 0664 | IPC_CREAT);
    	assert(msgid != -1);
    
    	MsgData data;
    	memset(&data, 0, sizeof(data));
    
    	msgrcv(msgid, &data, 128, 1, 0);//把数据恢复成结构体读出
    	printf("data.type: %d\n", data.mtype);
    	printf("data.text: %s\n", data.buff);
    
    	msgctl(msgid, IPC_RMID, NULL);
    	exit(0);
    }

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L0xJTlpFWVU2NjY_size_16_color_FFFFFF_t_70_pic_center 4]  
**运行结果如下：**  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L0xJTlpFWVU2NjY_size_16_color_FFFFFF_t_70_pic_center 5]  
**读一次消息，就少1条  
如果读取2号类型消息**  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L0xJTlpFWVU2NjY_size_16_color_FFFFFF_t_70_pic_center 6]  
**阻塞住了，因为没有2号类型消息**  
**可以添加2号类型消息来解决阻塞情况**

消息类型要>=1,因为0有特殊的意义

如果接收消息设置为0，接收所有消息，不区分消息的类型  
但是发送时不能把消息设置为0

**消息队列为空或者满，运行程序，自动阻塞**  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L0xJTlpFWVU2NjY_size_16_color_FFFFFF_t_70_pic_center 7]

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L0xJTlpFWVU2NjY_size_16_color_FFFFFF_t_70_pic_center]: /images/20221119/738548007510447dab3dc45d54e5778a.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L0xJTlpFWVU2NjY_size_16_color_FFFFFF_t_70_pic_center 1]: https://img-blog.csdnimg.cn/20210125202615705.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L0xJTlpFWVU2NjY=,size_16,color_FFFFFF,t_70#pic_center
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L0xJTlpFWVU2NjY_size_16_color_FFFFFF_t_70_pic_center 2]: https://img-blog.csdnimg.cn/20210125203935562.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L0xJTlpFWVU2NjY=,size_16,color_FFFFFF,t_70#pic_center
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L0xJTlpFWVU2NjY_size_16_color_FFFFFF_t_70_pic_center 3]: https://img-blog.csdnimg.cn/20210125204149313.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L0xJTlpFWVU2NjY=,size_16,color_FFFFFF,t_70#pic_center
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L0xJTlpFWVU2NjY_size_16_color_FFFFFF_t_70_pic_center 4]: https://img-blog.csdnimg.cn/20210125204312831.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L0xJTlpFWVU2NjY=,size_16,color_FFFFFF,t_70#pic_center
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L0xJTlpFWVU2NjY_size_16_color_FFFFFF_t_70_pic_center 5]: https://img-blog.csdnimg.cn/20210125204430836.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L0xJTlpFWVU2NjY=,size_16,color_FFFFFF,t_70#pic_center
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L0xJTlpFWVU2NjY_size_16_color_FFFFFF_t_70_pic_center 6]: https://img-blog.csdnimg.cn/20210125204535891.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L0xJTlpFWVU2NjY=,size_16,color_FFFFFF,t_70#pic_center
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L0xJTlpFWVU2NjY_size_16_color_FFFFFF_t_70_pic_center 7]: https://img-blog.csdnimg.cn/20210125205119817.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L0xJTlpFWVU2NjY=,size_16,color_FFFFFF,t_70#pic_center