关于发送消息的Posix消息队列问题

问题描述

我正在尝试使用POSIX消息队列将消息从子进程发送到父进程。我在使用fork（）创建子级之前创建了消息队列。我的代码应该从链接列表中提取单词并将其发送给父代。但是，当我调用mq_send函数发送数据时，程序陷入该函数中，试图从控制台获取输入，并且永不停止。我一直在解决这个问题超过一天，但我不知道该怎么做。我检查了代码的其他部分，它们都起作用。仅mq_send函数会导致问题。有人可以告诉我这是什么问题吗？也许我缺少了一些东西。代码如下。

注意：我不能在此处包括所有代码。这里只有与问题相关的部分。另外，这是我在stackoverflow中遇到的第一个问题，因此对可能出现的格式错误感到抱歉。

编辑：因为我没有添加所有部分，所以代码无法编译。我的问题仅基于发送消息的代码的最后一个while循环。那就是代码卡住的地方。

#include <stdio.h>
#include <stdlib.h>
#include <stddef.h>
#include <math.h>
#include <string.h>
#include <sys/types.h>
#include <mqueue.h>
#include <sys/wait.h>
#include <fcntl.h>
#include <sys/ipc.h> 
#include <sys/msg.h> 
#include <unistd.h>

struct Node {
    char value[1024];
    int count;
    struct Node* next;
};

struct dataPackage {
    char word[1024];
    int count;
};


int main(int argcount,char** argvalues) {
    struct Node* headList[atoi(argvalues[1])];      // an array to hold linked lists   
    
    // creating fileCount number of linked lists and storing them
    for ( int i = 0; i < atoi(argvalues[1]); i++ ) {
        headList[i] = NULL;
    }

    // creating message queues
    mqd_t mqList[fileCount];
    char queueNames[5][1024];
    int n;
    // creating different names for different message queues

    strcpy(queueNames[0],"/queue1");
    strcpy(queueNames[1],"/queue2");
    strcpy(queueNames[2],"/queue3");
    strcpy(queueNames[3],"/queue4");
    strcpy(queueNames[4],"/queue5");

    // creating the message queues
    for (int i = 0; i < atoi(argvalues[1]); i++ ) {
        mqList[i] = mq_open(queueNames[i],O_RDWR | O_CREAT,0666,NULL ); 
        printf("%i\n",mqList[i]); 
    }

    // creating child processes to process input files
    
    for (int i = 0; i < atoi(argvalues[1]); i++ ) {
        
        // creating a child process
        pid_t pid = fork();
        
        // child processes process seperate files
        if (pid == 0 ) {
            //printf("Before file process\n");
            // processing the file and creating the sorted linked lists
            processFile(fileNames[i],&headList[i]);
            
            // send linked list contents to parent process below
            struct dataPackage package;
            struct Node* tempHead = headList[i];
            
            while (tempHead != NULL) {
                // creating a package to send it to the parent process
                package.count = tempHead->count;
                strcpy(package.word,tempHead->value);
                
                // !!!!!this is the part where the program gets stuck!!!!!!!!
                n = mq_send(mqList[i],(char*) &package,sizeof(struct dataPackage),0);
                tempHead = tempHead -> next;
            }
            // creating a message that will indicate the end of message queue
            package.count = -10;
            strcpy(package.word,"stop");
            n = mq_send(mqList[i],(char *) &package,0);
            exit(0);
        }   
        else {
            wait(NULL);
        }
    }

解决方法

行

 struct Node* headList[argvalues[1]];

让我想知道您想要实现什么。 argvalues[1]是指向字符的指针，而不是数字。您的编译器应该已经告诉您了。

如果要将第一个参数转换为数字，则应使用类似的

int count;
if (sscanf(argvalues[1],"%d",&count) != 1) {
     /* does not look like a number */
     exit(1);
}
/* use count */

,

我看不到mq_receive调用。系统设置了队列限制，一旦确定了消息队列，您应该可以通过执行cat / dev / mqueue / mymq之类的操作来查看该限制。也就是说，我将检查您是否正确使用了消息。我看到您的代码正在执行的操作与产生子级mq_send的argvalues [1]中的值一样，产生了许多子级，但是父级只是在不消耗消息的情况下等待子级死亡。

https://linux.die.net/man/7/mq_overview

,

确保您尝试访问的队列中没有消息。

使用mq_getattr()和mq_curmsgs确定当前的邮件数量。