C语言IPC消息队列报错：msgsnd: Function not implemented 求助

核心错误原因 #

1. 系统不支持System V消息队列 #

错误提示msgsnd: Function not implemented直接说明当前运行环境未启用System V消息队列支持。这种情况常见于：

• 轻量级容器（如部分Docker镜像、WSL1/特定WSL2配置）
• 嵌入式Linux或裁剪过的内核系统
• 内核编译时未开启CONFIG_SYSVIPC相关选项

验证方式：执行ls /proc/sys/kernel/，若看不到msgmax、msgmnb、msgmni文件，即可确认系统不支持该IPC机制。

2. 消息长度参数错误（无错误处理时输出空字符串的根源） #

代码中msgsnd和msgrcv的第三个参数使用sizeof(message)是错误的。System V消息队列要求该参数为消息体的字节数，不包含结构体开头的long mesg_type字段。传递整个结构体大小会导致：

• 发送时额外传递mesg_type的字节，造成接收端解析混乱
• 接收端读取到无效数据，表现为空字符串或乱码

正确参数应为sizeof(message.mesg_text)，或sizeof(struct mesg_buffer) - sizeof(long)。

3. 关键系统调用缺失错误检查 #

除msgsnd外，ftok、msgget、msgrcv均未做错误处理：

• ftok失败返回-1（如当前目录不存在或无权限访问）
• msgget失败返回-1（如权限不足）
• msgrcv失败返回-1（如队列不存在、消息类型不匹配）
  这些错误会导致后续逻辑异常，却无法快速定位问题。

4. 父进程wait逻辑的潜在问题 #

output()中的wait(NULL)会等待任意子进程退出，在无限循环场景下，若存在意外残留的子进程，可能导致wait提前返回，后续执行时消息队列还未写入数据。

修复后的代码 #

#include <stdio.h>
#include <string.h>
#include <sys/unistd.h>
#include <sys/ipc.h>
#include <sys/msg.h>
#include <stdlib.h>
#include <sys/wait.h>

#define MAX_STRING_SIZE 128

struct mesg_buffer {
    long mesg_type;
    char mesg_text[MAX_STRING_SIZE];
};

void input() {
    printf("Enter Text: ");
    fflush(stdout); // 确保提示语立即输出

    key_t key = ftok(".", 69);
    if (key == -1) {
        perror("ftok");
        exit(EXIT_FAILURE);
    }

    int msgid = msgget(key, 0666 | IPC_CREAT);
    if (msgid == -1) {
        perror("msgget");
        exit(EXIT_FAILURE);
    }

    struct mesg_buffer message;
    message.mesg_type = 1;
    if (fgets(message.mesg_text, MAX_STRING_SIZE, stdin) == NULL) {
        perror("fgets");
        exit(EXIT_FAILURE);
    }

    // 移除fgets读取的换行符（可选）
    message.mesg_text[strcspn(message.mesg_text, "\n")] = '\0';

    int result = msgsnd(msgid, &message, sizeof(message.mesg_text), 0);
    if (result == -1) {
        perror("msgsnd");
        exit(EXIT_FAILURE);
    }

    exit(0);
}

void output() {
    // 等待当前fork的子进程退出，避免等待无关进程
    pid_t child_pid;
    int status;
    if ((child_pid = wait(&status)) == -1) {
        perror("wait");
        exit(EXIT_FAILURE);
    }

    key_t key = ftok(".", 69);
    if (key == -1) {
        perror("ftok");
        exit(EXIT_FAILURE);
    }

    int msgid = msgget(key, 0666 | IPC_CREAT);
    if (msgid == -1) {
        perror("msgget");
        exit(EXIT_FAILURE);
    }

    struct mesg_buffer message;
    ssize_t recv_len = msgrcv(msgid, &message, sizeof(message.mesg_text), 1, 0);
    if (recv_len == -1) {
        perror("msgrcv");
        exit(EXIT_FAILURE);
    }

    printf("Entered Text: %s\n", message.mesg_text);

    if (msgctl(msgid, IPC_RMID, NULL) == -1) {
        perror("msgctl");
        exit(EXIT_FAILURE);
    }
}

int main(int argc, char **argv) {
    printf("Communication test (exit with CTRL+c)\n");
    while (1) {
        int pid = fork();
        if (pid == -1) {
            perror("fork");
            exit(EXIT_FAILURE);
        } else if (pid == 0) {
            input();
        } else {
            output();
        }
    }
    return 0;
}

额外说明 #

• 若系统确实不支持System V消息队列，可改用POSIX消息队列（头文件<mqueue.h>），或管道、共享内存等其他IPC机制。
• 每次循环销毁消息队列是合理的，若需持续复用队列，可将msgctl移至主循环结束时执行。

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