Linux进程间通信——使用消息队列

简介:

一、什么是消息队列

消息队列提供了一种从一个进程向另一个进程发送一个数据块的方法。 每个数据块都被认为含有一个类型,接收进程可以独立地接收含有不同类型的数据结构。我们可以通过发送消息来避免命名管道的同步和阻塞问题。但是消息队列与命名管道一样,每个数据块都有一个最大长度的限制。

Linux用宏MSGMAX和MSGMNB来限制一条消息的最大长度和一个队列的最大长度。

二、在Linux中使用消息队列

Linux提供了一系列消息队列的函数接口来让我们方便地使用它来实现进程间的通信。它的用法与其他两个System V PIC机制,即信号量和共享内存相似。

1、msgget函数

该函数用来创建和访问一个消息队列。它的原型为:

int msgget(key_t, key, int msgflg);

与其他的IPC机制一样,程序必须提供一个键来命名某个特定的消息队列。msgflg是一个权限标志,表示消息队列的访问权限,它与文件的访问权限一样。msgflg可以与IPC_CREAT做或操作,表示当key所命名的消息队列不存在时创建一个消息队列,如果key所命名的消息队列存在时,IPC_CREAT标志会被忽略,而只返回一个标识符。

它返回一个以key命名的消息队列的标识符(非零整数),失败时返回-1.

2、msgsnd函数

该函数用来把消息添加到消息队列中。它的原型为:

int msgsend(int msgid, const void *msg_ptr, size_t msg_sz, int msgflg);

msgid是由msgget函数返回的消息队列标识符。

msg_ptr是一个指向准备发送消息的指针,但是消息的数据结构却有一定的要求,指针msg_ptr所指向的消息结构一定要是以一个长整型成员变量开始的结构体,接收函数将用这个成员来确定消息的类型。所以消息结构要定义成这样:


  
  
  1. struct my_message{   
  2.  
  3.     long int message_type;   
  4.  
  5.     /* The data you wish to transfer*/   
  6.  
  7. };   

msg_sz是msg_ptr指向的消息的长度,注意是消息的长度,而不是整个结构体的长度,也就是说msg_sz是不包括长整型消息类型成员变量的长度。

msgflg用于控制当前消息队列满或队列消息到达系统范围的限制时将要发生的事情。

如果调用成功,消息数据的一分副本将被放到消息队列中,并返回0,失败时返回-1.

3、msgrcv函数

该函数用来从一个消息队列获取消息,它的原型为

int msgrcv(int msgid, void *msg_ptr, size_t msg_st, long int msgtype, int msgflg);

msgid, msg_ptr, msg_st的作用也函数msgsnd函数的一样。

msgtype可以实现一种简单的接收优先级。如果msgtype为0,就获取队列中的第一个消息。如果它的值大于零,将获取具有相同消息类型的第一个信息。如果它小于零,就获取类型等于或小于msgtype的绝对值的第一个消息。

msgflg用于控制当队列中没有相应类型的消息可以接收时将发生的事情。

调用成功时,该函数返回放到接收缓存区中的字节数,消息被复制到由msg_ptr指向的用户分配的缓存区中,然后删除消息队列中的对应消息。失败时返回-1.

4、msgctl函数

该函数用来控制消息队列,它与共享内存的shmctl函数相似,它的原型为:

int msgctl(int msgid, int command, struct msgid_ds *buf);

command是将要采取的动作,它可以取3个值,

IPC_STAT:把msgid_ds结构中的数据设置为消息队列的当前关联值,即用消息队列的当前关联值覆盖msgid_ds的值。

IPC_SET:如果进程有足够的权限,就把消息列队的当前关联值设置为msgid_ds结构中给出的值

IPC_RMID:删除消息队列

buf是指向msgid_ds结构的指针,它指向消息队列模式和访问权限的结构。msgid_ds结构至少包括以下成员:


  
  
  1. struct msgid_ds      
  2. {          
  3. uid_t shm_perm.uid;  
  4.         uid_t shm_perm.gid; 
  5.         mode_t shm_perm.mode; 
  6. };    

成功时返回0,失败时返回-1.

三、使用消息队列进行进程间通信

马不停蹄,介绍完消息队列的定义和可使用的接口之后,我们来看看它是怎么让进程进行通信的。由于可以让不相关的进程进行行通信,所以我们在这里将会编写两个程序,msgreceive和msgsned来表示接收和发送信息。根据正常的情况,我们允许两个程序都可以创建消息,但只有接收者在接收完最后一个消息之后,它才把它删除。

接收信息的程序源文件为msgreceive.c的源代码为:


  
  
  1. #include <unistd.h>   
  2.  
  3. #include <stdlib.h>   
  4.  
  5. #include <stdio.h>   
  6.  
  7. #include <string.h>   
  8.  
  9. #include <errno.h>   
  10.  
  11. #include <sys/msg.h>   
  12.  
  13.    
  14.  
  15. struct msg_st   
  16.  
  17. {   
  18.  
  19.     long int msg_type;   
  20.  
  21.     char text[BUFSIZ];   
  22.  
  23. };   
  24.  
  25.    
  26.  
  27. int main()   
  28.  
  29. {   
  30.  
  31.     int running = 1;   
  32.  
  33.     int msgid = -1;   
  34.  
  35.     struct msg_st data;   
  36.  
  37.     long int msgtype = 0; //注意1   
  38.  
  39.    
  40.  
  41.     //建立消息队列   
  42.  
  43.     msgid = msgget((key_t)1234, 0666 | IPC_CREAT);   
  44.  
  45.     if(msgid == -1)   
  46.  
  47.     {   
  48.  
  49.         fprintf(stderr, "msgget failed with error: %d\n", errno);   
  50.  
  51.         exit(EXIT_FAILURE);   
  52.  
  53.     }   
  54.  
  55.     //从队列中获取消息,直到遇到end消息为止   
  56.  
  57.     while(running)   
  58.  
  59.     {   
  60.  
  61.         if(msgrcv(msgid, (void*)&data, BUFSIZ, msgtype, 0) == -1)   
  62.  
  63.         {   
  64.  
  65.             fprintf(stderr, "msgrcv failed with errno: %d\n", errno);   
  66.  
  67.             exit(EXIT_FAILURE);   
  68.  
  69.         }   
  70.  
  71.         printf("You wrote: %s\n",data.text);   
  72.  
  73.         //遇到end结束   
  74.  
  75.         if(strncmp(data.text, "end", 3) == 0)   
  76.  
  77.             running = 0;   
  78.  
  79.     }   
  80.  
  81.     //删除消息队列   
  82.  
  83.     if(msgctl(msgid, IPC_RMID, 0) == -1)   
  84.  
  85.     {   
  86.  
  87.         fprintf(stderr, "msgctl(IPC_RMID) failed\n");   
  88.  
  89.         exit(EXIT_FAILURE);   
  90.  
  91.     }   
  92.  
  93.     exit(EXIT_SUCCESS);   
  94.  
  95. }    

发送信息的程序的源文件msgsend.c的源代码为:


  
  
  1. #include <unistd.h>   
  2.  
  3. #include <stdlib.h>   
  4.  
  5. #include <stdio.h>   
  6.  
  7. #include <string.h>   
  8.  
  9. #include <sys/msg.h>   
  10.  
  11. #include <errno.h>   
  12.  
  13.    
  14.  
  15. #define MAX_TEXT 512   
  16.  
  17. struct msg_st   
  18.  
  19. {   
  20.  
  21.     long int msg_type;   
  22.  
  23.     char text[MAX_TEXT];   
  24.  
  25. };   
  26.  
  27.    
  28.  
  29. int main()   
  30.  
  31. {   
  32.  
  33.     int running = 1;   
  34.  
  35.     struct msg_st data;   
  36.  
  37.     char buffer[BUFSIZ];   
  38.  
  39.     int msgid = -1;   
  40.  
  41.    
  42.  
  43.     //建立消息队列   
  44.  
  45.     msgid = msgget((key_t)1234, 0666 | IPC_CREAT);   
  46.  
  47.     if(msgid == -1)   
  48.  
  49.     {   
  50.  
  51.         fprintf(stderr, "msgget failed with error: %d\n", errno);   
  52.  
  53.         exit(EXIT_FAILURE);   
  54.  
  55.     }   
  56.  
  57.    
  58.  
  59.     //向消息队列中写消息,直到写入end   
  60.  
  61.     while(running)   
  62.  
  63.     {   
  64.  
  65.         //输入数据   
  66.  
  67.         printf("Enter some text: ");   
  68.  
  69.         fgets(buffer, BUFSIZ, stdin);   
  70.  
  71.         data.msg_type = 1;    //注意2   
  72.  
  73.         strcpy(data.text, buffer);   
  74.  
  75.         //向队列发送数据   
  76.  
  77.         if(msgsnd(msgid, (void*)&data, MAX_TEXT, 0) == -1)   
  78.  
  79.         {   
  80.  
  81.             fprintf(stderr, "msgsnd failed\n");   
  82.  
  83.             exit(EXIT_FAILURE);   
  84.  
  85.         }   
  86.  
  87.         //输入end结束输入   
  88.  
  89.         if(strncmp(buffer, "end", 3) == 0)   
  90.  
  91.             running = 0;   
  92.  
  93.         sleep(1);   
  94.  
  95.     }   
  96.  
  97.     exit(EXIT_SUCCESS);   
  98.  
  99. }    

运行结果如下:

四、例子分析——消息类型

这里主要说明一下消息类型是怎么一回事,注意msgreceive.c文件main函数中定义的变量msgtype(注释为注意1),它作为msgrcv函数的接收信息类型参数的值,其值为0,表示获取队列中第一个可用的消息。再来看看msgsend.c文件中while循环中的语句data.msg_type = 1(注释为注意2),它用来设置发送的信息的信息类型,即其发送的信息的类型为1。所以程序msgreceive能够接收到程序msgsend发送的信息。

如果把注意1,即msgreceive.c文件main函数中的语句由long int msgtype = 0;改变为long int msgtype = 2;会发生什么情况,msgreceive将不能接收到程序msgsend发送的信息。因为在调用msgrcv函数时,如果msgtype(第四个参数)大于零,则将只获取具有相同消息类型的第一个消息,修改后获取的消息类型为2,而msgsend发送的消息类型为1,所以不能被msgreceive程序接收。重新编译msgreceive.c文件并再次执行,其结果如下:

我们可以看到,msgreceive并没有接收到信息和输出,而且当msgsend输入end结束后,msgreceive也没有结束,通过jobs命令我们可以看到它还在后台运行着。

五、消息队列与命名管道的比较

消息队列跟命名管道有不少的相同之处,通过与命名管道一样,消息队列进行通信的进程可以是不相关的进程,同时它们都是通过发送和接收的方式来传递数据的。在命名管道中,发送数据用write,接收数据用read,则在消息队列中,发送数据用msgsnd,接收数据用msgrcv。而且它们对每个数据都有一个最大长度的限制。

与命名管道相比,消息队列的优势在于,1、消息队列也可以独立于发送和接收进程而存在,从而消除了在同步命名管道的打开和关闭时可能产生的困难。2、同时通过发送消息还可以避免命名管道的同步和阻塞问题,不需要由进程自己来提供同步方法。3、接收程序可以通过消息类型有选择地接收数据,而不是像命名管道中那样,只能默认地接收。





本文作者:佚名
来源:51CTO
目录
相关文章
|
17天前
|
算法 Linux 调度
深入理解Linux操作系统的进程管理
本文旨在探讨Linux操作系统中的进程管理机制,包括进程的创建、执行、调度和终止等环节。通过对Linux内核中相关模块的分析,揭示其高效的进程管理策略,为开发者提供优化程序性能和资源利用率的参考。
43 1
|
6天前
|
存储 监控 Linux
嵌入式Linux系统编程 — 5.3 times、clock函数获取进程时间
在嵌入式Linux系统编程中,`times`和 `clock`函数是获取进程时间的两个重要工具。`times`函数提供了更详细的进程和子进程时间信息,而 `clock`函数则提供了更简单的处理器时间获取方法。根据具体需求选择合适的函数,可以更有效地进行性能分析和资源管理。通过本文的介绍,希望能帮助您更好地理解和使用这两个函数,提高嵌入式系统编程的效率和效果。
50 13
|
12天前
|
SQL 运维 监控
南大通用GBase 8a MPP Cluster Linux端SQL进程监控工具
南大通用GBase 8a MPP Cluster Linux端SQL进程监控工具
|
20天前
|
运维 监控 Linux
Linux操作系统的守护进程与服务管理深度剖析####
本文作为一篇技术性文章,旨在深入探讨Linux操作系统中守护进程与服务管理的机制、工具及实践策略。不同于传统的摘要概述,本文将以“守护进程的生命周期”为核心线索,串联起Linux服务管理的各个方面,从守护进程的定义与特性出发,逐步深入到Systemd的工作原理、服务单元文件编写、服务状态管理以及故障排查技巧,为读者呈现一幅Linux服务管理的全景图。 ####
|
25天前
|
缓存 算法 Linux
Linux内核的心脏:深入理解进程调度器
本文探讨了Linux操作系统中至关重要的组成部分——进程调度器。通过分析其工作原理、调度算法以及在不同场景下的表现,揭示它是如何高效管理CPU资源,确保系统响应性和公平性的。本文旨在为读者提供一个清晰的视图,了解在多任务环境下,Linux是如何智能地分配处理器时间给各个进程的。
|
1月前
|
存储 运维 监控
深入Linux基础:文件系统与进程管理详解
深入Linux基础:文件系统与进程管理详解
78 8
|
1月前
|
网络协议 Linux 虚拟化
如何在 Linux 系统中查看进程的详细信息?
如何在 Linux 系统中查看进程的详细信息?
78 1
|
1月前
|
Linux
如何在 Linux 系统中查看进程占用的内存?
如何在 Linux 系统中查看进程占用的内存?
|
1月前
|
算法 Linux 定位技术
Linux内核中的进程调度算法解析####
【10月更文挑战第29天】 本文深入剖析了Linux操作系统的心脏——内核中至关重要的组成部分之一,即进程调度机制。不同于传统的摘要概述,我们将通过一段引人入胜的故事线来揭开进程调度算法的神秘面纱,展现其背后的精妙设计与复杂逻辑,让读者仿佛跟随一位虚拟的“进程侦探”,一步步探索Linux如何高效、公平地管理众多进程,确保系统资源的最优分配与利用。 ####
71 4
|
1月前
|
消息中间件 存储 供应链
进程间通信方式-----消息队列通信
【10月更文挑战第29天】消息队列通信是一种强大而灵活的进程间通信机制,它通过异步通信、解耦和缓冲等特性,为分布式系统和多进程应用提供了高效的通信方式。在实际应用中,需要根据具体的需求和场景,合理地选择和使用消息队列,以充分发挥其优势,同时注意其可能带来的复杂性和性能开销等问题。