msg2.c

来自「国嵌所有的实验代码」· C语言 代码 · 共 55 行

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

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

int main(void)
{
    int running=1;
	struct my_msg_st some_data;
	int msgid;
	char buffer[BUFSIZ];

	/*创建消息队列*/
	msgid=msgget((key_t)1234,0666 | IPC_CREAT);
	if(msgid==-1)
	{
	    fprintf(stderr,"msgget failed with error:%d\n",errno);
		exit(EXIT_FAILURE);
    }

	/*循环向消息队列中添加消息*/
	while(running)
	{
	    printf("Enter some text:");
		fgets(buffer,BUFSIZ,stdin);
		some_data.my_msg_type=1;
		strcpy(some_data.some_text,buffer);

		/*添加消息*/
		if(msgsnd(msgid,(void *)&some_data,MAX_TEXT,0)==-1)
		{
		    fprintf(stderr,"msgsed failed\n");
			exit(EXIT_FAILURE);
		}

		/*用户输入的为“end”时结束循环*/
		if(strncmp(buffer,"end",3)==0)
		{
		    running=0;
		}
	}
	exit(EXIT_SUCCESS);
}