1、先说结论，消息队列用于进程间消息传递使用很方便，特别适用于异步通信。
2、试验思路：验证生产者和消费者之间的异步通信，同时通过linux上的命令行观察消息队列的使用情况。
3、试验结果：
a. 生产者（发送方）轮询从命令行上接收字符串，消费者（接收方）进程会自动打印内容。
b. 生产者先发送很多信息，消费者还没有启动。后来，消费者进程才启动，消费者进程也是可以正常显示数据的。
c. 在生产者和消费者配合的过程中，通过ipcs命令行查看消息队列的状态。
d. 生产者先生产，然后再启动消费者。此时从命令行上查看ipcs，可以看到有缓存的消息
后启动消费者进程。可见缓存的消息已被处理结束。
下面是接收方和发送方的源代码：
接收方 rcv.c
#include <stdlib.h> #include <stdio.h> #include <string.h> #include <errno.h> #include <unistd.h> #include <sys/msg.h> struct my_msg_st { long int my_msg_type; char some_text[BUFSIZ]; }; int main() { int running = 1; int msgid; struct my_msg_st some_data; long int msg_to_receive = 0; msgid = msgget((key_t) 1234, 0666 | IPC_CREAT); if( -1 == msgid) { fprintf(stderr, "msgget failed with error: %d \n", errno); exit(EXIT_FAILURE); } while(running) { if( msgrcv(msgid, (void *)&some_data, BUFSIZ, msg_to_receive, 0) == -1) { fprintf(stderr, "msgrcv failed with error : %d \n", errno); exit(EXIT_FAILURE); } printf("You wrote %s", some_data.some_text); if(strncmp(some_data.some_text, "end", 3) == 0) { running = 0; } } if(msgctl(msgid, IPC_RMID, 0) == -1) { fprintf(stderr, "msgctl(IPC_RMID) failed"); exit(EXIT_FAILURE); } exit(EXIT_SUCCESS); } 发送方 snd.c #include <stdlib.h> #include <stdio.h> #include <string.h> #include <errno.h> #include <unistd.h> #include <sys/msg.h> #define MAX_TEXT 512 struct my_msg_st { long int my_msg_type; char some_text[BUFSIZ]; }; int main() { int running = 1; int msgid; struct my_msg_st some_data; char buffer[BUFSIZ]; msgid = msgget((key_t) 1234, 0666 | IPC_CREAT); if( -1 == msgid) { 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, "msgsnd failed with error : %d \n", errno); exit(EXIT_FAILURE); } if(strncmp(buffer, "end", 3) == 0) { running = 0; } } exit(EXIT_SUCCESS); } 编译方法：[zhou@localhost msgqueue]$ gcc rcv.c -o rcv.o [zhou@localhost msgqueue]$ gcc snd.c -o snd.o [zhou@localhost msgqueue]$ chmod 777 rcv.o [zhou@localhost msgqueue]$ chmod 777 snd.o [zhou@localhost msgqueue]$
