C程序中fork()与消息队列通信的异常问题求助

1. 子进程重复执行接收逻辑引发无效查询 #

父进程调用fork()后，子进程会继承完整的执行上下文：包括当前循环状态、消息队列ID、data变量的内容。子进程执行完puts("Received")后，会回到while(1)循环开头，调用receive_message时传入的msg_type是子进程自身PID，但消息队列中没有发送给该PID的消息，因此msgrcv会返回ENOMSG（错误码42）。你看到的报错实际来自子进程的msgrcv操作，而非fork()本身失败，只是错误信息被误关联到了fork()步骤。

2. receive_message存在竞态条件 #

函数中先通过msgctl查询队列长度、再调用msgrcv的操作不是原子的：

• 当msgctl返回队列有消息时，其他进程（比如刚创建的子进程、外部进程）可能在这两步之间取走目标消息，导致msgrcv返回ENOMSG。
• 单进程时这种概率极低，但多进程并发操作时会频繁触发。

3. 父子进程接收逻辑冲突 #

虽然子进程的消息类型是自身PID，不会直接抢占父进程的消息，但子进程持续循环查询不存在的消息，会间接占用系统资源，导致父进程的消息接收稳定性下降。

1. 终止子进程的循环流程 #

子进程只需执行目标任务，不需要继续参与消息接收，执行完任务后直接退出：

while (1)
{
    receive_message(msg_queue_id, data, sizeof(data), getpid());
    if (strcmp(data, "ON") == 0)
    {
        pid = fork();
        if (pid == -1) {
            perror("fork failed");
            continue;
        }
        if (pid == 0)
        {
            puts("Received");
            exit(0); // 子进程执行完立即退出，不再进入循环
        }
        // 父进程继续执行循环
    }
}

2. 移除竞态逻辑，简化消息接收 #

不需要提前查询队列长度，直接调用msgrcv即可，它本身能处理队列空的情况：

void receive_message(int msg_id, void *msg_ptr, size_t msg_size, int msg_type)
{
    struct msgbuf message;

    if (msgrcv(msg_id, &message, msg_size, msg_type, IPC_NOWAIT) == -1)
    {
        if (errno != ENOMSG) {
            fprintf(stderr, "[ERROR] %s Line:%d PID=%d Error %d (%s)\n",
                    __FILE__, __LINE__, getpid(), errno, strerror(errno));
        }
        return;
    }

    memcpy(msg_ptr, message.mtext, msg_size);
}

3. 明确错误来源，避免混淆 #

将通用的CATCH_ERROR替换为针对性的错误处理，区分不同系统调用的错误：

#define CATCH_FORK_ERROR do { \
    if (pid == -1) { \
        fprintf(stderr, "[ERROR] fork failed: PID=%d Error %d (%s)\n", \
                getpid(), errno, strerror(errno)); \
    } \
} while(0)

使用时单独处理fork()的错误，避免和消息队列操作的错误混淆。

4. 统一消息类型（可选） #

如果不需要按PID区分消息接收方，可以使用固定的消息类型（比如1）代替PID，减少多进程环境下的消息类型混乱。

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