一.消息队列
创新互联建站坚持“要么做到，要么别承诺”的工作理念，服务领域包括：
成都网站设计、网站建设、企业官网、英文网站、手机端网站、网站推广等服务，满足客户于互联网时代的
萧县网站设计、移动媒体设计的需求，帮助企业找到有效的互联网解决方案。努力成为您成熟可靠的网络建设合作伙伴！
消息队列是一个进程向另一个进程发送一个数据块的方法，所以消息队列是基于消息的，而管道则是基于字节流的。消息队列提供的是进程间的双向通信。
消息队列中的几个原型函数：
1.获取消息信息：int msgget(key_t key,int msgflag);key 是用ftok()函数创建的
2.接收消息：ssize_t msgrcv(int msqid, void *msgp, size_t msgsz, long msgtyp, int msgflg);
3.发送消息：int msgsnd(int msqid, const void *msgp, size_t msgsz, int msgflg);
4.销毁消息信息：int msfctl(int msgid)
查看key值命令：ipcs -q
删除key值命令：ipcs -q key值
//comm.h
#pragma once
#include
#include
#include
#include
#include
#include
#include
#define _PATH_ "." //路径
#define _PROJ_ID_ 0x7777
#define _BLOCK_SIZE_ 1024
#define _CLIENT_TYPE_ 1
#define _SERVER_TYPE_ 2
struct msgBuf //定义一个消息结构体
{
long mtype; //消息类型
char mtext[_BLOCK_SIZE_];
};
static int creat_msg_queue();
int get_msg_queue();
int send_msg_queue(int msg_id,const char*info,long type);
int recv_msg_queue(int msg_id,char info[],long type);
int destroy_msg_queue(int msg_id);
//comm.c
#include"comm.h"
int get_msg_queue()
{
return creat_msg_queue();
}
static int creat_msg_queue()
{
key_t key=ftok(_PATH_,_PROJ_ID_);
if(key<0)
{
perror("ftok");
return -1;
}
int msg_id=msgget(key,IPC_CREAT);
if(msg_id<0)
{
perror("msgget");
return -1;
}
return msg_id;
}
int send_msg_queue(int msg_id,const char*info,long type)//将要发送的消息存入mtext中
{
struct msgBuf msg;
msg.mtype=type;
memset(msg.mtext,'\0',sizeof(msg.mtext));
strcpy(msg.mtext,info);
if(msgsnd(msg_id,&msg,sizeof(msg.mtext),0)<0)
{
perror("msgsnd");
return -1;
}
return 0;
}
int recv_msg_queue(int msg_id,char* info,long type)//将mtext中的消息拿出放入info中
{
struct msgBuf msg;
if(msgrcv(msg_id,&msg,sizeof(msg.mtext),type,0)<0)
{
perror("msgrcv");
return -1;
}
strcpy(info,msg.mtext);
return 0;
}
int destroy_msg_queue(int msg_id)
{
if(msgctl(msg_id,IPC_RMID,NULL)<0)
{
perror("msgctl");
return -1;
}
return 0;
}
//server.c 先发送后接收
#include"comm.h"
int main()
{
int msgid=get_msg_queue();
if(msgid<0)
{
exit(1);
}
char info[_BLOCK_SIZE_];
while(1)
{
memset(info,'\0',sizeof(info));
printf("please input:");
fflush(stdout);
gets(info);
if(send_msg_queue(msgid,info,_SERVER_TYPE_)<0)
{
printf("send information failed\n");
exit(1);
}
if(recv_msg_queue(msgid,info,_CLIENT_TYPE_)<0)
{
printf("recieve information failed\n");
exit(1);
}
printf("client:%s\n",info);
}
destroy(msgid);
return 0;
}
//client.c 先接收后发送
#include"comm.h"
int main()
{
int msgid=get_msg_queue();
if(msgid<0)
{
exit(1);
}
char info[_BLOCK_SIZE_];
memset(info,'\0',sizeof(info));
printf("when input stop endding...\n");
while(1)
{
if(recv_msg_queue(msgid,info,_SERVER_TYPE_)<0)
{
printf("recieve information failed\n");
exit(1);
}
else
{
if(strcmp("stop",info)==0)
{
return 0;
}
printf("server :%s\n",info);
}
printf("please input:");
fflush(stdout);
gets(info);
if(send_msg_queue(msgid,info,_CLIENT_TYPE_)<0)
{
printf("send information failed\n");
exit(1);
}
}
destroy(msgid);
return 0;
}
运行结果：
另外有需要云服务器可以了解下创新互联scvps.cn，海内外云服务器15元起步，三天无理由+7*72小时售后在线，公司持有idc许可证，提供“云服务器、裸金属服务器、高防服务器、香港服务器、美国服务器、虚拟主机、免备案服务器”等云主机租用服务以及企业上云的综合解决方案，具有“安全稳定、简单易用、服务可用性高、性价比高”等特点与优势，专为企业上云打造定制，能够满足用户丰富、多元化的应用场景需求。
分享名称：进程间通信：消息队列的实现-创新互联
转载源于：
http://cdkjz.cn/article/cspesh.html
