Я хочу написать 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 с клиентом: «Нет такого файла или каталога»
Сервер не создает файл, но почему?
client
#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;
}