1 #include <stdio.h>
 2 #include <sys/types.h>
 3 #include <sys/ipc.h>
 4 #include <sys.msg.h>
 5 
 6 struct msgt
 7 {
 8     long msgtype;
 9     char msgtext[1024];
10 };
11 
12 int main()
13 {
14     int msqid;
15     int msg_type;
16     //创建消息队列
17     msqid = msgget(1024,IPC_CREAT);
18     char str[256];
19     struct msgt msgs;
20     
21     //循环
22     while(1)
23     {
24         printf("please input message type,0 for quit!\n");
25         //获取消息类型
26         scanf("%d",&msg_type);
27         //如果用户输入的消息类型为0，退出该循环
28         if(msg_type == 0)
29         {
30             break;
31         }
32         //获取消息数据
33         printf("please input message content\n");
34         scanf("%s",str);
35         msgs.type = msg_type;
36         strcpy(msgs.msgtext,str);
37         //发送消息
38         msgsnd(msqid,&msgs,sizeof(struct msgt),0);
39         
40     }
41 
42     msgctl(msqid,IPC_RMID,0);
43     //删除消息队列
44 
45     return 0;
46 
47 }

 1 #include <stdio.h>
 2 #include <sys/ipc.h>
 3 #include <sys/types.h>
 4 #include <sys/msg.h>
 5 
 6 int msqid = 0;
 7 
 8 struct msgt
 9 {
10     long msgtype;
11     char msgtext[1024];
12 };
13 void childprocess()
14 {
15     struct msgt msgs;
16 
17     while(1)
18     {
19         //接收消息队列
20         msgrcv(msqid,&msgs,sizeof(struct msgt),0,0);
21     
22         //打印消息队列中的数据
23         printf("msg text: %s\n",msgs.msgtext);
24     }
25     return;
26 }
27 
28 int main()
29 {
30     int i;
31     int cpid;
32     //打开消息队列
33     msqid = msgget(1024,IPC_EXCL);
34 
35     //创建3个子进程
36     for(i=0;i<3;i++)
37     {
38         cpid = fork();
39         if(cpid < 0)
40         {
41             printf("creat child process error!\n");
42         }
43         else if(cpid == 0)
44         {
45             childprocess();
46         }
47     }
48     
49     return 0;
50 }