消息队列 - Solaris10 - 无法打开答案

【问题标题】：Message Queue - Solaris10 - Could not open消息队列 - Solaris10 - 无法打开
【发布时间】：2012-04-08 18:42:42
【问题描述】：

我想写 2 个与消息队列通信的程序！

common.h

#ifndef COMMON_H
#define COMMON_H

#define QUEUE_NAME "/zq1"
#define MAX_SIZE 100
#define MSG_STOP "quit"

#endif

服务器

#include <stdio.h>
#include <strings.h>
#include <mqueue.h>
#include <fcntl.h>
#include <sys/stat.h>
#include <sys/types.h>
#include <unistd.h>
#include "common.h"

int main(int argc,char **argv)
{
    char buf[MAX_SIZE];
    int size=0;
    mqd_t mq;
    int open_flags= O_CREAT | O_RDWR | O_EXCL;



mq=mq_open(QUEUE_NAME, open_flags, S_IRWXU | S_IRWXG, NULL);

if(mq ==(mqd_t)-1)
{
    perror("Message Queue Open Failed");
    return 1;
}


/* INPUT */
printf("Exit with 'quit' \n\n");
for(;;)
{
    printf("Eingabe:");
    fgets(buf,sizeof(buf),stdin);
    size=strlen(buf);
    buf[size-1]=0;

    if(mq_send(mq,buf,strlen(buf),0)<0)
    {
        perror("Failure mq_send()");
    }
    if(strcmp(buf,MSG_STOP)==0) break;
}
/*
for(;;)
{
    memset(&buf,0,sizeof(buf));
    mq_receive(mq,buf,MAX_SIZE,NULL);
    printf("%s ",buf);
    if(strcmp(buf,MSG_STOP)==0) break;
}
*/
mq_close(mq);
//  mq_unlink(QUEUE_NAME);

return 0;
}

我可以读写，但如果我想用客户端打开 mq： "没有这样的文件或目录"

服务器没有创建文件，但是为什么？

客户

#include <mqueue.h>
#include "common.h"
#include <stdio.h>
#include <strings.h>

int main()
{
mqd_t mq;
char buf[MAX_SIZE];
ssize_t bytes_read;

mq=mq_open(QUEUE_NAME,O_RDWR);
if((mqd_t)-1 == mq)
{
    perror("Error mq_open()");
    return 1;
}

for(;;)
{
    bytes_read=mq_receive(mq,buf,MAX_SIZE,NULL);
            if(bytes_read == -1) perror("Error Read")
    printf("inhalt:%s",buf);
    if(strncmp(buf,MSG_STOP,strlen(MSG_STOP))==0)
        break;
}
return 0;
}

【问题讨论】：

可以添加完整的代码吗？

标签： c ipc solaris message-queue

【解决方案1】：

我找到了，我写了

if((mqd_t)-1 != mq)

对不起！

但问题还是一样！客户端没有收到任何消息

错误：消息太长

MAX_SIZE的大小太短了，我把它提高到1024，效果很好！

【讨论】：

在这种情况下，您会在客户端中获得Error mq_open(): Success，对吗？