消息队列的程序

zcw_ease

#include <stdio.h>
#include <stdlib.h>
#include <sys/types.h>
#include <sys/ipc.h>
#include <sys/msg.h>
#include <unistd.h>
#include <errno.h>
#include <string.h>
void quit(char *err)
{
  perror(err);
  exit(EXIT_FAILURE);
}
struct msgbuf
{
  long mtype;
  char msg_text[100];
};
int main(int arg,char *arc[])
{
  int ret;
  struct msgbuf msg;
  int msqid;
  msg.mtype=getpid();
  strcpy(msg.msg_text,"I send the message!\0");
  while(arg!=2)
  {
    printf("the number of arguments should be two\n");
    quit("arg number");
  }
  int key=atoi(arc[1]);
  if((msqid=msgget(key,0))<0)
  { printf("key:%d don't exists\n",key);
    msqid=msgget(key,IPC_CREAT|0666);
    if(msqid<0)
      quit("msgget create");
    printf("msg queue create successfully\n");
  }
  system("ipcs -q");
  int len=strlen(msg.msg_text);
  int pid;
  //if((pid=fork())<0)
   // quit("fork");
  //if(pid==0)
  {
    ret=msgsnd(msqid,&msg,len,0);
    if(ret<0)
      quit("msgsnd");
  }
  //else
  {
   // wait(pid);
    ret=msgrcv(msqid,&msg,len,0,0);
    if(ret<0)
      quit("msgrcv");
    printf("message content:%s\n",msg.msg_text);
    printf("message type=%d\n",msg.mtype);
  }
  system("ipcs -q");
  msgctl(msqid,IPC_RMID,NULL);
  exit(EXIT_SUCCESS);
}
现在这个程序是单进程，程序好使，当将注释加入的时候，想实现多进程，程序执行时就出现msgrcv的参数无效，为什么？
另外问一下，对于进程之间共资源“子进程具有父进程的副本”这句话怎样理解，是不是父进程的所有资源子进程都具有它的副本呢，请指教

rickxbx

是你的wait搞错了，改一下，变成下面这个样子：

1. 
   
2. #include <stdio.h>
   
3. #include <stdlib.h>
   
4. #include <sys/types.h>
   
5. #include <sys/ipc.h>
   
6. #include <sys/msg.h>
   
7. #include <unistd.h>
   
8. #include <errno.h>
   
9. #include <string.h>
   
10. void
    
11. quit (char *err)
    
12. {
    
13.   printf("error : %d\n",errno);
    
14.   perror (err);
    
15.   exit (EXIT_FAILURE);
    
16. }
    
17. struct msgbuf
    
18. {
    
19.   long mtype;
    
20.   char msg_text[100];
    
21. };
    
22. 
    
23. int
    
24. main (int arg, char *arc[])
    
25. {
    
26.   int ret;
    
27.   struct msgbuf msg = {1,{0}};;
    
28.   int msqid;
    
29.   msg.mtype = getpid ();
    
30.   strcpy (msg.msg_text, "I send the message!\0");
    
31.   while (arg != 2)
    
32.     {
    
33.       printf ("the number of arguments should be two\n");
    
34.       quit ("arg number");
    
35.     }
    
36.   int key = atoi (arc[1]);
    
37.   if ((msqid = msgget (key, 0)) < 0)
    
38.     {
    
39.       printf ("keyd don't exists\n", key);
    
40.       msqid = msgget (key, IPC_CREAT | 0666);
    
41.       if (msqid < 0)
    
42.                 quit ("msgget create");
    
43.       printf ("msg queue create successfully\n");
    
44.     }
    
45.   system ("ipcs -q");
    
46.   int len = strlen (msg.msg_text);
    
47.   int pid;
    
48.   if((pid=fork())<0)
    
49.         quit("fork");
    
50.   if(pid==0)
    
51.   {
    
52.     ret = msgsnd (msqid, &msg, len, 0);
    
53.     if (ret < 0)
    
54.       quit ("msgsnd");
    
55.     exit(0);
    
56.   }
    
57.   else
    
58.   {
    
59.     int status;
    
60.     waitpid(pid,&status,0);
    
61.     ret = msgrcv (msqid, &msg, len, 0, 0);
    
62.     if (ret < 0)
    
63.       quit ("msgrcv");
    
64.     printf ("message contents %s\n", msg.msg_text);
    
65.     printf ("message type=%d\n", msg.mtype);
    
66.   }
    
67.   system ("ipcs -q");
    
68.   msgctl (msqid, IPC_RMID, NULL);
    
69.   exit (EXIT_SUCCESS);
    
70. }
    
71. 
    

复制代码