1

我正在学习 IPC 编程。作为其中的一部分，我尝试了以下两个代码来了解消息队列......

消息队列创建者或消息发送者

struct my_msgbuf {
    long mtype;
    char mtext[200];
};

int main(void)
{
    struct my_msgbuf buf;
    int msqid;
    key_t key;
if ((key = ftok("kirk.c", 'B')) == -1) {
    perror("ftok");
    exit(1);
}

if ((msqid = msgget(key, 0644 | IPC_CREAT)) == -1) {
    perror("msgget");
    exit(1);
}

printf("Enter lines of text, ^D to quit:\n");

buf.mtype = 1; /* we don't really care in this case */

while(fgets(buf.mtext, sizeof buf.mtext, stdin) != NULL) {
    int len = strlen(buf.mtext);

    /* ditch newline at end, if it exists */
    if (buf.mtext[len-1] == '\n') buf.mtext[len-1] = '\0';

    if (msgsnd(msqid, &buf, len+1, 0) == -1) /* +1 for '\0' */
        perror("msgsnd");
}

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

return 0;
}

消息接收者

    struct my_msgbuf {
    long mtype;
    char mtext[200];
};

int main(void)
{
    struct my_msgbuf buf;
    int msqid;
    key_t key;

    if ((key = ftok("kirk.c", 'B')) == -1) {  /* same key as kirk.c */
        perror("ftok");
        exit(1);
    }

    if ((msqid = msgget(key, 0644)) == -1) { /* connect to the queue */
        perror("msgget");
        exit(1);
    }

    printf("spock: ready to receive messages, captain.\n");

    for(;;) { /* Spock never quits! */
        if (msgrcv(msqid, &buf, sizeof(buf.mtext), 0, 0) == -1) {
            perror("msgrcv");
            exit(1);
        }
        printf("spock: \"%s\"\n", buf.mtext);
    }

    return 0;
}

以上代码可以在beej 的消息队列指南中找到。

当我尝试执行“spock”​​时，msgget() 抛出错误：没有这样的文件或目录。ftok() 有什么问题吗？我将文件的权限更改为传递给 msgget() 函数的权限。但同样的错误。提前致谢。提前致谢。

4

2 回答 2

4

ftok要求文件存在，因为它使用inode信息来构造密钥。如果您在单独的目录中构建它们，则指向kirk.c使用相对路径应该可以正常工作，例如spock/spock.c包含 spock 代码，kirk/kirk.c包含 kirk 代码，spock/spock.c您应该参考../kirk/kirk.c

于 2013-01-02T11:50:27.117 回答
1

也有同样的问题。如果你想执行消息接收者进程，你必须确保消息发送者当时也在执行。否则 msgqueue（如果你曾经运行过 message-sender）将被破坏，与之相关的 id 将不再有效。因此，它有什么神奇之处。波兹博士。

于 2013-12-21T23:46:35.730 回答