linux c消息队列例子
/*设计两个程序，
要求
对教师党员的评价套管和固井爆破片与爆破装置仓库管理基本要求三甲医院都需要复审吗
用消息队列实现聊天程序，每次发言后自动在后面增加当前
系统时间。增加结束字符，比如最后输入“88”后结束今年成*/
/*未实现自动添加当前系统时间和结束字符*/
/*第一个程序，先添加消息后读取消息*/
#include
#include
#include
#include
#include
#include
#include
struct msgmbuf /*定义消息的结构体*/
{
long msg_type; /*消息类型*/
int msg_date; /*添加系统时间*/
char msg_text[1024]; /*消息内容*/
};
int main()
{
int ret;
int qid;
key_t key;
struct msgmbuf msg;
msg.msg_type=100; /*定义写入消息类型为100*/
key=ftok(".",'a'); /*产生
标准
excel标准偏差excel标准偏差函数exl标准差函数国标检验抽样标准表免费下载红头文件格式标准下载
key*/
if(key==-1)
{
perror("产生标准key错误!\n");
exit(1);
}
qid=msgget(key,IPC_CREAT|0666); /*创建消息队列返回值为qid*/
if(qid==-1)
{
perror("创建消息队列失败!");
exit(1);
}
while(1)
{
/*从键盘获取发送内容，并利用msgsnd添加消息，ret判断添加消息是否成功*/
printf("请输入发送内容:\n");
scanf("%s",&msg.msg_text);
msg.msg_date=system("date|cut -d' ' -f 5"); /*添加系统时间*/
ret=msgsnd(qid,&msg,sizeof(msg.msg_text),msg.msg_type);
if(ret<0)
{
perror("添加消息失败!");
exit(1);
}
/*定义读取消息类型为200利用msgrcv读取消息，并添加到标准输出*/
msg.msg_type=200;
msgrcv(qid,&msg,sizeof(msg),msg.msg_type,0);
if(ret<0)
{
perror("读取消息失败!");
exit(1);
}
printf("读取的内容为:\n%s\n",msg.msg_text);
}
msgctl(qid,IPC_RMID,NULL); /*关闭消息队列*/
return 0;
}
/*第二个程序，先读取消息后添加消息*/
#include
#include
#include
#include
#include
struct msgmbuf /*定义消息结构体*/
{
int msg_type; /*消息类型*/
int msg_date; /*消息发送时间*/
char msg_text[1024]; /*消息内容*/
};
int main()
{
int ret;
int qid;
key_t key;
struct msgmbuf msg;
msg.msg_type=100; /*读取消息类型为100*/
key=ftok(".",'a'); /*产生标准key*/
if(key==-1)
{
perror("产生标准key错误!\n");
exit(1);
}
qid=msgget(key,IPC_CREAT|0666); /*创建消息队列*/
if(qid==-1)
{
perror("创建消息队列失败!");
exit(1);
}
while(1)
{
/*先利用msgrcv读取demo5-1发送的消息，并添加到标准输出*/
ret=msgrcv(qid,&msg,sizeof(msg),msg.msg_type,0);
if(ret==-1)
{
perror("读取消息失败!");
exit(1);
}
printf("读取的内容为:\n%s\n",msg.msg_text);
/*定义写入消息类型为200，并从键盘获取发送内容，利用msgsnd添加消息*/
msg.msg_type=200;
printf("请输入发送内容:\n");
scanf("%s",&msg.msg_text);
msg.msg_date=system("date|cut -d' ' -f 5");
ret=msgsnd(qid,&msg,sizeof(msg.msg_text),msg.msg_type);
if(ret==-1)
{
perror("添加消息失败!");
exit(1);
}
}
msgctl(qid,IPC_RMID,NULL); /*关闭消息队列*/
return 0;
}
浙公网安备 33021202002483