AI 助理
文档备案控制台
开发者社区 云原生 云消息队列 文章 正文

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

2017-04-13 2234
版权
版权声明：
本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《 阿里云开发者社区用户服务协议》和 《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写 侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
简介：
消息队列是消息的链接表，包括Posix消息队列system V消息队列。消息队列用于运行于同一台机器上的进程间通信，它
和管道很相似，有足够权限的进程可以向队列中添加消息，被赋予读权限的进程则可以读走队列中的消息。消息队列克服了
信号承载信息量少，管道只能承载无格式字节流以及缓冲区大小受限等缺点。 我们可以用流管道或者套接口的方式来取代它。

查询系统消息队列：ipcs -q

#include <sys/types.h>

#include <sys/ipc.h>

#include <sys/msg.h>

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

int msgget(key_t key, int msgflg);

int msgrcv(int msqid, void *msg_ptr, size_t msg_sz, long int msgtype, int msgflg);

int msgsnd(int msqid, const void *msg_ptr, size_t msg_sz, int msgflg);


C代码
  1. /*msgserver.c*/ 
  2.  
  3. #include <stdlib.h> 
  4. #include <string.h> 
  5. #include <errno.h> 
  6. #include <sys/types.h> 
  7. #include <sys/ipc.h> 
  8. #include <sys/msg.h> 
  9. #include <sys/stat.h> 
  10.  
  11. #define   MSG_FILE "msgserver.c"  
  12. #define   BUFFER 255  
  13. #define   PERM S_IRUSR|S_IWUSR  
  14. /* 服务端创建的消息队列最后没有删除,我们要使用ipcrm命令来删除的 */ 
  15. /* ipcrm -q <msqid> */ 
  16.  
  17. struct msgtype  
  18. {  
  19.     long mtype;  
  20.     char buffer[BUFFER+1];  
  21. };  
  22.  
  23. int main()  
  24. {  
  25.     struct msgtype msg;  
  26.     key_t key;  
  27.     int msgid;  
  28.      
  29.     if((key=ftok(MSG_FILE,'a'))==-1)  
  30.     {  
  31.         fprintf(stderr,"Creat Key Error:%s\n", strerror(errno));  
  32.         exit(1);  
  33.     }  
  34.  
  35.     if((msgid=msgget(key, PERM|IPC_CREAT|IPC_EXCL))==-1)  
  36.     { 
  37.         fprintf(stderr, "Creat Message Error:%s\n", strerror(errno));  
  38.         exit(1); 
  39.     }  
  40.     printf("msqid = %d\n", msgid); 
  41.     while(1) 
  42.     {  
  43.         msgrcv(msgid, &msg, sizeof(struct msgtype), 1, 0);  
  44.         fprintf(stderr,"Server Receive:%s\n", msg.buffer);  
  45.         msg.mtype = 2;  
  46.         msgsnd(msgid, &msg, sizeof(struct msgtype), 0);  
  47.     }  
  48.     exit(0);  
  49. }    
C代码
  1. /* msgclient.c */ 
  2.  
  3. #include <stdio.h> 
  4. #include <stdlib.h> 
  5. #include <string.h> 
  6. #include <errno.h> 
  7. #include <sys/types.h> 
  8. #include <sys/ipc.h> 
  9. #include <sys/msg.h> 
  10. #include <sys/stat.h> 
  11.  
  12. #define   MSG_FILE "msgserver.c"  
  13. #define   BUFFER 255  
  14. #define   PERM S_IRUSR|S_IWUSR  
  15.  
  16. struct msgtype {  
  17.     long mtype;  
  18.     char buffer[BUFFER+1];  
  19. };  
  20.  
  21. int main(int argc, char **argv)  
  22. {  
  23.     struct msgtype msg;  
  24.     key_t key;  
  25.     int msgid;  
  26.      
  27.     if(argc != 2)  
  28.     {  
  29.         fprintf(stderr,"Usage:%s string\n", argv[0]);  
  30.         exit(1);  
  31.     }  
  32.      
  33.     if((key=ftok(MSG_FILE,'a'))==-1)  
  34.     {  
  35.         fprintf(stderr,"Creat Key Error:%s\n", strerror(errno));  
  36.         exit(1);  
  37.     }  
  38.      
  39.     if((msgid=msgget(key, PERM))==-1)  
  40.     {  
  41.         fprintf(stderr,"Creat Message  Error:%s\n", strerror(errno));  
  42.         exit(1);  
  43.     }  
  44.      
  45.     msg.mtype = 1;  
  46.     strncpy(msg.buffer, argv[1], BUFFER);  
  47.     msgsnd(msgid, &msg, sizeof(struct msgtype), 0);   
  48.     memset(&msg, '\0', sizeof(struct msgtype));  
  49.     msgrcv(msgid, &msg, sizeof(struct msgtype), 2, 0);  
  50.     fprintf(stderr, "Client receive:%s\n", msg.buffer);  
  51.     exit(0); 
  52. }   
本文转自feisky博客园博客，原文链接：http://www.cnblogs.com/feisky/archive/2010/03/24/1693485.html，如需转载请自行联系原作者

文章标签：
Linux
消息中间件
文艺小青年
目录
相关文章
蓝易云
|
并行计算 Linux
Linux内核中的线程和进程实现详解
了解进程和线程如何工作，可以帮助我们更好地编写程序，充分利用多核CPU，实现并行计算，提高系统的响应速度和计算效能。记住，适当平衡进程和线程的使用，既要拥有独立空间的'兄弟'，也需要在'家庭'中分享和并行的成员。对于这个世界，现在，你应该有一个全新的认识。
蓝易云
535 67
蓝易云
|
Web App开发 Linux 程序员
获取和理解Linux进程以及其PID的基础知识。
总的来说，理解Linux进程及其PID需要我们明白，进程就如同汽车，负责执行任务，而PID则是独特的车牌号，为我们提供了管理的便利。知道这个，我们就可以更好地理解和操作Linux系统，甚至通过对进程的有效管理，让系统运行得更加顺畅。
蓝易云
506 16
蓝易云
|
Unix Linux
对于Linux的进程概念以及进程状态的理解和解析
现在，我们已经了解了Linux进程的基础知识和进程状态的理解了。这就像我们理解了城市中行人的行走和行为模式！希望这个形象的例子能帮助我们更好地理解这个重要的概念，并在实际应用中发挥作用。
蓝易云
330 20
hahaha无
|
监控 Shell Linux
Linux进程控制（详细讲解）
进程等待是系统通过调用特定的接口（如waitwaitpid）来实现的。来进行对子进程状态检测与回收的功能。
hahaha无
387 0
hahaha无
|
存储 负载均衡 算法
Linux2.6内核进程调度队列
本篇文章是Linux进程系列中的最后一篇文章，本来是想放在上一篇文章的结尾的，但是想了想还是单独写一篇文章吧，虽然说这部分内容是比较难的，所有一般来说是简单的提及带过的，但是为了让大家对进程有更深的理解与认识，还是看了一些别人的文章，然后学习了学习，然后对此做了总结，尽可能详细的介绍明白。最后推荐一篇文章Linux的进程优先级 NI 和 PR - 简书。
hahaha无
435 0
hahaha无
|
存储 Linux Shell
Linux进程概念-详细版（二）
在Linux进程概念-详细版（一）中我们解释了什么是进程，以及进程的各种状态，已经对进程有了一定的认识，那么这篇文章将会继续补全上篇文章剩余没有说到的，进程优先级，环境变量，程序地址空间，进程地址空间，以及调度队列。
hahaha无
322 0
hahaha无
|
Linux 调度 C语言
Linux进程概念-详细版（一）
子进程与父进程代码共享，其子进程直接用父进程的代码，其自己本身无代码，所以子进程无法改动代码，平时所说的修改是修改的数据。为什么要创建子进程：为了让其父子进程执行不同的代码块。子进程的数据相对于父进程是会进行写时拷贝（COW）。
hahaha无
404 0
ephemerals__
|
存储 Linux 调度
【Linux】进程概念和进程状态
本文详细介绍了Linux系统中进程的核心概念与管理机制。从进程的定义出发，阐述了其作为操作系统资源管理的基本单位的重要性，并深入解析了task_struct结构体的内容及其在进程管理中的作用。同时，文章讲解了进程的基本操作（如获取PID、查看进程信息等）、父进程与子进程的关系（重点分析fork函数）、以及进程的三种主要状态（运行、阻塞、挂起）。此外，还探讨了Linux特有的进程状态表示和孤儿进程的处理方式。通过学习这些内容，读者可以更好地理解Linux进程的运行原理并优化系统性能。
ephemerals__
633 4
云域A
|
Linux Shell
Linux 进程前台后台切换与作业控制
进程前台/后台切换及作业控制简介： 在 Shell 中，启动的程序默认为前台进程，会占用终端直到执行完毕。例如，执行 `./shella.sh` 时，终端会被占用。为避免不便，可将命令放到后台运行，如 `./shella.sh &`，此时终端命令行立即返回，可继续输入其他命令。 常用作业控制命令： - `fg %1`：将后台作业切换到前台。 - `Ctrl + Z`：暂停前台作业并放到后台。 - `bg %1`：让暂停的后台作业继续执行。 - `kill %1`：终止后台作业。 优先级调整：
云域A
1765 5
云域A
|
Linux 应用服务中间件 nginx
Linux 进程管理基础
Linux 进程是操作系统中运行程序的实例，彼此隔离以确保安全性和稳定性。常用命令查看和管理进程：`ps` 显示当前终端会话相关进程；`ps aux` 和 `ps -ef` 显示所有进程信息；`ps -u username` 查看特定用户进程；`ps -e | grep &lt;进程名&gt;` 查找特定进程；`ps -p &lt;PID&gt;` 查看指定 PID 的进程详情。终止进程可用 `kill &lt;PID&gt;` 或 `pkill &lt;进程名&gt;`，强制终止加 `-9` 选项。
云域A
316 3
云原生

云消息队列

热门文章

最新文章

  • 1
    Redis Stream——作为消息队列的典型应用场景
  • 2
    SpringBoot开发案例之整合Kafka实现消息队列
  • 3
    ActiveMQ消息队列
  • 4
    基于TableStore构建简易海量Topic消息队列
  • 5
    Redis笔记（七）Java实现Redis消息队列
  • 6
    阿里云物联网平台设备数据转发到消息队列RocketMQ全链路测试
  • 7
    练习--LINUX进程间通信之消息队列MSG
  • 8
    消息队列 Kafka学习总结
  • 9
    详解linux进程间通信-消息队列
  • 10
    消息队列入门（四）ActiveMQ的应用实例
  • 1
    可视化生成RocketMQ配置工具
    674
  • 2
    Apache RocketMQ + “太乙” = 开源贡献新体验
    580
  • 3
    乐言科技：云原生加速电商行业赋能，云消息队列助力降本 37%
    1080
  • 4
    10倍降本、10倍无损弹性！Kafka Serverless 基础版与专业版重磅发布！
    1055
  • 5
    ApsaraMQ x Confluent 云原生 Kafka 线上沙龙
    437
  • 6
    云原生 Kafka 问卷调研启动，你的声音很重要！参与赢精美礼品！
    829
  • 7
    RocketMQ Controller 模式 始终更新成本机ip
    516
  • 8
    云消息队列 RabbitMQ 版实践解决方案评测
    640
  • 9
    RocketMQ体验测评
    692
  • 10
    关键成果与技术应用
    478

    • 相关课程

    更多
  • Linux磁盘与文件系统管理
  • Linux软件包安装和yum仓库实战
  • Linux文件管理命令
  • Linux文本处理、正则表达式与Vim
  • Linux MySQL服务器搭建与应用
  • Linux用户和组管理

    • 相关电子书

    更多
  • 从Linux系统内核层面来解决实际问题的实战经验
  • 基于消息队列RocketMQ的大型分布式应用上云最佳实践
  • 云原生消息队列Apache RocketMQ

    • 推荐镜像

    更多
  • mxlinux-iso
  • archlinuxarm
  • archlinuxcn
    • 下一篇
    一条命令迁移，帮你实现 OpenClaw 与 Hermes Agent 记忆互通！