C++怎么使用消息队列进行通信-C++-PHP中文网

system v 消息队列需用pod结构体，首字段为long mtype且>0；msgsnd/msgrcv须设ipc_nowait防阻塞，避免传std::string等非pod类型。

c++怎么使用消息队列进行通信

Linux 下用 `msgget` + `msgsnd` / `msgrcv` 发送接收消息

POSIX 消息队列在 Linux 上更常用，但 System V 消息队列（msgget 等）仍是 C++ 项目里最易上手的原生选择——不需要额外依赖，头文件只加 <sys></sys> 就行。关键不是“能不能用”，而是“怎么避免阻塞卡死”和“消息体结构怎么设计”。

常见错误是直接传 std::string 或含指针的对象，导致 msgsnd 写入乱码或崩溃；另一个坑是没检查 msgflg 参数，比如忘了加 IPC_NOWAIT，msgrcv 就会永远等下去。

消息缓冲区必须是 POD 类型：用 struct 手动定义，第一个字段固定为 long mtype（不能是 int），后续字段按需排布
发送前确保 mtype > 0，否则 msgsnd 返回 -1 并设 errno = EINVAL
接收时若指定 msgtyp = 0，取队列中最早的消息；若 msgtyp > 0，只取该类型；若 msgtyp ，取 <li>用完记得调 <code>msgctl(msqid, IPC_RMID, nullptr) 清理，否则队列残留（ipcs -q 可查）

C++ 封装 `mq_open` 时为什么总返回 `(mqd_t)-1`

mq_open 是 POSIX 消息队列接口，返回 (mqd_t)-1 表示失败，但具体原因得看 errno。最常踩的三个坑：路径名没加 / 前缀、O_CREAT 时漏了权限参数、或内核没启用 POSIX MQ 支持。

比如写 mq_open("myq", O_RDWR | O_CREAT) 必定失败——O_CREAT 必须配 mode（如 0644），否则 errno = EINVAL；再比如用 "myq" 而非 "/myq"，errno = ENOENT（POSIX MQ 名字必须以 / 开头，且不能有多个连续 /）。

编译时加 -lrt 链接 librt，否则链接失败
检查内核是否支持：cat /proc/sys/fs/mqueue/msg_max，值为 0 表示被禁用（需改 /etc/default/grub 加 mq_ci=1 并重启）
struct mq_attr 中 mq_flags 默认为 0（阻塞），设为 O_NONBLOCK 后 mq_receive 才会立即返回 -1 并置 errno = EAGAIN

跨进程通信时消息体大小怎么控制才不丢数据

System V 消息队列默认最大消息长度是 8192 字节（可通过 /proc/sys/kernel/msgmax 查看/修改），POSIX MQ 则由 mq_attr.mq_msgsize 在 mq_open 时设定。超长消息直接被 msgsnd 或 mq_send 拒绝，返回 -1，errno = EMSGSIZE。

C++14

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

下载

别指望靠分包自动重组——消息队列不保证顺序（除非严格单生产者+单消费者+不跳类型），也不合并消息。实际做法是：预估最大负载，留 128 字节余量给协议头（如版本号、校验字段），然后硬性截断或报错，而不是尝试压缩或 Base64 编码塞进去。

System V：用 msgctl(msqid, IPC_STAT, &buf) 获取当前 msg_qbytes（队列总容量）和 msg_lspid（最后发送 PID）辅助调试
POSIX MQ：创建时显式设置 attr.mq_msgsize = 4096，比默认 8192 更可控；读写前用 mq_getattr 校验实际值
字符串字段务必用定长数组（如 char name[256]），不用 std::string 成员，避免指针悬空