Linux系统编程-进程间通信(消息队列)

简介: 前面文章介绍了Linux下进程的创建,管理,陆续介绍了进程间通信的方式:管道、内存映射、共享内存等。这篇文章继续介绍Linux的进程间通信方式消息队列。

前面文章介绍了Linux下进程的创建,管理,陆续介绍了进程间通信的方式:管道、内存映射、共享内存等。这篇文章继续介绍Linux的进程间通信方式消息队列

image-20211216090722856

1. 消息队列介绍

消息队列通过名字字面意思理解就是队列排队-和平常超市买东西排队付款一样结构,消息队列与FIFO很相似,都是一个队列结构,都可以有多个进程往队列里面写信息,多个进程从队列中读取信息。但FIFO需要读、写的两端事先都打开,才能够开始信息传递工作。而消息队列可以事先往队列中写信息,需要时再打开读取信息。

注意事项:

  1. 消息队列属于顺序队列形式的结构,向队列里写的每一条消息,会追加到队列后面,读取一个就从队列里消除一个。
  2. 写函数不会阻塞,除非队列里存放的消息数量已经满了,才会导致写阻塞。
  3. 读函数,从队列里读取不到数据时,会阻塞。

查看当前系统所有的消息队列:

[root@wbyq 20181005]# ipcs -q

------ Message Queues --------
键值    消息队列ID                        使用的字节数量  队里现存的消息数量                
key        msqid      owner      perms     used-bytes   messages    
0x000004d3 0          root       666        65532        192         
0x00003044 32769      root       666        65424        564         
0x0a120534 65538      root       0          2352         21          
0x0a00000f 196611     root       0          65520        2730        
0xffffffff 163844       root       0          0            0  

查看消息队列的详细信息:

[root@wbyq 20181005]# ipcs -l

------ Shared Memory Limits --------
max number of segments = 4096
max seg size (kbytes) = 4194303
max total shared memory (kbytes) = 1073741824
min seg size (bytes) = 1

------ Semaphore Limits --------
max number of arrays = 128
max semaphores per array = 250
max semaphores system wide = 32000
max ops per semop call = 32
semaphore max value = 32767

------ Messages: Limits --------
max queues system wide = 1736        【系统最多的消息队列数量(最多支持同时1736个消息队列)】
max size of message (bytes) = 65536     【单个消息的最大字节数】
default max size of queue (bytes) = 65536 【默认的单个队列的大小65536】

默认单个队列总字节大小为: 65535字节。
消息队列的最大字节数量和消息的最大条数加起来的总字节数不能超过65535字节。

System V IPC机制消息队列相关的函数接口: 这里先列出所有函数,下面会详细介绍每个函数的用法。

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

2. 消息队列相关函数介绍

2.1 msgget函数

函数原型:

#include <sys/types.h>
#include <sys/ipc.h>
#include <sys/msg.h>
int msgget(key_t key, int msgflg);

功能
msgget用于创建和访问一个消息队列。
参数
(1) key:是唯一标识一个消息队列的关键字,如果为IPC_PRIVATE(值为0,用创建一个只有创建者进程才可以访问的消息队列),表示创建一个只由调用进程使用的消息队列,非0值的key(可以通过ftok函数获得)表示创建一个可以被多个进程共享的消息队列;
(2) msgflg:指明队列的访问权限和创建标志,创建标志的可选值为IPC_CREAT和IPC_EXC,如果单独指定IPC_CREAT,msgget要么返回新创建的消息队列id,要么返回具有相同key值的消息队列id;如果IPC_EXCL和IPC_CREAT同时指明,则要么创建新的消息队列,要么当队列存在时,调用失败并返回-1。

/*1. 创建消息队列*/
int msgid = msgget((key_t)1235,0666 | IPC_CREAT);

返回值
成功执行时,返回消息队列标识值(0也是成功的)。

失败返回-1,errno被设为以下的某个值。

EACCES:指定的消息队列已存在,但调用进程没有权限访问它,而且不拥有CAP_IPC_OWNER权能
EEXIST:key指定的消息队列已存在,而msgflg中同时指定IPC_CREAT和IPC_EXCL标志
ENOENT:key指定的消息队列不存在同时msgflg中不指定IPC_CREAT标志
ENOMEM:需要建立消息队列,但内存不足
ENOSPC:需要建立消息队列,但已达到系统的最大消息队列容量

2.2 msgsnd和msgrcy函数

原型:

#include <sys/types.h>
#include <sys/ipc.h>
#include <sys/msg.h>
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);

功能

函数msgsnd和msgrcy用来将消息添加到消息队列中和从一个消息队列中获取信息。

参数

(1)msgid:指明消息队列的ID; 通常是msgget函数成功的返回值。

(2)msgbuf:是消息结构体,它的长度必须小于系统规定的上限,必须以一个长整型成员变量开始,接收函数将用这个成员变量来确定消息的类型。必须重写这个结构体,其中第一个参数类型不能改,其他可以自定义。

如下:

struct msgbuf {
    long mtype;         /* type of message */
    char mtext[1];       /* message text */
};

字段mtype是用户自己指定的消息类型(通常是1—5中的任意一个数值),该结构体第2个成员仅仅是一种说明性的结构,实际上用户可以使用任何类型的数据,就是消息内容;

(3)msgsz是消息体的大小,每个消息体最大不要超过4K; 不含消息类型占用的4个字节,即mtext的长度

(4)msgtyp有3种选项:


msgtyp == 0      接收队列中的第1个消息,不区分消息类型
msgtyp > 0        接收对列中的第1个类型等于msgtyp的消息
msgtyp < 0        接收其类型小于或等于msgtyp绝对值的第1个最低类型消息

(5)msgflg有3种选项:

0:当消息队列满时,msgsnd将会阻塞,直到消息能写进消息队列
IPC_NOWAIT:当消息队列已满的时候,msgsnd函数不等待立即返回
IPC_NOERROR:若发送的消息大于size字节,则把该消息截断,截断部分将被丢弃,且不通知发送进程。

2.3 msgctl函数

原型:

#include <sys/types.h>
#include <sys/ipc.h>
#include <sys/msg.h>
int msgctl(int msqid, int cmd, struct msqid_ds *buf);

功能

msgctl是消息队列的控制函数,常用来删除消息队列。

参数

(1)msqid:由msgget返回的消息队列标识符。

(2)cmd:通常为IPC_RMID表示删除消息队列。

(3)参数buf通常为NULL。

通过命令查看系统消息信息

(1)ipcs -q 命令查看系统的消息队列

(2)ipcs -m查看系统的共享内存

(3)ipcs -s 查看系统的信号量集。

image-20211216085707736

3. 案例代码: 消息队列示例1

下面两个程序分别编译,依次运行,不分先后顺序,就可以看到效果了。

3.1 发送消息

#include <stdio.h>
#include <string.h>
#include <stdlib.h>
#include <errno.h>
#include <sys/types.h>
#include <sys/ipc.h>
#include <sys/msg.h>
#include <sys/stat.h>
#define BUFFER 255
struct msgtype {    //重新定义该结构体
    long mtype;     //第一个参数类型不变
    char buf[BUFFER];
};

int main(int argc,char **argv)
{
    if(argc!=3)
    {
        printf("./app <消息> <消息类型-整数>\n");
        return 0;
    }
    /*1. 创建消息队列*/
    int msgid = msgget((key_t)1235,0666 | IPC_CREAT); 
    /*2. 向消息队列发送消息*/
    struct msgtype msg;
    memset(&msg,0,sizeof(struct msgtype));
    msg.mtype = atoi(argv[2]);                      //给结构体的成员赋值
    strncpy(msg.buf,argv[1],BUFFER);
    msgsnd(msgid,&msg,sizeof(struct msgtype),0);  
    return 0;
}

3.2 读取消息

#include <stdio.h>
#include <string.h>
#include <stdlib.h>
#include <errno.h>
#include <unistd.h>
#include <sys/types.h>
#include <sys/ipc.h>
#include <sys/stat.h>
#include <sys/msg.h>
#define BUFFER 255
struct msgtype {
    long mtype;
    char buf[BUFFER];
};

int main(int argc,char **argv)
{
    if(argc!=2)
    {
        printf("./app <消息类型-整数>\n");
        return 0;
    }
    /*1. 创建消息队列-如果存在就打开消息队列*/
    int msgid = msgget((key_t)1235, 0666 | IPC_CREAT); //获得消息队列
    struct msgtype msg;
    memset(&msg,0,sizeof(struct msgtype));
    while(1)
    {
        /*2. 从消息队列里读取指定消息类型*/
        msgrcv(msgid,&msg,sizeof(struct msgtype),atoi(argv[1]),0);
        printf("读取的消息: %s\n", msg.buf);
    }
    return 0;
}

4. 案例代码: 消息队列基本使用

下面两个例子,一个例子用于创建队列,并向队列里写数据,另一个例子从队列里读取数据。

4.1 向队列写入消息

程序运行需要传入两个额外的参数。一个是消息的类型,一个是具体的内容。

./app 1 hello
./app 2 123456789

示例代码:

#include <stdio.h>
#include <unistd.h>
#include <string.h>
#include <sys/types.h>
#include <sys/stat.h>
#include <fcntl.h>
#include <dirent.h>
#include <stdlib.h>
#include <sys/mman.h>
#include <sys/wait.h>
#include <sys/shm.h>
#include <sys/types.h>
#include <sys/ipc.h>
#include <sys/msg.h>
#include <stdlib.h>

struct msgbuf
{
    long mtype;       /* message type, must be > 0 */
    char mtext[1024];    /* message data */
};

int main(int argc,char **argv)
{
    if(argc!=3)
    {
        printf("./app <消息类型> <消息内容>\n");
        return 0;
    }
    /*1. 创建消息队列*/
    int msqid=msgget(123456,0666|IPC_CREAT);
    /*2. 向消息队列里加入数据*/
    struct msgbuf msg_buf;
    msg_buf.mtype=atoi(argv[1]); //消息类型  1、2、3、4、5
    strcpy(msg_buf.mtext,argv[2]); //消息内容
    msgsnd(msqid,&msg_buf,sizeof(struct msgbuf),0);
    printf("消息发送成功:%s,%s\n",argv[1],argv[2]);
    return 0;
}

4.2 从队列读取消息

#include <stdio.h>
#include <unistd.h>
#include <string.h>
#include <sys/types.h>
#include <sys/stat.h>
#include <fcntl.h>
#include <dirent.h>
#include <stdlib.h>
#include <sys/mman.h>
#include <sys/wait.h>
#include <sys/shm.h>
#include <sys/types.h>
#include <sys/ipc.h>
#include <sys/msg.h>
#include <stdlib.h>

struct msgbuf
{
    long mtype;       /* message type, must be > 0 */
    char mtext[1024];    /* message data */
};

int main(int argc,char **argv)
{
    if(argc!=2)
    {
        printf("./app <消息类型>\n");
        return 0;
    }
    /*1. 创建消息队列*/
    int msqid=msgget(123456,0666|IPC_CREAT);
    /*2. 从消息队列里取出数据*/
    struct msgbuf msg_buf;
    msgrcv(msqid,&msg_buf,sizeof(struct msgbuf),atoi(argv[1]),0);
    printf("消息读取成功:%d,%s\n",msg_buf.mtype,msg_buf.mtext);
    return 0;
}
目录
相关文章
|
28天前
麒麟系统mate-indicators进程占用内存过高问题解决
【10月更文挑战第7天】麒麟系统mate-indicators进程占用内存过高问题解决
132 2
|
5天前
|
缓存 监控 Linux
linux进程管理万字详解!!!
本文档介绍了Linux系统中进程管理、系统负载监控、内存监控和磁盘监控的基本概念和常用命令。主要内容包括: 1. **进程管理**: - **进程介绍**:程序与进程的关系、进程的生命周期、查看进程号和父进程号的方法。 - **进程监控命令**:`ps`、`pstree`、`pidof`、`top`、`htop`、`lsof`等命令的使用方法和案例。 - **进程管理命令**:控制信号、`kill`、`pkill`、`killall`、前台和后台运行、`screen`、`nohup`等命令的使用方法和案例。
28 4
linux进程管理万字详解!!!
|
5天前
|
算法 Linux 定位技术
Linux内核中的进程调度算法解析####
【10月更文挑战第29天】 本文深入剖析了Linux操作系统的心脏——内核中至关重要的组成部分之一,即进程调度机制。不同于传统的摘要概述,我们将通过一段引人入胜的故事线来揭开进程调度算法的神秘面纱,展现其背后的精妙设计与复杂逻辑,让读者仿佛跟随一位虚拟的“进程侦探”,一步步探索Linux如何高效、公平地管理众多进程,确保系统资源的最优分配与利用。 ####
28 4
|
5天前
|
消息中间件 存储 供应链
进程间通信方式-----消息队列通信
【10月更文挑战第29天】消息队列通信是一种强大而灵活的进程间通信机制,它通过异步通信、解耦和缓冲等特性,为分布式系统和多进程应用提供了高效的通信方式。在实际应用中,需要根据具体的需求和场景,合理地选择和使用消息队列,以充分发挥其优势,同时注意其可能带来的复杂性和性能开销等问题。
|
6天前
|
缓存 负载均衡 算法
Linux内核中的进程调度算法解析####
本文深入探讨了Linux操作系统核心组件之一——进程调度器,着重分析了其采用的CFS(完全公平调度器)算法。不同于传统摘要对研究背景、方法、结果和结论的概述,本文摘要将直接揭示CFS算法的核心优势及其在现代多核处理器环境下如何实现高效、公平的资源分配,同时简要提及该算法如何优化系统响应时间和吞吐量,为读者快速构建对Linux进程调度机制的认知框架。 ####
|
7天前
|
消息中间件 存储 Linux
|
11天前
|
运维 监控 Shell
深入理解Linux系统下的Shell脚本编程
【10月更文挑战第24天】本文将深入浅出地介绍Linux系统中Shell脚本的基础知识和实用技巧,帮助读者从零开始学习编写Shell脚本。通过本文的学习,你将能够掌握Shell脚本的基本语法、变量使用、流程控制以及函数定义等核心概念,并学会如何将这些知识应用于实际问题解决中。文章还将展示几个实用的Shell脚本例子,以加深对知识点的理解和应用。无论你是运维人员还是软件开发者,这篇文章都将为你提供强大的Linux自动化工具。
|
14天前
|
运维 Linux
Linux查找占用的端口,并杀死进程的简单方法
通过上述步骤和命令,您能够迅速识别并根据实际情况管理Linux系统中占用特定端口的进程。为了获得更全面的服务器管理技巧和解决方案,提供了丰富的资源和专业服务,是您提升运维技能的理想选择。
15 1
|
25天前
|
算法 Linux 调度
深入理解Linux操作系统的进程管理
【10月更文挑战第9天】本文将深入浅出地介绍Linux系统中的进程管理机制,包括进程的概念、状态、调度以及如何在Linux环境下进行进程控制。我们将通过直观的语言和生动的比喻,让读者轻松掌握这一核心概念。文章不仅适合初学者构建基础,也能帮助有经验的用户加深对进程管理的理解。
18 1
|
30天前
|
消息中间件 Linux API
Linux c/c++之IPC进程间通信
这篇文章详细介绍了Linux下C/C++进程间通信(IPC)的三种主要技术:共享内存、消息队列和信号量,包括它们的编程模型、API函数原型、优势与缺点,并通过示例代码展示了它们的创建、使用和管理方法。
26 0
Linux c/c++之IPC进程间通信