UNP(卷2:进程间通信)—— 第6章:System V消息队列

2024-05-06 14:48

本文主要是介绍UNP(卷2:进程间通信)—— 第6章:System V消息队列,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

System V 消息队列使用消息队列标识符(Message Queue Identifier)。具有足够特权的任何进程都可以往一个给定进程放置一个消息。也可以读出一个消息。跟Posix消息队列一样,在写消息之前,不求另外某个进程正在等待该队列上一个消息的到达。

对于每个消息队列,内核维护一个定义在<sys/msg.h>头文件中的信息结构。

struct msqid_ds {struct ipc_perm   msg_perm;   /* read_write perms */struct msg       *msg_first;  /* first message on queue,unused  */struct msg       *msg_last;   /* last message in queue,unused */time_t            msg_stime;  /* last msgsnd time */time_t            msg_rtime;  /* last msgrcv time */time_t            msg_ctime;  /* last change time */unsigned long  msg_lcbytes;   /* Reuse junk fields for 32 bit */unsigned long  msg_lqbytes;   /* ditto */msglen_t          msg_cbytes; /* current number of bytes on queue */msgqnum_t         msg_qnum;   /* number of messages in queue */msglen_t          msg_qbytes; /* max number of bytes on queue */pid_t             msg_lspid;  /* pid of last msgsnd */pid_t             msg_lrpid;  /* last receive pid */
};


msgget

创建一个新的消息队列或者访问一个已存在的消息队列。

#include <sys/types.h>
#include <sys/ipc.h>
#include <sys/msg.h>int msgget(key_t key, int msgflg);// 返回:若成功则为非负标识符,出错为-1
key:既可以是ftok的返回值,也可以是常值IPC_PRIVATE。

msgflg:读写权限位的组合(MSG_R、MSG_W),还可以与  IPC_CREATE、IPC_CREATE | IPC_EXCL 按为或。

当创建一个新的消息队列时,msqid_ds结构的如下成员被初始化:
(1)msg_perm结构的uid和cuid成员被设置成当前进程的有效用户ID,gid和cgid成员被设置成当前进程的有效组ID
(2)msgflg中的读写权限位存放在msg_perm.mode中
(3)msg_qnum,msg_lspid,msg_lrpid,msg_stime,msg_rtime被置为0
(4)msg_ctime被设置成当前时间
(5)msg_qbytes被设置成系统限制值


msgsnd、msgrcv

msgsnd使用msgget打开一个消息队列后,使用msgsnd往其上放置一个消息。

msgrcv从某个消息队列中读出一个消息。

#include <sys/types.h>
#include <sys/ipc.h>
#include <sys/msg.h>int msgsnd(int msqid, const void *msgp, size_t msgsz, int msgflg);// 返回:若成功则为0,出错-1ssize_t msgrcv(int msqid, void *msgp, size_t msgsz, long msgtyp, int msgflg);// 返回:若成功则为读入缓冲区中的数据的字节数,出错-1struct msgbuf {
long mtype;      /* message type, must be > 0 */
char mtext[1];    /* message data */
};

--------------------------------------  msgsnd -----------------------------------------  

msqid:由msgget返回的标识符。

msgp:结构指针,msgbuf。通常一个字节的数据是不够用的,可以自定义。

msgflg:可以是0,可以是IPC_NOWAIT(使得msgsnd调用非阻塞nonblocking,如果没有存放新消息的可用空间,就立马返回)。

  • 在指定的队列中已有太多的字节;
  • 在系统范围存在太多的消息。

如果这两个条件有一个存在,而且IPC_NOWAIT已指定,msgsnd就返回一个EAGAIN错误。如果有一个存在,且未指定IPC_NOWAIT标志,那么调用线程被投入睡眠,直到:

  • 具备存放新消息的空间;
  • 由msqid标识的消息队列从系统中删除(返回EIDRM错误);
  • 调用线程被某个信号所中断(返回EINTR错误。)

------------------------------------ msgrcv -----------------------------------------------

msgtyp:指定希望读出什么样的消息。

  • type == 0: 表示将会返回队列中的第一个消息。
  • type > 0 : 表示将会返回队列中消息类型的值等于type参数的第一个消息。
  • type < 0 : 表示将会返回队列中小于或者等于type的绝对值中最小的第一个消息。

msgflg指定所请求的消息不在队列时的处理。在没有消息可得的情况下,如果设置了IPC_NOWAIT位,立即返回一个ENOMSG错误,否则阻塞到下列某个事件发生为止
(1)有一个所请求类型的消息可获取
(2)由msqid标识的消息队列被从系统中删除
(3)调用线程被某个捕获的信号所中断
msgflg参数中另有一位可以指定MSG_NOERROR,当所接收消息的真正数据部分大于length参数时,如果设置了该位,msgrcv函数只是截短数据部分,而不返回错误,否则,返回一个E2BIG错误。


msgctl

#include <sys/types.h>
#include <sys/ipc.h>
#include <sys/msg.h>int msgctl(int msqid, int cmd, struct msqid_ds *buf);// 返回:若成功则为0,出错-1
msgctl提供在一个消息队列上的各种控制操作。

有三个命令:
(1)IPC_RMID:  从系统中删除msqid指定的消息队列。当前在该队列上的任何消息都被丢弃
(2)IPC_SET  :  给队列设置其中的msqid_ds结构的四个成员:msg_perm.uid, msg_perm.gid, msg_perm.mode和msg_qbytes
(3)IPC_STAT:  给调用者返回指定队列的当前msqid_ds结构

复用消息

  与一个队列中的每个消息相关联的类型字段提供了两个特性:

(1)类型字段可以用于标识消息,从而允许多个进程在单个队列上复用消息。

(2)类型字段可以用做优先级,允许接收者以不同于先进先出的某个顺序读出各个消息。


限制






















这篇关于UNP(卷2:进程间通信)—— 第6章:System V消息队列的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/964646

相关文章

Javaee多线程之进程和线程之间的区别和联系(最新整理)

《Javaee多线程之进程和线程之间的区别和联系(最新整理)》进程是资源分配单位,线程是调度执行单位,共享资源更高效,创建线程五种方式:继承Thread、Runnable接口、匿名类、lambda,r... 目录进程和线程进程线程进程和线程的区别创建线程的五种写法继承Thread,重写run实现Runnab

怎样通过分析GC日志来定位Java进程的内存问题

《怎样通过分析GC日志来定位Java进程的内存问题》:本文主要介绍怎样通过分析GC日志来定位Java进程的内存问题,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教... 目录一、GC 日志基础配置1. 启用详细 GC 日志2. 不同收集器的日志格式二、关键指标与分析维度1.

Java进程异常故障定位及排查过程

《Java进程异常故障定位及排查过程》:本文主要介绍Java进程异常故障定位及排查过程,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教... 目录一、故障发现与初步判断1. 监控系统告警2. 日志初步分析二、核心排查工具与步骤1. 进程状态检查2. CPU 飙升问题3. 内存

java向微信服务号发送消息的完整步骤实例

《java向微信服务号发送消息的完整步骤实例》:本文主要介绍java向微信服务号发送消息的相关资料,包括申请测试号获取appID/appsecret、关注公众号获取openID、配置消息模板及代码... 目录步骤1. 申请测试系统2. 公众号账号信息3. 关注测试号二维码4. 消息模板接口5. Java测试

Windows的CMD窗口如何查看并杀死nginx进程

《Windows的CMD窗口如何查看并杀死nginx进程》:本文主要介绍Windows的CMD窗口如何查看并杀死nginx进程问题,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地... 目录Windows的CMD窗口查看并杀死nginx进程开启nginx查看nginx进程停止nginx服务

Java中常见队列举例详解(非线程安全)

《Java中常见队列举例详解(非线程安全)》队列用于模拟队列这种数据结构,队列通常是指先进先出的容器,:本文主要介绍Java中常见队列(非线程安全)的相关资料,文中通过代码介绍的非常详细,需要的朋... 目录一.队列定义 二.常见接口 三.常见实现类3.1 ArrayDeque3.1.1 实现原理3.1.2

Java进程CPU使用率过高排查步骤详细讲解

《Java进程CPU使用率过高排查步骤详细讲解》:本文主要介绍Java进程CPU使用率过高排查的相关资料,针对Java进程CPU使用率高的问题,我们可以遵循以下步骤进行排查和优化,文中通过代码介绍... 目录前言一、初步定位问题1.1 确认进程状态1.2 确定Java进程ID1.3 快速生成线程堆栈二、分析

C++ RabbitMq消息队列组件详解

《C++RabbitMq消息队列组件详解》:本文主要介绍C++RabbitMq消息队列组件的相关知识,本文给大家介绍的非常详细,对大家的学习或工作具有一定的参考借鉴价值,需要的朋友参考下吧... 目录1. RabbitMq介绍2. 安装RabbitMQ3. 安装 RabbitMQ 的 C++客户端库4. A

golang实现延迟队列(delay queue)的两种实现

《golang实现延迟队列(delayqueue)的两种实现》本文主要介绍了golang实现延迟队列(delayqueue)的两种实现,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的... 目录1 延迟队列:邮件提醒、订单自动取消2 实现2.1 simplChina编程e简单版:go自带的time

SpringCloud整合MQ实现消息总线服务方式

《SpringCloud整合MQ实现消息总线服务方式》:本文主要介绍SpringCloud整合MQ实现消息总线服务方式,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐... 目录一、背景介绍二、方案实践三、升级版总结一、背景介绍每当修改配置文件内容,如果需要客户端也同步更新,