消息队列

零的执行人

1. #include <sys/types.h>
   
2. #include <sys/ipc.h>
   
3. #include <sys/msg.h>
   
4. #include <stdio.h>
   
5. #include <stdlib.h>
   
6. #include <string.h>
   
7. 
   
8. #define MSGKEY 75
   
9. struct msgform
   
10. {
    
11.         long mtype;
    
12.         char mtext[512];
    
13.        
    
14. };
    
15. 
    
16. int main()
    
17. {
    
18.         struct msgform msg;
    
19.         int msgqid,pid,*pint;
    
20.         msgqid =msgget (MSGKEY,0777);
    
21.         pid= getpid ();
    
22.         pint =(int*)msg.mtext;
    
23.         *pint=pid;
    
24.         msg.mtype=1;//定义消息类型
    
25.         msgsnd(msgqid,&msg,sizeof(int),0);//发送消息
    
26.         msgrcv(msgqid,&msg,512,pid,0);//接受服务者server消息
    
27.         printf("client: receive from pid %d\n",*pint);
    
28.        
    
29. }
    
30. 
    
31. 
    
32. 
    
33. 
    

复制代码

1. #include <sys/types.h>
   
2. #include <sys/ipc.h>
   
3. #include <sys/msg.h>
   
4. #include <stdio.h>
   
5. #include <stdlib.h>
   
6. #include <string.h>
   
7. #include <unistd.h>
   
8. #define MSGKEY 75
   
9. struct msgform
   
10. {
    
11.         long mtype;
    
12.         char mtext[512];
    
13.        
    
14. }msg;
    
15. int msgqid;
    
16. 
    
17. int main()
    
18. {
    
19.         int i,pid,*pint;
    
20.         extern cleanup();
    
21.         for(i=0;i<20;i++){//软中断处理
    
22.                 signal (i,cleanup);
    
23.         }
    
24.         //建立与顾客进程相同的消息队列
    
25.         msgqid=msgget(MSGKEY,0777|IPC_CREAT);
    
26.         for(;;)
    
27.         {
    
28.                 msgrcv(msgqid,&msg, 512,1,0);
    
29.                 pint=(int*)msg.mtext;
    
30.                 pid =*pint;
    
31.                 printf ("server:receive from pid %d\n",pid);//接受客户client消息
    
32.                 msg.mtype= pid;
    
33.                 *pint= getpid();
    
34.                 msgsnd(msgqid,&msg,sizeof(int),0);
    
35.         }
    
36.        
    
37. }
    
38. 
    
39. cleanup()
    
40. {
    
41.         msgctl(msgqid,IPC_RMID,0);
    
42.         exit (1);
    
43. }
    
44. 
    
45. 
    

复制代码

请问为什么在我运行server接收不到消息？