Linux进程间通信(4)消息队列

Linux进程间通信(4)消息队列,第1张

Linux进程间通信(4)消息队列

消息队列
    • 消息队列原理
    • 消息队列接口介绍
    • 代码示例

消息队列原理

消息队列是消息的链表,存放在内核中并由消息队列标识符表示。
  消息队列提供了一个从一个进程向另一个进程发送数据块的方法,每个数据块都可以被认为是有一个类型,接受者接受的数据块可以有不同的类型。
  但是同管道类似,它有一个不足就是每个消息的最大长度是有上限的(MSGMAX),每个消息队列的总的字节数(MSGMNB),系统上消息队列的总数上限(MSGMNI)。可以用cat /proc/sys/kernel/msgmax查看具体的数据。
  内核为每个IPC对象维护了一个数据结构struct ipc_perm,用于标识消息队列,让进程知道当前 *** 作的是哪个消息队列。每一个msqid_ds表示一个消息队列,并通过msqid_ds.msg_first、msg_last维护一个先进先出的msg链表队列,当发送一个消息到该消息队列时,把发送的消息构造成一个msg的结构对象,并添加到msqid_ds.msg_first、msg_last维护的链表队列。
  特点:

  • 生命周期随内核,消息队列会一直存在,需要我们显示的调用接口删除或使用命令删除
  • 消息队列可以双向通信
  • 克服了管道只能承载无格式字节流的缺点

消息队列接口介绍

- 头文件

#include 
#include 
#include 
  • int msgget(key_t key, int msqflg);
msgget()创建或者获取一个消息队列
msgget()成功返回消息队列 ID,失败返回-1
 msqflg: IPC_CREAT
  • *int msgsnd( int msqid, const void msqp, size_t msqsz, int msqflg);
msgsnd()发送一条消息,消息结构为:
struct msgbuf
{
 long mtype; // 消息类型, 必须大于 0
 char mtext[1]; // 消息数据
 };
 msgsnd()成功返回 0, 失败返回-1
 msqsz: 指定 mtext 中有效数据的长度
 msqflg:一般设置为 0 可以设置 IPC_NOWAIT
  • ssize_t msgrcv( int msqid, void *msgp, size_t msqsz, long msqtyp, int
    msqflg);
msgrcv()接收一条消息
msgrcv()成功返回 mtext 中接收到的数据长度, 失败返回-1
msqtyp: 指定接收的消息类型,类型可以为 0
msqflg: 一般设置为 0 可以设置 IPC_NOWAIT
  • int msgctl( int msqid, int cmd, struct msqid_ds *buf);
msgctl()控制消息队列
msgctl()成功返回 0,失败返回-1
cmd: IPC_RMID
代码示例

进程 a 发送一条消息,进程 b 读取消息。

a.c :

#include
#include
#include
#include
#include


struct mess
{
    long type;
    char data[32];
};
int main()
{

    int msgid = msgget((key_t)1234,IPC_CREAT|0600);//
    if( msgid ==-1)
    {
        printf("msget errn");
        exit(0);
    }
    struct mess dt;
    dt.type =1;
    strcpy(dt.data,"hello word");//
    msgsnd(msgid,&dt,32,0);//把消息添加到消息队列中:&dt指向准备发消息的指针(长整型)32 指向消息的长度,不包括长整型消息内型成员变量长度
}

b.c

#include
#include
#include
#include
#include


struct mess
{
    long type;
    char data[32];
};
int main()
{
 int msgid = msgget((key_t)1234,IPC_CREAT|0600);
 if(msgid ==-1)
 {
     printf("msgget errn");
     exit(0);
 }

 struct mess dt;
 msgrcv(msgid,&dt,32,1,0);//migid 由函数返回消息队列标识符/&dt 指向准备接收消息的指针
 printf("dt.data=%sn",dt.data);
}

欢迎分享,转载请注明来源:内存溢出

原文地址: http://outofmemory.cn/zaji/5659474.html

(0)
打赏 微信扫一扫 微信扫一扫 支付宝扫一扫 支付宝扫一扫
上一篇 2022-12-16
下一篇 2022-12-16

发表评论

登录后才能评论

评论列表(0条)

保存