1.消息队列的原理：

2.消息队列的接口：

（1）创建消息队列

（2）向消息队列发送消息

（3）接收消息

（4）操作消息队列的接口

1.消息队列的原理：

消息队列（messagequeue）以链表作为基础，实现消息队列，由操作系统维护该链表

操作系统中，使用消息队列描述符（qid）来区分每个消息队列（qid是唯一的）

进程在消息队列的末尾增加消息，需要信息的进程按照所需的类型在队列中取消息

2.消息队列的接口：

（1）创建消息队列

int megget(key_t,int msgflg)

参数：

key：消息队列的标识符

megflg：创建的标志，如IPC_CREAT

IPC_CREAT :如果不存在就创建，按位或上一个权限

返回值：

成功：返回队列ID

失败：返回-1，并设置erron

2）向消息队列发送消息

int msgsnd（int msqid, const void *msgp, size_t msgsz, int msgflg）

参数：

msqid：消息队列的ID

msgp：指向msgbuf的指针，用来发送指定的消息，在写msgsnd、msgrev函数时，要提前定义该结构体，主要是指定mtext大小。

msgp指向的msgbuf为发送的结构体，操作系统指定了函数发送消息的格式，只定义了一部分，mtext可以由程序员自己改变。

msgsz：要发送的消息的长度，该参数的值不是表示msgp指向的msgbuf结构体的大小，而是该结构体中mtext的大小。

msgflg：创建标记，如果指定了IPC_NOWAIT，失败会立即返回。

0：阻塞发送

IPC_NOWAIT：非阻塞发送

返回值：

0：成功

-1：失败，并设置errno

(3）接收消息

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

参数：

msgid：消息队列的ID

msgp：指向msgbuf的指针，用来接收消息

**struct msgbuf{……}为输出型参数

msgsz：需要接受的消息的长度，注意msgsz是由msgp所指向的结构体的成员 mtext的最大大小决定的（byte）

msgtyp有三种形式：

1.msgtyp=0：读取队列的第一个消息

2.msgtyp>0：读取队列类型为msgtyp的第一条消息，除非在msgflg中指定了 MSG_EXCEPT，否则将读取类型不等于 megtyp的队列中的第一条消息，

3.msgtyp<0:读取队列中最小类型小于或等于msgtyp绝对值的第一条消息

msgflg：创建标记，若指定了IPC_NOWAIT，获取失败后就直接返回

（4）操作消息队列的接口

int msgctl(int msqid , int cmd, struct msqid_ds *buf)

参数：

msqid：消息队列的ID

cmd：控制命令：

IPC_RMID,删除命令

IPC_STAT,获取命令

buf：存储队列的相关信息的buf

返回值：

成功：根据不同的cmd有不同的返回值

失败：返回-1，并设置errno

5.代码实现：

写端发送消息，读端从队列读取

mesgrcv:

#include<stdio.h>
#include<unistd.h>
#include<sys/msg.h>
#include<sys/ipc.h>struct msgbuf
{long mtype;char mtext[1024];};int main()
{int msg_id=msgget(0x06060606,IPC_CREAT|0664);if(msg_id<0 )
{perror("msgget \n" );
return 0;
}printf("msggqueued id is %d\n",msg_id );
struct msgbuf mq;
msgrcv(msg_id,&mq,sizeof(mq.mtext),1,0);
printf("接受的消息：%s \n",mq.mtext);return 0;
}

msgsnd:

#include<stdio.h>
#include<unistd.h>
#include<sys/msg.h>struct msgbuf
{long mtype;        //message typechar mtext[512];   //message data};int main()
{int msg_qid=msgget(0x06060606,IPC_CREAT|0664);if(msg_qid<0 ){perror("msgget\n");return 0;}struct msgbuf mq;int i;for(i=0;i<10;i++){mq.mtype=i+1;sprintf(mq.mtext,"%s,%d ","xxxxxxxxxx ",i+1);msgsnd(msg_qid,&mq,sizeof(mq.mtext),0);}return 0;
}

查看系统中的message queue：

当多次读出时，由于消息已经出了队列，所以不能再读出。

Linux进程通信之消息队列相关推荐

python笔记 7-8 进程池进程通信迭代器消息队列 Queue 协程和正则表达式
day7 进程进程池进程通信迭代器消息队列 Queue 作用用于多个进程间的通信操作put放入消息(值) put_nowait() 放入值,不等待如果队满,则报错 get获取消息(值) ...
linux进程间通讯-消息队列
文章目录 IPC对象查看已经创建的IPC对象: 消息队列概述消息队列的概念消息队列的特点在ubuntu 12.04中消息队列限制值如下 ftok函数创建消息队列 -- msgget( ) 发 ...
Linux进程通信的四种方式——共享内存、信号量、无名管道、消息队列｜实验、代码、分析、总结
Linux进程通信的四种方式--共享内存.信号量.无名管道.消息队列|实验.代码.分析.总结每个进程各自有不同的用户地址空间,任何一个进程的全局变量在另一个进程中都看不到,所以进程之间要交换数据必须 ...
Linux C 进程间的IPC通信之消息队列（2）
Linux C 进程间的IPC通信之消息队列双向通信代码:(进程1) 1 #include <stdio.h>2 #include <sys/msg.h>3 #incl ...
【Linux】Linux进程间通信——共享内存/消息队列/守护进程
文章目录进程间通信--共享内存/守护进程一, 共享内存 1. 共享内存概念 2. 共享内存使用 1. 共享内存使用步骤 2. 共享内存操作函数 3. 共享内存常用操作命令 4. 共享内存使用示例: ...
linux进程间通信：POSIX 消息队列 ----异步通信
在上一篇中linux进程间通信:POSIX 消息队列我们知道消息队列中在消息个数达到了队列所能承载的上限,就会发生消息的写阻塞. 阻塞式的通信影响系统效率,进程之间在通信收到阻塞时并不能去做其他事情, ...
linux进程间通信：POSIX 消息队列
文章目录基本介绍相关编程接口编程实例消息队列通信实例消息队列属性设置实例基本介绍关于消息队列的基本介绍,前面在学习system V的消息队列时已经有过了解,linux进程间通信:syst ...
linux 进程通信比较,浅析Linux进程通信的几种方式及其比较
摘要:本文通过对Linux下几种主要通信方式进行概述,并结合Linux系统的系统调用对OS中的实现进行简要概述,并对其优缺点进行分析,阐述了在不同通信情况下应该选择何种通信方式进行选择. 关键词:Li ...
Linux进程间通信(管道、消息队列、共享内存、信号、信号量)
目录 Linux进程间通信概述 1.管道无名管道(pipe) 有名管道(fifo) 2.消息队列(msg) 消息队列的通信原理消息队列相关api 消息队列收发数据键值生成消息队列移除 3.共享 ...

Linux进程通信之消息队列

1.消息队列的原理：

2.消息队列的接口：

（1）创建消息队列

2）向消息队列发送消息

(3）接收消息

（4）操作消息队列的接口

5.代码实现：

Linux进程通信之消息队列相关推荐

最新文章

热门文章