Client to Server Communication using a Message Queue

So here's my issue:
I need to implement a program(client and server) using message queues instead of named pipes (FIFO's).

I already do the client and server programs using named pipes (FIFO's), but I need change these programs in order to use message queues.

Any idea for the new code?
Thanks

The client program:

Code:

#include <unistd.h>
#include <stdlib.h>
#include <stdio.h>
#include <string.h>
#include <sys/types.h>
#include <sys/socket.h>
#include <sys/un.h>
#include <float.h>
#include <fcntl.h>
#include <limits.h>

#define  FIFO_Name "FIFO"

int main()
{	
	FILE *inasc;
	float fltmax=FLT_MAX;
	float aux;
	int ffopen;

	
	if((ffopen = open(FIFO_Name,O_WRONLY)) < 0)
	{
		perror("\nFIFO not open\n");
		exit(1);
	}
	
	if((inasc=fopen("input.asc","rb")) < 0)
	{
		perror("\nERROR OPEN THE FILE input.asc\n");
		exit(1);
	}

	
	else 
	{
		printf("\nOPEN THE FILE input.asc\n");
		while(!feof(inasc))
		{
			int ret=fscanf(inasc, "%f", &aux); 	
			if(ret==1){			
				if(aux<FLT_MAX){
					write(ffopen,&aux,sizeof(aux)); 
					printf("DATA SEND TO FIFO %f\n",aux);
				}
			}				
			
		}
	/**/
	write(ffopen,&fltmax,sizeof(fltmax));
	close(ffopen);
	}
return 0;
}

The server program:

Code:

#include <stdio.h>
#include <string.h>
#include <fcntl.h>
#include <float.h>
#include <stdlib.h>
#include <errno.h>
#include <sys/un.h>
#include <unistd.h>
#include <sys/stat.h>

#define FIFO_Name "FIFO"

int main()
{
	remove(FIFO_Name);
	remove("input.bin");
	
	int inbin;
	FILE *bin;
	FILE *outasc;

	int conta = 0;
	
	
	int ff = mkfifo(FIFO_Name, O_CREAT|O_EXCL | 0777);
	if (ff < 0)
	{
		perror("\nFIFO NOT CREATED\n");
		exit(1);
	}
	else
	{
		printf("\nFIFO CREATED! CONECTING...\n");
	}

	
	int ffread = open(FIFO_Name,O_RDONLY);
	if(ffread < 0)
	{
		perror("\nISN'T POSSIBLE READ THE FIFO!\n");
		exit(1);
	}
	else
	{
		printf("\nEND OF READING.\n");
	}

	float TEMP;
	
	
	if((inbin = open("input.bin",O_WRONLY|O_TRUNC|O_CREAT,0600)) < 0)
	{
		perror("\nERROR NO input.bin!\n");
		exit(1);
	}
	
	else
	{
		printf("\n FILE input.bin READ\n");
		printf("-------------------------\n\n");
		while(TEMP != FLT_MAX)
		{
			read(ffread, &TEMP, sizeof(TEMP));
			if(TEMP<FLT_MAX){				
				write(inbin,&TEMP,sizeof(TEMP));
				printf("DATA RECEIVED IN CLIENT: %f\n",TEMP);
				conta++;
			}								
			
		}
	}
	
	
	int closeinbin = close(inbin);
	if(closeinbin < 0)
	{
		perror("\nERROR CLOSE THE FILE input.bin\n");
		exit(1);
	}
	float tab[conta];

	
	int readinbin = fread(&tab,sizeof(tab),1,(bin=fopen("input.bin","r")));
	if(bin < 0 || readinbin < 0)
	{
		perror("\nERROR TRY TO OPEN FILE input.bin\n");
		exit(1);
	}
	
	if(fclose(bin) < 0)
	{
		perror("\nERROR CLOSE THE FILE input.bin!\n");
		exit(1);
	}
	remove(FIFO_Name);
	


	if((outasc=fopen("output.asc","a")) < 0)	/
	{
		perror("ERROR OPEN output.asc");
		exit(1);
	}

	
	int i;
	
	printf("\n\n IN FILE ASCII WAS WRITE:\n");
	printf("-------------------------------------------\n");
	for(i = 0; i < conta; i++)
	{
		char BUFFER[20]; 
		tab[i] = 3.0*tab[i];	
		sprintf(BUFFER,"%lf",tab[i]);
		fputs(BUFFER,outasc);
		fputs("\n",outasc);
		printf("WRITE %f \n",tab[i]);
	}

	if(fclose(outasc) < 0)
	{
		printf("ERROR CLOSE THE FILE");
		exit(1);
	}
	
	return 0;
}

The file input.asc can be:

1.1
2.2
3.3
4.4
5.5

Yes, you read the manual pages on message queues, and try to write a simple test program which sends

Code:

char message[] = "hello world";

through the queue.

Then you post your attempt here if you get stuck somewhere.

But if you figure it out from your simple example, you can then replace the FIFO bits in your code with the MQ bits, and you're done.