当前位置：首页 > news >正文

消息队列（Message Queue）简介

news 来源：原创 2025/9/21 2:10:27

消息队列是一种进程间通信（IPC）机制，允许不同进程通过发送和接收消息进行 异步通信。它的核心特点包括：

解耦：消息队列解耦了生产者和消费者，简化了系统设计。
持久化存储：支持将消息存储在队列中，保证数据不会丢失。
流量控制：适用于分布式系统或需要流量控制的场景。

在 Linux 系统中，常用的消息队列实现包括 System V 消息队列 和 POSIX 消息队列。这里将以 System V 消息队列 为例，介绍其 C 语言 API 的使用方法。

核心 API 函数 💻

1. 创建/获取消息队列

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

key：队列的唯一标识符，通常通过 ftok 生成。
msgflg：权限标志（如 IPC_CREAT | 0666）。
返回值：消息队列的 ID，失败返回 -1。

2. 发送消息

int msgsnd(int msqid, const void *msgp, size_t msgsz, int msgflg);

msqid：消息队列 ID。
msgp：指向消息结构体的指针。
msgsz：消息数据部分的长度。
msgflg：标志（如 0 或 IPC_NOWAIT）。

3. 接收消息

ssize_t msgrcv(int msqid, void *msgp, size_t msgsz, long msgtyp, int msgflg);

msgtyp：消息类型（0 表示任意类型）。
其他参数与 msgsnd 类似。

4. 控制消息队列

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

cmd：控制命令（如 IPC_RMID 删除队列）。

消息结构体 📜

消息结构体包含一个 long 类型的消息类型字段，后跟消息数据部分：

struct msgbuf {long mtype;    // 消息类型（必须 > 0）char mtext[64]; // 消息数据（可自定义长度）
};

示例代码 📑

发送端（`sender.c`）

#include <stdio.h>
#include <stdlib.h>
#include <sys/msg.h>
#include <string.h>struct msgbuf {long mtype;char mtext[64];
};int main() {key_t key = ftok(".", 'a'); // 生成唯一 keyint msqid = msgget(key, IPC_CREAT | 0666);if (msqid == -1) {perror("msgget");exit(1);}struct msgbuf msg;msg.mtype = 1; // 消息类型strcpy(msg.mtext, "Hello from sender!");if (msgsnd(msqid, &msg, sizeof(msg.mtext), 0) == -1) {perror("msgsnd");exit(1);}printf("Message sent: %s\n", msg.mtext);return 0;
}

接收端（`receiver.c`）

#include <stdio.h>
#include <stdlib.h>
#include <sys/msg.h>struct msgbuf {long mtype;char mtext[64];
};int main() {key_t key = ftok(".", 'a');int msqid = msgget(key, 0666);if (msqid == -1) {perror("msgget");exit(1);}struct msgbuf msg;if (msgrcv(msqid, &msg, sizeof(msg.mtext), 1, 0) == -1) { // 接收类型为 1 的消息perror("msgrcv");exit(1);}printf("Received: %s\n", msg.mtext);// 删除消息队列if (msgctl(msqid, IPC_RMID, NULL) == -1) {perror("msgctl");exit(1);}return 0;
}

编译与运行 ⚙️

编译：

gcc sender.c -o sender
gcc receiver.c -o receiver

运行：
- 先运行 发送端：
```
./sender
```
- 再运行 接收端：
```
./receiver
```

关键注意事项 ⚠️

权限问题：确保 msgget 的权限标志（如 0666）允许进程访问队列。
消息类型：mtype 必须为正整数，用于区分不同类型的消息。
队列持久性：即使进程退出，消息队列仍会保留，需显式调用 msgctl(IPC_RMID) 删除。
错误处理：所有 API 调用后应检查返回值，避免资源泄漏。

通过消息队列，可以实现 可靠的进程间通信，特别适用于生产者和消费者速度不匹配的场景。🚀

消息队列（Message Queue）简介

消息队列是一种进程间通信（IPC）机制，允许不同进程通过发送和接收消息进行异步通信。它的核心特点包括： 解耦：消息队列解耦了生产者和消费者，简化了系统设计。持久化存储：支持将消息存储在队列…...

编程日记 2025/9/21 2:10:27

动/静态库

1.先了解一下动静态库上图可以看出来静态库就是由一堆进过链接阶段的.o文件组成的.a文件。在这里必须要强调的是库文件格式一定是libxxx.a/so在你进行路径查找使用的时候要去掉lib和后缀使用！ 静态库概念：在程序编译链接阶段，其代码被完整…...

编程日记 2025/9/21 2:03:10

KWDB创作者计划—边缘计算：从概念到落地的技术解读

引言随着物联网（IoT）和人工智能（AI）的快速发展，数据量呈爆炸式增长，传统的云计算架构逐渐暴露出延迟高、带宽占用大等问题。边缘计算作为一种新兴的分布式计算范式，正在改变数据处理的方式。本…...

编程日记 2025/9/21 2:06:56

ubuntu根文件系统通过uMTP-Responder实现usb的MTP功能

实现mtp设备添加服务 /home/flynn/firfly_rootfs/lib/systemd/system/adbd.service #start [Unit] Description Adbd for linux Beforerockchip.service[Service] Typeforking ExecStart/etc/init.d/adbd.sh start ExecStop/etc/init.d/adbd.sh stop ExecReload/etc/init.d…...

编程日记 2025/9/21 2:08:39

8、nRF52xx蓝牙学习（boards.h文件学习）

boards.h文件的代码如下： #ifndef BOARDS_H #define BOARDS_H#include "nrf_gpio.h" #include "nordic_common.h"#if defined(BOARD_NRF6310)#include "nrf6310.h" #elif defined(BOARD_PCA10000)#include "pca10000.h" #…...

编程日记 2025/9/20 6:53:18

辛格迪客户案例 | 河南宏途食品实施电子合约系统(eSign)

01 河南宏途食品有限公司：食品行业的数字化践行者河南宏途食品有限公司（以下简称“宏途食品”）作为国内食品行业的创新企业，专注于各类食品的研发、生产和销售。公司秉承“质量为先、创新驱动、服务至上”的核心价值观&#xff…...

编程日记 2025/9/9 1:34:04

webrtc-stats

1. RTP 相关统计 1.1 inbound-rtp (接收端统计) 接收到的 RTP 流统计信息，包含以下关键指标： bytesReceived: 接收到的字节总数packetsReceived: 接收到的数据包总数packetsLost: 丢失的数据包数量jitter: 数据包到达时间的抖动（毫秒&…...

编程日记 2025/8/27 14:11:22

【LangChain框架组成】 LangChain 技术栈的模块化架构解析

目录整体架构概述整体架构层级划分模块详细解析 1. 部署与服务层（LangServe & Deployments） 2. 应用模板层（Templates & Committee Architectures） 3. 核心功能层（LangChain） 4. 社区扩展…...

编程日记 2025/9/16 7:35:11

RNN、LSTM、GRU汇总

RNN、LSTM、GRU汇总 0、论文汇总1.RNN论文2、LSTM论文3、GRU4、其他汇总 1、发展史2、配置和架构1.配置2.架构 3、基本结构1.神经元2.RNN1. **RNN和前馈网络区别：**2. 计算公式：3. **梯度消失:**4. **RNN类型**:（查看发展史）5. **…...

编程日记 2025/8/18 0:10:58

用TypeScript和got库编写爬虫程序指南

用TypeScript和got库写一个爬虫程序。首先，我得确认他们对TypeScript和Node.js的基础了解，可能他们已经有了一些JS的经验，但不确定。接下来，需要明确爬虫的目标，比如要爬取的网站、需要的数据类型以及处理方式。首先…...

编程日记 2025/9/9 0:47:03

使用 Spring Boot 快速构建企业微信 JS-SDK 权限签名后端服务

使用 Spring Boot 快速构建企业微信 JS-SDK 权限签名后端服务本篇文章将介绍如何使用 Spring Boot 快速构建一个用于支持企业微信 JS-SDK 权限校验的后端接口，并提供一个简单的 HTML 页面进行功能测试。适用于需要在企业微信网页端使用扫一扫、定位、录音等接口的…...

编程日记 2025/9/12 15:39:05

【软考-架构】13.2、软件层次风格

✨资料&文章更新✨ GitHub地址：https://github.com/tyronczt/system_architect 文章目录 2、层次架构风格两层C/S架构三层C/S架构三层B/S架构富互联网应用RIAMVC架构MVP架构MVVM架构 ✨3、面向服务的架构风格SOASOA中应用的关键技术WEB Service企业服务总线ESB …...

编程日记 2025/9/5 21:48:00

Java 进阶-全面解析

目录异常处理集合框架 List 集合 Set 集合 Map 集合文件与字符集 IO 流多线程通过继承Thread类创建线程通过实现Runnable接口创建线程线程同步示例线程通信示例网络编程 Java 高级技术反射机制动态代理注解异常处理在 Java …...

编程日记 2025/9/16 4:56:30

mongodb 创建keyfile

在 MongoDB 中，keyFile 是用于副本集成员间内部认证的密钥文件。它是一个包含随机字符串的文件，所有副本集成员必须使用相同的 keyFile 进行通信。以下是创建和配置 keyFile 的详细步骤。创建 KeyFile 的步骤 1. 生成随机字符串使用以下命令生成一个…...

编程日记 2025/8/17 23:12:22

工业4.0时代，RK3562工控机为何成为智慧工位首选？

在制造业数字化转型的浪潮中，智慧车间已成为提升生产效率、降低运营成本的关键战场。作为智慧车间的"神经末梢"，工位机的智能化程度直接影响着整个生产线的运行效率。RK3562工控机凭借其强大的计算性能、稳定的运行表现和丰富的接口配置&#…...

编程日记 2025/9/15 21:51:53

WPF 资源加载问题：真是 XAML 的锅吗？

你的观察很敏锐！确实，在 WPF 项目中，.cs 文件主要负责逻辑实现，而资源加载的问题通常跟 XAML（以及它背后的 .csproj 配置）关系更大。我会围绕这个观点，用 CSDN 博客风格详细解释一下 .cs、XAML …...

编程日记 2025/9/20 17:54:22

5. 深度剖析：Spring AI项目架构与分层体系全解读

1、前言前面我们已经可以通过简单的方式集成Spring AI进行快速开发了。授人以鱼不如授人以渔，我们还是需要了解Spring AI的项目结构，以及他的一些核心概念。 2、项目结构我们将Spring AI代码直接fork到我们自己的仓库中。fork的目的是方便我们为了学…...

编程日记 2025/9/6 18:57:14

2025最新数字化转型国家标准《数字化转型管理参考架构》正式发布

当前，数字化转型是数字时代企业生存和发展的必答题，其根本任务是价值体系优化、创新和重构。数字生产力的飞速发展不仅引发了生产方式的转变，也深刻改变了企业的业务体系和价值模式。为进一步引导企业明确数字化转型的主要任务和关键着力点…...

编程日记 2025/9/13 12:57:03

蓝桥杯备赛 Day 20 树基础

![[树的基础概念.png]] 树的遍历二叉树遍历分类 DFS前序遍历根节点-左儿子-右儿子 DFS中序遍历左儿子-根节点-右儿子 DFS后序遍历左儿子-右儿子-根节点 BFS层序遍历![[树的遍历.png]] 代码: #include <bits/stdc.h>using namespace std; const int N20; i…...

编程日记 2025/9/18 20:22:40

清晰易懂的Jfrog Artifactory 安装与核心使用教程

JFrog Artifactory 是企业级二进制仓库管理工具，支持 Maven、Docker、npm 等 30 包格式。本教程将手把手教你完成安装、配置、核心操作，并指出企业级部署的避坑要点，助你快速搭建私有仓库！ 一、安装 JFrog Artifactory&#xff0…...

编程日记 2025/9/19 5:03:40

苍穹外卖总结

苍穹外卖学习知识点整体概括: 学到目前(day10),总体最核心的部分就是CURD各种数据,因为一些接口,前端页面都已经设计好,在实际开发中也应该是这样,重点是在每个不同的业务板块区别出细微不同的业务逻辑 Swagger注解 swagger是一种自动生成接口文档的插件使用注解,就可以…...

编程日记 2025/9/13 9:00:00

python学智能算法（九）|决策树深入理解

【1】引言前序学习进程中，初步理解了决策树的各个组成部分，此时将对决策树做整体解读，以期实现深入理解。各个部分的解读文章链接为： python学智能算法（八）|决策树-CSDN博客【2】代码【2.1】完整代…...

编程日记 2025/9/4 19:37:02

HTTP代理：内容分发战场上的「隐形指挥官」

目录一、技术本质：流量博弈中的「规则改写者」二、战略价值：内容分发的「四维升级」三、实战案例：代理技术的「降维打击」四、未来进化：代理技术的「认知升级」五、结语：代理技术的「战略觉醒」在数字内容爆…...

编程日记 2025/9/12 20:12:55

学习笔记（C++篇）--- Day2

1.类的定义 1.1 类的格式 ①class为类的关键字 ②在类的内容中还可以写函数，具体格式请看示例。 ③为了区分成员变量，一般习惯上成员变量会加一个特殊标识（如成员变量前面或者后面加_ 或者 m开头，注意C中这个并不是强制的&#x…...

编程日记 2025/9/12 16:15:06

下载firefox.tar.xz后如何将其加入到Gnome启动器

起因：近期（2025-04-07）发现firefox公布了130.0 版本，可以对pdf文档进行签名了，想试一下，所以卸载了我的Debian12上的firefox-esr,直接下载了新版本的tar.xz 包。经过一番摸索，实现了将其加入Gn…...

编程日记 2025/9/13 4:30:36

VSCode英文翻译插件：变量命名、翻单词、翻句子

目录【var-translate】【Google Translate】【code-translator】【其他插件】【var-translate】非常推荐，可以提供小驼峰、大驼峰、下划线、中划线、常量等翻译，Windows下快捷键为Ctrl Shift v 可以整句英文翻译，并且支持多个免费…...

编程日记 2025/9/13 22:37:26

快速高效的MCP Severs

通用AI Agent的瓶颈最近一直在用MCP协议开发通用智能体。虽然大模型本身请求比较慢，但是还可以接受。而最让人沮丧的是，工具效率也不高比如社区的filesystem，每次只能创建一个目录，生成文件时，如果目录不存在&…...

编程日记 2025/9/15 7:09:35

原子化 CSS 的常见实现框架

原子化 CSS 是一种 CSS 架构方法，其核心思想是将样式拆分为最小粒度的单一功能类，每个类仅对应一个具体的样式属性（如颜色、边距、字体大小等），通过组合这些类来构建复杂的界面。这种方式强调代码复用性、维护性和灵活…...

编程日记 2025/9/7 1:27:34

技术速递｜使用 GitHub Copilot Agent Mode 进行编程

作者：卢建晖 - 微软高级云技术布道师翻译/排版：Alan Wang GitHub Copilot 持续发展，从最初的代码补全、生成、优化功能，到通过对话交互提升 AI 代码质量的 GitHub Copilot Chat，再到能够基于项目中多个文件的关联进行…...

编程日记 2025/9/8 1:31:40

Linux系统（Ubuntu和树莓派）的远程操作练习

目录实验准备一、Ubuntu 下的远程操作二、树莓派下的远程操作三、思考实验准备 1.双方应保证处于同一个局域网内 2.关闭防火墙 (否则别人将不能 ping 通自己,具体说明请参考：windows-关闭防火墙） 3.配置虚拟机 a.网桥模式配置查询…...

编程日记 2025/9/18 9:51:23

电脑屏保壁纸怎么设置桌面壁纸设置方法详解

电脑桌面壁纸作为我们每天面对的第一视觉元素，不仅能够彰显个人品味，还能营造舒适的工作或娱乐氛围。电脑桌面壁纸怎么设置呢？下面本文将为大家介绍Windows和macOS两大主流操作系统中设置电脑桌面壁纸的方法，帮助大家快速设置个性…...

编程日记 2025/9/19 17:19:45

为什么选择Redis？解析核心使用场景与性能优化技巧

解析核心使用场景与性能优化技巧 redis只能能操作字符串，要把Java对象存入redis非关系型数据库，需要用序列化变成字符串，再反序列化成Java对象 not only sql NoSQL非关系型数据库：缓存数据库，只能读取数据&#xff0…...

编程日记 2025/9/19 6:40:09

Docker中Redis修改密码失效

docker容器中，我们通过docker run命令运行某一容器这里，我们通过以下命令来进行运行【注意，这里有两个关键点：-d 和--requirepass】 docker run \ --restartalways \ --log-opt max-size100m \ --log-opt max-file2 \ -p 6379:6…...

编程日记 2025/9/19 10:34:39

质数质数筛

1.试除法判定质数–O(sqrt(N)) bool is_prime(int x) {if (x < 2) return false;for (int i 2; i < x / i; i )if (x % i 0)return false;return true; }2.试除法分解质因数–O(logN)~O(sqrt(N)) void divide(int x) {for (int i 2; i < x / i; i )if (x % i …...

编程日记 2025/9/18 13:46:25

VGA接口设计

1.VGA简介 VGA（Video Graphics Array）视频图形阵列接口是一种模拟信号视频传输标准，用于连接计算机主机和显示设备，如显示器、投影仪等。 VGA接口能够传输红、绿、蓝三原色的模拟信号以及同步信号（数字信号），实现计算机图形和视频信号的输出和显示。尽管数字化显示接口…...

编程日记 2025/9/8 7:35:24

clickhouse注入手法总结

clickhouse 遇到一题clickhouse注入相关的，没有见过，于是来学习clickhouse的使用，并总结相关注入手法。环境搭建直接在docker运行 docker pull clickhouse/clickhouse-server docker run -d --name some-clickhouse-server --ulimit n…...

编程日记 2025/9/19 16:32:19

VsCode保存时删除无用的引用

打开设置文件教程：打开VsCode设置设置里添加 {"editor.codeActionsOnSave": {"source.organizeImports": false, // 禁用默认的整理导入"source.removeUnusedImports": true // 仅删除未使用的导入} }...

编程日记 2025/8/17 22:02:42

轻松Linux-4.进程概念

屋漏偏逢连夜雨，今天就学Linux 话不多说，展示军火 1.认识冯诺依曼体系冯诺依曼体系其实并不是什么稀罕的东西，我们生活中的笔记本、服务器、计算机等等大多都遵守冯诺依曼体系非常经典的一张图我们所认识的计算机，是由一个个…...

编程日记 2025/9/6 10:33:12

畅游Diffusion数字人(21)：基于Wan2.1的音频驱动数字人FantasyTalking

畅游Diffusion数字人(0)：专栏文章导航前言：AI数字人是目前视觉AIGC最有希望大规模落地的场景之一。现阶段的商业工具，如字节的OminiHuman-1(即梦大师版)、快手的可灵对口型，虽然效果不错，但是收费昂贵。而开源解决方案…...

编程日记 2025/9/13 7:47:00

CentOS禁用nouveau驱动

1、验证 nouveau 是否在运行 lsmod | grep nouveau如果命令返回结果，说明 nouveau 驱动正在运行。 2、编辑黑名单文件通过编辑黑名单配置文件来禁用 nouveau 驱动，这样在系统启动时不会加载它。 vi /etc/modprobe.d/blacklist-nouveau.conf修改以下…...

编程日记 2025/9/16 1:59:56

《Operating System Concepts》阅读笔记：p587-p596

《Operating System Concepts》学习第 52 天，p587-p596 总结，总计 10 页。一、技术总结 1.Recovery (1)consistency checking consistency checking 工具：fsck。 (2)log-structure file system (3)WAFL file system 2.Veritas (1)Ve…...

编程日记 2025/9/19 19:28:30

k8s 1.24.17版本部署(使用Flannel插件)

1.k8s集群环境准备推荐阅读: https://kubernetes.io/zh/docs/setup/production-environment/tools/kubeadm/install-kubeadm/ 1.1 环境准备环境准备:硬件配置: 2core 4GB磁盘: 50GB操作系统: Ubuntu 22.04.04 LTSIP和主机名:10.0.0.231 master23110.0.0.232 worker23210.0…...

编程日记 2025/9/14 16:41:47

通信协议详解（十）：PSI5 —— 汽车安全传感器的“抗干扰狙击手”

一、PSI5是什么？ 一句话秒懂 PSI5就像传感器界的“防弹信使”：在汽车安全系统（如气囊）中，用两根线同时完成供电数据传输，即便车祸时线路受损，仍能确保关键信号准确送达！ 基础概念…...

编程日记 2025/9/20 10:02:37

Kafka生产者和消费者：数据管道的核心引擎与智能终端

在分布式系统中，数据的高效流动如同人体的血液循环，而Kafka的生产者（Producer）与消费者（Consumer）正是驱动这一循环的核心组件。它们不仅是Kafka客户端的基本形态，更是构建实时数据生态的基石。…...

编程日记 2025/9/20 0:40:21

特权FPGA之按键消抖

完整代码如下所示： timescale 1ns / 1ps// Company: // Engineer: 特权 // // Create Date: // Design Name: // Module Name: // Project Name: // Target Device: // Tool versions: // Description: // // Dependencies: // // Revision: // …...

编程日记 2025/9/7 6:48:14