rcvmsg.cpp

linux环境下 消息队列的简单使用

#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <errno.h>
#include <unistd.h>
#include <sys/types.h>
#include <sys/ipc.h>
#include <sys/msg.h>

#define BUGSIZE 1024

struct my_msg_st
{
	long int my_msg_type;
	char some_text[BUGSIZE];
};

int main()
{

	int running = 1;
	int msgid;
	struct my_msg_st some_data;
	long int msg_to_receice = 0;
	
	msgid = msgget((key_t)12341, 0666|IPC_CREAT);
	if(msgid == -1)
	{
		fprintf(stderr, "msgget failed with error: %d \n", errno);
		exit(EXIT_FAILURE);
	}
	while(running)
	{
		if(msgrcv(msgid, (void*)&some_data, BUFSIZ, msg_to_receice, 0) == -1)
		{
			fprintf(stderr, "msgget failed with error: %d \n", errno);
			exit(EXIT_FAILURE);
		}
		printf("you wrote : %s", some_data.some_text);	
		if(strncmp(some_data.some_text, "end", 3) == 0)
		{
			running = 0;
		}

	}
	if(msgctl(msgid, IPC_RMID, 0) == -1)
	{
		
		fprintf(stderr, " msgctl(IPC_RMID) failed \n");
		exit(EXIT_FAILURE);
	}

	
	exit(EXIT_SUCCESS);

}