C语言消息队列IPC实现宾果游戏异常问题求助

核心问题分析 #

你遇到的问题集中在三个方向：消息队列的访问/匹配错误、卡片生成逻辑的循环复用、进程间同步缺失。以下是针对性的修复方案：

1. 消息队列的键值与权限修正 #

部分子进程无法接收消息，大概率是队列权限不足或键值冲突导致的访问失败。

• 用ftok()生成唯一键值，避免硬编码键值引发的队列冲突：

  key_t key = ftok("/tmp/bingo", 'B'); // 固定路径+字符生成唯一标识
  if (key == -1) { perror("ftok failed"); exit(EXIT_FAILURE); }
  

• 创建队列时设置全局读写权限，确保子进程能访问：

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

2. 消息类型匹配修正 #

如果父进程发送消息时的类型与子进程接收的类型不匹配，会导致部分子进程收不到数据。

• 给每个子进程分配唯一消息类型（例如用子进程的序号作为类型值）：
  父进程发送逻辑：

  struct msg_buf {
      long mtype; // 消息类型，用子进程序号标识
      int card[5][5]; // 宾果卡片数据
  };
  
  // 假设child_idx是当前子进程的序号（从1到子进程总数）
  struct msg_buf send_buf;
  send_buf.mtype = child_idx;
  // 填充卡片数据到send_buf.card
  if (msgsnd(msqid, &send_buf, sizeof(send_buf.card), 0) == -1) {
      perror("msgsnd failed");
      exit(EXIT_FAILURE);
  }
  

  子进程接收逻辑：

  struct msg_buf recv_buf;
  // 只接收属于自己的消息类型（child_idx由父进程传递或预先约定）
  if (msgrcv(msqid, &recv_buf, sizeof(recv_buf.card), child_idx, 0) == -1) {
      perror("msgrcv failed");
      exit(EXIT_FAILURE);
  }
  

3. 卡片生成逻辑去重 #

父进程重复生成卡片，是因为生成代码被放在了创建子进程的循环内部，每次fork都会重新生成一组卡片。

• 先一次性生成所有需要的卡片（总数量=子进程数×单进程卡片数），再分发给子进程：

  #define MAX_CARDS 100
  int all_cards[MAX_CARDS][5][5];
  int total_cards = child_count * cards_per_child;
  
  // 先批量生成所有卡片
  generate_bingo_cards(all_cards, total_cards);
  
  // 再循环创建子进程并分发卡片
  int card_idx = 0;
  for (int i = 0; i < child_count; i++) {
      if (fork() == 0) {
          // 子进程接收cards_per_child张卡片
          for (int j = 0; j < cards_per_child; j++) {
              msgrcv(...); // 接收并打印
          }
          exit(EXIT_SUCCESS);
      } else {
          // 父进程给当前子进程发送cards_per_child张卡片
          for (int j = 0; j < cards_per_child; j++) {
              // 将all_cards[card_idx++]填充到消息缓冲区
              msgsnd(...);
          }
      }
  }
  

4. 进程同步与队列清理 #

父进程如果提前删除消息队列，会导致未完成接收的子进程报错。

• 父进程必须等待所有子进程退出后，再清理消息队列：

  // 等待所有子进程结束
  for (int i = 0; i < child_count; i++) {
      wait(NULL);
  }
  // 删除消息队列，避免资源残留
  if (msgctl(msqid, IPC_RMID, NULL) == -1) {
      perror("msgctl remove failed");
      exit(EXIT_FAILURE);
  }
  

验证要点 #

修复后需确认：

• 所有子进程均能接收到指定数量的卡片并正确打印
• 父进程仅生成一次完整的卡片集合
• 程序退出后无消息队列残留（可通过ipcs -q命令检查）

内容的提问来源于stack exchange，提问作者Valentino Fabris Valenti