Linux进程间通信（简单的消息队列通信）

前几天在计算机操作系统课中学习了Linux下进程通信，今日做了个消息队列通信的简单小程序，权当练习。

程序有服务器和客户端两个进程。先运行服务器，然后客户端。客户端向服务器发送问题，服务器收到后可进行回复。

服务器运行时先判断要创建的消息队列是否存在，若已经存在，则退出。不存在，进入循环。（此为关键。若队列存在仍继续操作，则将二者都收不到消息。（不知为何哈！求高人解释。最早就是再此出耽误了很多时间，还以为是自己程序的毛病呢。））

msgrcv最后个参数设置为0，意思为若当前队列中无消息，则阻塞。等待消息进入队列后接受（即等待客户端启动发送消息） 。然后客户端，服务器无限循环进行问答。若想退出，按ctrl+c。

用到的主要函数：msgget() 创建消息队列 msgrcv()接受消息 msgsnd()发送消息 msgctl()操纵一个消息 fgets()键盘接受字符串，放入message.buffer。详细内容可使用man msgget ....等命令查找。

程序源码如下：

serve.c:

/*Serve process.Write in Ubuntu 11.04*/
#include<stdio.h>
#include<sys/types.h>
#include<sys/ipc.h>
#include<sys/msg.h>
#define Histype 4  //message 的类型。区分服务器和客户端发送的不同消息。接受时，第四个参数设置此类型。下Mytype相同。
#define Mytype 3
#define MY_KEY 20
struct mymessage
{
long mtype;
char buffer[200];
} message;
int msgid;
void server()
{
msgid=msgget(MY_KEY, IPC_CREAT|IPC_EXCL|0666);//IPC_CREAT创建消息，和IPC_EXCL一起使用如果消息已经存在则返回-1；
if(msgid<0)
{
printf("消息队列已经存在！");
exit(0);//消息存在退出.若消息存在仍不退出，则此服务器将陷入死循环。
}
printf("server start:\n");
while(1)
{
msgrcv(msgid,&message,sizeof(struct mymessage),Histype,0);
printf("Question is:\n%s", message.buffer);
printf("Here is the answer :\n");
fgets(message.buffer,sizeof(struct mymessage)-sizeof(long)-1,stdin);//用stdin从键盘接受字符串，存入message.buffer。置于大小的计算，可查指令手册
message.mtype=Mytype;//服务器消息标识
msgsnd(msgid, &message, sizeof(struct mymessage), 0);
}
}
int main()
{
server();
}

client.c:

/*Client process.Write in Ubuntu 11.04*/
#include<stdio.h>
#include<sys/types.h>
#include<sys/ipc.h>
#include<sys/msg.h>
#define Mytype 4
#define Histype 3
#define MY_KEY 20
struct mymessage
{
long mtype;
char buffer[200];
} message;
int msgid;
void client()
{
msgid=msgget(MY_KEY, 0666);//MY_KEY是消息的关键建。唯一标识一个消息。该句返回消息ID
if(msgid>=0)
printf("welcome to numeber %d queue!Input your questions\n",msgid);
else
{
exit(0);//若msgid>=0则说明存在该消息队列。不存在则<0,退出。
}
fgets(message.buffer, sizeof(struct mymessage)-sizeof(long)-1, stdin);
while(1)
{
message.mtype=Mytype;
msgsnd(msgid, &message, sizeof(struct mymessage), 0);
msgrcv(msgid,&message,sizeof(struct mymessage),Histype,0);
printf("The answer is: %sInput your question:\n",message.buffer);
fgets(message.buffer,sizeof(struct mymessage)-sizeof(long)-1,stdin);
}
}
int main()
{
client();
}

运行结果如下：