讲师中心 微信公众号

工具推荐

视频效率加速
AniShort
AniShort

AI短剧协同制作平台

Seko
Seko

AI短剧一键生成成片

立刻MV
立刻MV

低成本歌曲 MV、视频生成

updream

一键生成高质量推广成片

c++怎么实现基于文件的简单的消息队列(Message Queue)模型【详解】

陌磊君_7334

陌磊君_7334

发布时间:2026-04-06 22:48:33

|

847人浏览过

|

来源于php中文网

原创

结论:不推荐用纯文件模拟消息队列,除非满足跨进程、无依赖、可持久化且性能要求低于1000 msg/s的极简场景;应优先使用System V IPC(msgget/msgsnd/msgrcv)或mmap+ring buffer+flock方案。

c++怎么实现基于文件的简单的消息队列(message queue)模型【详解】

直接说结论:C++ 用文件实现消息队列,不是“能不能”,而是“该不该”——除非你明确需要跨进程、无依赖、可持久化、且性能要求低于 1000 msg/s 的极简场景,否则不推荐用纯文件模拟。它本质是用 fseek + fread + fwrite 模拟环形缓冲区,但会踩到原子性、并发竞争、文件锁粒度粗、磁盘 I/O 成为瓶颈等一堆坑。

为什么不能直接用 std::fstream 做多线程消息队列

文件 I/O 本身不是线程安全的:std::fstream 对象实例不能被多个线程同时读写;即使加 std::mutex,也只保护了 C++ 流对象状态,不保证底层 write(2) 系统调用的原子性。更关键的是:Linux 下普通文件写入不保证“追加写”的原子性(除非用 O_APPEND 标志打开),两个线程同时 write 可能导致数据错乱或覆盖。

常见错误现象:

  • 消费者读出半条消息(比如只读到 struct 头部,没读完 payload)
  • 两条消息粘包(没有分隔符,read 返回连续字节流)
  • 生产者写入中途崩溃,文件末尾残留脏数据,下次读取直接 segfault

必须用 mmap + ring buffer + fcntl 文件锁才勉强可用

真正能落地的基于文件的消息队列,核心是把文件当内存映射载体,而非 I/O 流。典型结构是「固定头 + 环形消息区」,所有读写都通过 mmap 指针操作,避免 read/write 调用开销和边界问题。

立即学习“C++免费学习笔记(深入)”;

实操要点:

  • 用 open(path, O_RDWR | O_CREAT, 0644) 创建文件,再 ftruncate 预分配大小(比如 4MB)
  • 用 mmap(nullptr, size, PROT_READ|PROT_WRITE, MAP_SHARED, fd, 0) 映射整块区域
  • 头部放两个原子变量:std::atomic<size_t> read_off</size_t> 和 std::atomic<size_t> write_off</size_t>(需对齐到缓存行)
  • 每次 Push() 前,用 flock(fd, LOCK_EX) 锁整个文件(或用 fcntl 锁特定字节范围),写完立即解锁;Pop() 同理
  • 消息体必须带长度字段(如 uint32_t len),不能依赖换行或 \0 分隔

性能影响:mmap 方式比纯 write/read 快 3–5 倍,但依然比内存队列慢一个数量级;flock 是阻塞锁,高并发下容易成为瓶颈。

C++14
C++14

C++14 对 C++11 的修正与增强版本,适合旧系统维护和较老工具链兼容。

下载

msgget/msgsnd/msgrcv 系统调用才是正解

Linux 原生消息队列(System V IPC)就是基于内核文件系统(/dev/mqueue 下可见)实现的,但它由内核保障原子性、类型过滤、阻塞/非阻塞语义,且支持 mtype 字段做消息路由——这才是“基于文件”的正确打开方式,而不是自己造轮子。

关键差异:

  • msgget(key, IPC_CREAT|0666) 创建队列,返回 msgid(本质是内核索引)
  • msgsnd(msgid, &msgbuf, msgsz, IPC_NOWAIT) 发送,msgbuf.mtype 必须 > 0
  • msgrcv(msgid, &msgbuf, msgsz, type, flag) 中 type=0 表示取队首,type>0 表示只取该类型,type 表示取 ≤ |type| 的最小类型
  • 队列满时 msgsnd 默认阻塞,加 IPC_NOWAIT 则返回 -1 并设 errno=EAGAIN

兼容性注意:System V IPC 在容器中默认禁用(需 --ipc=host 或挂载 /dev/mqueue),macOS 不支持;但 glibc 兼容层稳定,从 2.2 到 2.39 都可用。

最容易被忽略的三个细节

一是 ftok(".", 'a') 生成 key 时,路径参数必须存在且权限可读,否则 ftok 返回 -1 —— 很多人用不存在的路径调试半天才发现;

二是 struct msgbuf 中 mtype 必须是 正整数,传 0 或负数会导致 msgsnd 直接失败(errno=EINVAL),但错误信息不提示具体原因;

三是消息体大小不能超过系统限制(cat /proc/sys/kernel/msgmax,默认 65536),超长消息会被截断,且 msgrcv 返回实际读取字节数,必须校验是否等于预期长度,否则后续解析全错。

相关文章

c++速学教程(入门到精通)
c++速学教程(入门到精通)

c++怎么学习?c++怎么入门?c++在哪学?c++怎么学才快?不用担心,这里为大家提供了c++速学教程(入门到精通),有需要的小伙伴保存下载就能学习啦!

下载

相关标签:

c++

本站声明:本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系admin@php.cn

热门AI工具

更多
WorkBuddy

一款AI办公效率工具,主要用于腾讯云推出的AI原生桌面智能体工作台,适合需要提升相关任务效率的用户。

SoundView
SoundView Hot

SoundView是一款面向跨境电商的视频翻译、配音和本地化 AI 创作平台。

Flowith
Flowith Hot

Flowith是一款基于画布和智能体工作流的 AI 协作工作空间。

PixPix
PixPix Hot

PixPix是一款面向电商视觉生产的AI商品图生成工具。

DeepSeek

DeepSeek是一款面向对话、写作、编程和推理场景的AI大模型工具。

Lovart
Lovart Hot

一款面向视觉设计创作的AI设计平台,可通过智能体和画布工作流辅助制作海报、Logo、网页、PPT及其他视觉内容。

Atoms
Atoms Hot

Atoms是一款AI智能体工具,第一支自动构建真实业务的 AI 团队。

豆包大模型

豆包大模型是一款由字节跳动推出的企业级大语言模型服务平台。

Seko
Seko Hot

一款AI视频创作工具,主要用于商汤科技推出的创编一体的AI短视频创作Agent,适合需要提升相关任务效率的用户。

相关专题

更多
C++ 智能指针与现代内存管理
C++ 智能指针与现代内存管理

深入讲解 C++ 现代内存管理的核心工具——智能指针,涵盖 unique_ptr 独占所有权语义、shared_ptr 引用计数机制与循环引用问题、weak_ptr 弱引用的应用场景、make_unique/make_shared 工厂函数的性能优势、自定义删除器的编写、RAII 资源管理思想的实践,以及从裸指针迁移到智能指针的重构策略,帮助开发者编写安全无泄漏的现代 C++ 代码。

399

2026.04.23

堆和栈的区别
堆和栈的区别

堆和栈的区别:1、内存分配方式不同;2、大小不同;3、数据访问方式不同;4、数据的生命周期。本专题为大家提供堆和栈的区别的相关的文章、下载、课程内容,供大家免费下载体验。

7007

2023.07.18

堆和栈区别
堆和栈区别

堆(Heap)和栈(Stack)是计算机中两种常见的内存分配机制。它们在内存管理的方式、分配方式以及使用场景上有很大的区别。本文将详细介绍堆和栈的特点、区别以及各自的使用场景。php中文网给大家带来了相关的教程以及文章欢迎大家前来学习阅读。

2868

2023.08.10

线程和进程的区别
线程和进程的区别

线程和进程的区别:线程是进程的一部分,用于实现并发和并行操作,而线程共享进程的资源,通信更方便快捷,切换开销较小。本专题为大家提供线程和进程区别相关的各种文章、以及下载和课程。

4858

2023.08.10

Python 多线程与异步编程实战
Python 多线程与异步编程实战

本专题系统讲解 Python 多线程与异步编程的核心概念与实战技巧,包括 threading 模块基础、线程同步机制、GIL 原理、asyncio 异步任务管理、协程与事件循环、任务调度与异常处理。通过实战示例,帮助学习者掌握 如何构建高性能、多任务并发的 Python 应用。

1369

2025.12.24

java多线程相关教程合集
java多线程相关教程合集

本专题整合了java多线程相关教程,阅读专题下面的文章了解更多详细内容。

463

2026.01.21

C++多线程相关合集
C++多线程相关合集

本专题整合了C++多线程相关教程,阅读专题下面的的文章了解更多详细内容。

599

2026.01.21

C# 多线程与异步编程
C# 多线程与异步编程

本专题深入讲解 C# 中多线程与异步编程的核心概念与实战技巧,包括线程池管理、Task 类的使用、async/await 异步编程模式、并发控制与线程同步、死锁与竞态条件的解决方案。通过实际项目,帮助开发者掌握 如何在 C# 中构建高并发、低延迟的异步系统,提升应用性能和响应速度。

449

2026.02.06

Go-Zero API开发使用教程
Go-Zero API开发使用教程

本专题聚焦Go-Zero的API开发,拆解.api描述文件的语法结构、路由与分组定义、参数绑定与校验规则,说明统一响应体、JWT鉴权、跨域与接口文档生成的落地方式,并给出网关聚合与接口测试的实践建议。

20

2026.11.12

热门下载

更多
网站特效
/
网站源码
/
网站素材
/
前端模板

精品课程

更多
相关推荐
/
热门推荐
/
最新课程
C++ Core Guidelines
C++ Core Guidelines

共0课时 | 0人学习

C++ Reference
C++ Reference

共0课时 | 0人学习

C++ 官方标准说明
C++ 官方标准说明

共0课时 | 0人学习

关于我们 免责申明 举报中心 意见反馈 讲师合作 广告合作 最新更新
php中文网:公益在线php培训,帮助PHP学习者快速成长!
关注服务号
PHP中文网订阅号
每天精选资源文章推送

Copyright 2014-2026 https://www.php.cn/ All Rights Reserved | php.cn