我想编写 2 个与消息队列通信的程序!
通用.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;
}
最佳答案
我找到了,我写了
if((mqd_t)-1 != mq)
对不起!
但是问题还是一样!客户端没有收到任何消息
错误:消息太长
MAX_SIZE 的大小太短了,我把它提高到 1024,效果很好!
关于c - 消息队列 - Solaris10 - 无法打开,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/9852187/