Linux IPC实践(4) --System V消息队列(1)

简介: 消息队列概述   消息队列提供了一个从一个进程向另外一个进程发送一块数据的方法(仅局限于本机);   每个数据块都被认为是有一个类型,接收者进程接收的数据块可以有不同的类型值.

消息队列概述

   消息队列提供了一个从一个进程向另外一个进程发送一块数据的方法(仅局限于本机);

   每个数据块都被认为是有一个类型,接收者进程接收的数据块可以有不同的类型值.

   消息队列也有管道一样的不足: (1)每个消息的最长字节数的上限(MSGMAX); (2)系统中消息队列的总条数也有一个上限(MSGMNI); (3)每个消息队列所能够保存的总字节数是有上限的(MSGMNB) .

 

查看系统限制

   cat /proc/sys/kernel/msgmax  #最大消息长度限制

   cat /proc/sys/kernel/msgmnb  #消息队列总的字节数

   cat /proc/sys/kernel/msgmni  #消息条目数

 

 

管道 vs. 消息队列

管道

消息

流管道

有边界

先进先出

可以后进先出


IPC对象数据结构

//内核为每个IPC对象维护一个数据结构
struct ipc_perm
{
    key_t          __key;       /* Key supplied to msgget(2) */
    uid_t          uid;         /* Effective UID of owner */
    gid_t          gid;         /* Effective GID of owner */
    uid_t          cuid;        /* Effective UID of creator */
    gid_t          cgid;        /* Effective GID of creator */
    unsigned short mode;        /* Permissions */
    unsigned short __seq;       /* Sequence number */
};
//消息队列特有的结构
struct msqid_ds
{
    struct ipc_perm msg_perm;     /* Ownership and permissions 各类IPC对象所共有的数据结构*/
    time_t          msg_stime;    /* Time of last msgsnd(2) */
    time_t          msg_rtime;    /* Time of last msgrcv(2) */
    time_t          msg_ctime;    /* Time of last change */
    unsigned long   __msg_cbytes; /* Current number of bytes in queue (nonstandard) 消息队列中当前所保存的字节数 */
    msgqnum_t       msg_qnum;     /* Current number of messages in queue 消息队列中当前所保存的消息数 */
    msglen_t        msg_qbytes;   /* Maximum number of bytes allowed in queue 消息队列所允许的最大字节数 */
    pid_t           msg_lspid;    /* PID of last msgsnd(2) */
    pid_t           msg_lrpid;    /* PID of last msgrcv(2) */
};

消息队列在内核中的表示

 

消息在消息队列中是以链表形式保存的, 每个节点的类型类似如下:

struct msq_Node
{
    Type msq_type;  //类型
    Length msg_len; //长度
    Data msg_data;  //数据

    struct msg_Node *next;
};

消息队列API

#include <sys/types.h>
#include <sys/ipc.h>
#include <sys/msg.h>
int msgget(key_t key, int msgflg);
int msgctl(int msqid, int cmd, struct msqid_ds *buf);
int msgsnd(int msqid, const void *msgp, size_t msgsz, int msgflg);
ssize_t msgrcv(int msqid, void *msgp, size_t msgsz, long msgtyp, int msgflg);

msgget

功能:用来创建访问一个消息队列

int msgget(key_t key, int msgflg);

参数:

  key: 某个消息队列的名字

  msgflg:由九个权限标志构成,如0644,它们的用法和创建文件时使用的mode模式标志是一样的(但是消息队列没有x(执行)权限)

返回值:

  成功返回消息队列编号,即该消息队列的标识码;失败返回-1


msgget调用关系图

/** 示例1: 在msgflg处指定IPC_CREAT, 如果不存在该消息队列, 则创建之**/
int main(int argc, char *argv[])
{
    //指定IPC_CREAT,如果不存在, 则创建消息队列
    int msgid = msgget(1234, 0666|IPC_CREAT);
    if (msgid == -1)
        err_exit("msgget error");
    cout << "msgget success" << endl;
}
/** 示例2:IPC_CREAT|IPC_EXCL, 如果该消息队列已经存在, 则返回出错 **/
int main(int argc, char *argv[])
{
    //指定IPC_EXCL, 如果已经存在,则报告文件已经存在(错误)
    int msgid = msgget(1234, 0666|IPC_CREAT|IPC_EXCL);
    if (msgid == -1)
        err_exit("msgget error");
    cout << "msgget success" << endl;
}
/**示例3:将key指定为IPC_PRIVATE(值为0)
将key指定为IPC_PRIVATE之后,则msgget就一定会创建一个新的消息队列,
而且每次创建的消息队列的描述符都是不同的! 因此, 除非将MessageID(key)传送给其他进程(除非有关联的进程),其他进程也无法使用该消息队列(血缘fork除外)
因此, IPC_PRIVATE创建的消息队列,只能用在与当前进程有关系的进程中使用!
**/
int main(int argc, char *argv[])
{
    //指定IPC_PRIVATE
    int msgid = msgget(IPC_PRIVATE, 0666|IPC_CREAT|IPC_EXCL);
    if (msgid == -1)
        err_exit("msgget error");
    cout << "msgget success" << endl;
}
/** 示例4: 仅打开消息队列时, msgflg选项可以直接忽略(填0), 此时是以消息队列创建时的权限进行打开
**/
int main(int argc, char *argv[])
{
    int msgid = msgget(1234, 0);
    if (msgid == -1)
        err_exit("msgget error");
    cout << "msgget success" << endl;
    cout << "msgid = " << msgid << endl;
}
//示例5:低权限创建,高权限打开
int main()
{
    //低权限创建
    int msgid = msgget(0x255,0444 | IPC_CREAT);
    if (msgid < 0)
        err_exit("mesget error");
    else
        cout << "Create Mes OK, msgid = " << msgid << endl;

    //高权限打开
    msgid = msgget(0x255,0644 | IPC_CREAT);
    if (msgid < 0)
        err_exit("mesget error");
    else
        cout << "Create Mes OK, msgid = " << msgid << endl;
}


msgctl函数

功能:获取/设置消息队列的信息

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

参数:

   msqid: 由msgget函数返回的消息队列标识码

   cmd:是将要采取的动作(见下)

 

cmd:将要采取的动作(有三个可取值),分别如下:

/** 示例1: IPC_RMID, 删除消息队列
注意: 消息队列并没有运用”引用计数”的功能
**/
int main()
{
    int msgid = msgget(1234, 0);
    if (msgid == -1)
        err_exit("msgget error");
    if (msgctl(msgid, IPC_RMID, NULL) == -1)
        err_exit("msgctl IPC_RMID error");
    cout << "msgctl IPC_RMID success" << endl;
}
/** 示例2: IPC_STAT
**/
int main()
{
    int msgid = msgget(0x255, 0666|IPC_CREAT);
    if (msgid == -1)
        err_exit("msgget error");

    struct msqid_ds buf;
    if (msgctl(msgid,IPC_STAT,&buf) == -1)
        err_exit("msgctl error");

    printf("buf.msg_perm.mode = %o\n",buf.msg_perm.mode);   //%o以八进制打印
    printf("buf.__key = %x\n", buf.msg_perm.__key);         //%x以十六进制打印
    cout << "buf.__msg_cbytes = " << buf.__msg_cbytes << endl;
    cout << "buf.msg_qbytes = " << buf.msg_qbytes << endl;
    cout << "buf.msg_lspid = " << buf.msg_lspid << endl;
}
/** 实践:IPC_SET,一般需要先获取,然后再设置
**/
int main()
{
    int msgid = msgget(0x255, 0);
    if (msgid == -1)
        err_exit("msgget error");

    //获取消息队列的属性
    struct msqid_ds buf;
    if (msgctl(msgid,IPC_STAT,&buf) == -1)
        err_exit("msgctl error");

    //设置消息队列的属性
    buf.msg_perm.mode = 0600;
    if (msgctl(msgid, IPC_SET, &buf) == -1)
        err_exit("msgctl error");

    //获取并打印
    bzero(&buf, sizeof(buf));
    if (msgctl(msgid, IPC_STAT, &buf) == -1)
        err_exit("msgctl IPC_STAT error");
    printf("mode = %o\n", buf.msg_perm.mode);
}

附-查看系统中的IPC对象

     ipcs

   删除消息队列

     ipcrm -q [msqid]

  或  ipcrm -Q [key] #如果key不等于0的话

目录
相关文章
|
4月前
|
监控 Linux 应用服务中间件
Linux多节点多硬盘部署MinIO:分布式MinIO集群部署指南搭建高可用架构实践
通过以上步骤,已成功基于已有的 MinIO 服务,扩展为一个 MinIO 集群。该集群具有高可用性和容错性,适合生产环境使用。如果有任何问题,请检查日志或参考MinIO 官方文档。作者联系方式vx:2743642415。
1346 57
|
8月前
|
消息中间件 存储 监控
活动实践 | 快速体验云消息队列RocketMQ版
本方案介绍如何使用阿里云消息队列RocketMQ版Serverless实例进行消息管理。主要步骤包括获取接入点、创建Topic和订阅组、收发消息、查看消息轨迹及仪表盘监控。通过这些操作,用户可以轻松实现消息的全生命周期管理,确保消息收发的高效与可靠。此外,还提供了消费验证、下载消息等功能,方便用户进行详细的消息处理与调试。
|
7月前
|
消息中间件 监控 数据挖掘
【有奖实践】轻量消息队列(原 MNS)订阅 OSS 事件实时处理文件变动
当你需要对对象存储 OSS(Object Storage Service)中的文件变动进行实时处理、同步、监听、业务触发、日志记录等操作时,你可以通过设置 OSS 的事件通知规则,自定义关注的文件,并将 OSS 事件推送到轻量消息队列(原 MNS)的队列或主题中,开发者的服务即可及时收到相关通知,并通过消费消息进行后续的业务处理。
149 95
|
7月前
|
消息中间件 Linux
Linux中的System V通信标准--共享内存、消息队列以及信号量
希望本文能帮助您更好地理解和应用System V IPC机制,构建高效的Linux应用程序。
267 48
|
7月前
|
消息中间件 对象存储
轻量消息队列(原 MNS)订阅 OSS 事件实践
使用轻量消息队列订阅OSS事件,实时处理文件变动,赢取ins风U型枕(限量500个)。访问活动页面,完成实操并上传截图即可参与领奖。活动时间:即日起至2025年2月28日16:00。奖品数量有限,先到先得,快来报名吧!
117 2
|
8月前
|
消息中间件 Linux
Linux:进程间通信(共享内存详细讲解以及小项目使用和相关指令、消息队列、信号量)
通过上述讲解和代码示例,您可以理解和实现Linux系统中的进程间通信机制,包括共享内存、消息队列和信号量。这些机制在实际开发中非常重要,能够提高系统的并发处理能力和数据通信效率。希望本文能为您的学习和开发提供实用的指导和帮助。
613 20
|
9月前
|
消息中间件 Java 开发工具
【实践】快速学会使用云消息队列RabbitMQ版
本次分享的主题是快速学会使用云消息队列RabbitMQ版的实践。内容包括:如何创建和配置RabbitMQ实例,如Vhost、Exchange、Queue等;如何通过阿里云控制台管理静态用户名密码和AccessKey;以及如何使用RabbitMQ开源客户端进行消息生产和消费测试。最后介绍了实验资源的回收步骤,确保资源合理利用。通过详细的操作指南,帮助用户快速上手并掌握RabbitMQ的使用方法。
769 10
|
17天前
|
Unix Linux 程序员
Linux文本搜索工具grep命令使用指南
以上就是对Linux环境下强大工具 `grep` 的基础到进阶功能介绍。它不仅能够执行简单文字查询任务还能够处理复杂文字处理任务,并且支持强大而灵活地正则表达规范来增加查询精度与效率。无论您是程序员、数据分析师还是系统管理员,在日常工作中熟练运用该命令都将极大提升您处理和分析数据效率。
80 16
|
9天前
|
Linux
linux命令—stat
`stat` 是 Linux 系统中用于查看文件或文件系统详细状态信息的命令。相比 `ls -l`,它提供更全面的信息,包括文件大小、权限、所有者、时间戳(最后访问、修改、状态变更时间)、inode 号、设备信息等。其常用选项包括 `-f` 查看文件系统状态、`-t` 以简洁格式输出、`-L` 跟踪符号链接,以及 `-c` 或 `--format` 自定义输出格式。通过这些选项,用户可以灵活获取所需信息,适用于系统调试、权限检查、磁盘管理等场景。