Unix C语言msgsnd部分消息发送失败及MSG_EXCEPT编译问题问询

根因 #

• msgsnd使用了IPC_NOWAIT标志：当系统消息队列存储达到默认上限时，msgsnd会直接返回EAGAIN错误，你当前的错误处理逻辑会直接退出程序，表现为消息发送失败。
• 程序退出没有销毁消息队列：多次运行测试后，队列中残留的旧消息会占满存储空间，新消息无法写入。
• 清屏逻辑可能导致显示异常：ClearCurrentConsoleLine的ANSI转义序列在输入、接收消息的并发场景下可能覆盖已收到的消息，会误导你判断为消息发送失败。

解决方案 #

1. 移除msgsnd的IPC_NOWAIT标志，使用默认阻塞模式，队列满时会自动等待空位再发送；如果要保留非阻塞逻辑，捕获EAGAIN错误后延迟重试，不要直接退出。
2. 程序退出时销毁消息队列，避免残留消息占用空间，在父进程退出逻辑中添加：

msgctl(qid, IPC_RMID, NULL);

3. 测试阶段先注释清屏代码，确认消息收发逻辑正常后再调整显示逻辑，避免显示问题干扰判断。
4. 调整main函数执行顺序，先打开消息队列再执行fork，避免父子进程资源竞争。

根因 #

MSG_EXCEPT是Linux特有的非POSIX标准扩展，默认不开启GNU扩展的情况下glibc不会暴露这个宏的定义，因此必须添加编译参数才能正常编译。

两种可选方案 #

方案1：代码开头显式定义宏（无需修改业务逻辑，仅兼容Linux） #

在所有头文件包含的最开头添加宏定义即可，不需要修改编译参数：

#define _GNU_SOURCE
#include <stdio.h>
// 其余原有头文件保持不变

方案2：移除MSG_EXCEPT依赖，应用层过滤自有消息（全平台可移植） #

不依赖Linux特有扩展，直接接收所有消息，在应用层过滤自身发送的消息即可实现原有逻辑，修改后的ReceiveMessage函数如下：

Message ReceiveMessage(int qid, int msgtype)
{
    Message msg;
    msg.success = 1;

    // 移除MSG_EXCEPT标志，接收所有类型的消息
    if(msgrcv(qid, (void*)&msg.message, sizeof(msg.message.text), 0, IPC_NOWAIT | MSG_NOERROR) == -1)
    {
        if (errno != ENOMSG)
        {
            perror("msgrcv");
            exit(EXIT_FAILURE);
        }
        else
            msg.success = 0;
    }
    // 应用层过滤自有消息，实现原有MSG_EXCEPT的效果
    else if (msg.message.type == msgtype)
    {
        msg.success = 0;
    }

    return msg;
}

该方案完全符合POSIX标准，不需要任何额外编译参数，在所有支持System V消息队列的系统上都可以正常运行。

内容的提问来源于stack exchange，提问作者Exero