消息队列通讯编程

1.基本概念

消息队列就是一个消息的链表。而一条消息则可看做是一个记录，具有特定的格式

进程可以按照一定的规则添加新消息；另一些进程则可以从消息队列中读走消息。

2.函数学习

创建消息队列

函数名：msgget

函数原型：int msgget(key_t key,int msgflg)

函数功能：打开或创建消息队列

头文件：<sys/types.h> <sys/ipc.h><sys/msg.h>

返回值：成功：返回消息队列的id  失败：-1

参数说明：key：键值  msgflg：打开标志IPC_CREAT标明新创建一个消息队列

写消息

函数名：msgsnd

函数原型：int msgsnd(int msqid,const void *msqp,size_t msgsz,int msgflg)

函数功能：发送消息到消息队列

头文件：<sys/types.h> <sys/ipc.h> <sys/msg.h>

返回值：失败：-1  成功：0

参数说明：msqid：消息队列的id

msgp：指向要发送的消息

msgsz：消息的长度

msgflg：标志

读消息

函数名：msgrcv

函数原型：ssize_t msgrcv(int msqid,void *msgp,size_t msgsz,long msgtyp,int msgflg)

函数功能：从消息队列中接收消息

头文件：<sys/types.h>  <sys/ipc.h> <sys/msg.h>

返回值：失败：-1 成功：实际接收到的消息长度

参数说明：msqid：消息队列的id

msgp：存放取出的消息

msgsz：希望取到消息的最大长度

msgtyp：消息的类型 取值0 则忽略类型 大于0取消息队列中类型等于msgtyp的第一条消息  小与0取类型比msgtyp的绝对值要小与等于的消息，如果有多条消息满足，则取类型最小的

msgflg：标志

删除消息队列

函数名：msgctl

函数原型：int msgctl(int msgqid,int cmd,struct msgqid_ds *buf)

函数功能：控制消息队列

头文件：<sys/types.h> <sys/ipc.h> <sys/msg.h>

返回值：成功：0   失败：-1

参数说明：msgqid：消息队列的id

cmd：对消息队列的操作命令

IPC_RMID删除消息队列

buf：获取内核中msqid_ds

3.综合实例

/* send.c */

#include <stdio.h>
#include <sys/types.h>
#include <sys/ipc.h>
#include <sys/msg.h>

struct msgt
{
	long msgtype;
	char msgtext[1024];
};

void main()
{
	int msqid;
	int msg_type;
	char str[256];
	struct msgt msgs;

	//创建消息队列
	msqid = msgget(1024,IPC_CREAT);

	while(1)
	{
		printf("please input message type,0 for quit");
		//获取消息类型
		scanf("%d",&msg_type);

		//如果用户输入的消息了类型为0，则退出
		if(msg_type == 0)
			break;

		//获取消息数据
		printf("please input message content\n");
		scanf("%s",str);

		msgs.msgtype = msg_type;
		strcpy(msgs.msgtext,str);

		//发送消息
		msgsnd(msqid,&msgs,sizeof(struct msgt),0);
	}
	//删除消息队列
	msgctl(msqid,IPC_RMID,0);
}

/* receive.c */

#include <stdio.h>
#include <sys/types.h>
#include <sys/ipc.h>
#include <sys/msg.h>

int msqid;

struct msgt
{
	long msgtype;
	char msgtext[1024];
};

void childprocess()
{
	struct msgt msgs;

	while(1)
	{
		//接收消息队列
		msgrcv(msqid,&msgs,sizeof(struct msgt),0,0);

		//打印消息数据
		printf("msg text:%s\n",msgs.msgtext);
	}
	return;
}

void main()
{
	int i;
	int pid;

	//打开消息队列
	msqid = msgget(1024,IPC_EXCL);

	//创建3个子进程
	for(i=0; i<3; i++)
	{
		pid = fork();
		if(pid<0)
		{
			printf("creat child process error\n");
		}
		else if(pid == 0)
		{
			childprocess();
		}
	}
}