消息队列函数的问题

UnWindows

程序如下，一个是接受一个发送
这个是发送的

1. #include<stdlib.h>
   
2. #include<stdio.h>
   
3. #include<string.h>
   
4. #include<unistd.h>
   
5. #include<sys/types.h>
   
6. #include<sys/ipc.h>
   
7. #include<sys/msg.h>
   
8. #include"err_exit.h"
   
9. 
   
10. struct my_msg{
    
11.         long int my_msg_type;
    
12.         char text[BUFSIZ];
    
13. };
    
14. int main()
    
15. {
    
16.         int running=1;
    
17.         struct my_msg msgbuf;
    
18.         int msgid;
    
19.         msgid=msgget((key_t)1234,0666|IPC_CREAT);
    
20.         if(msgid==-1)
    
21.                 err_exit("msgget failed\n");
    
22.         while(running){
    
23.                 printf("enter some text:");
    
24.                 fgets(msgbuf.text,BUFSIZ,stdin);
    
25.                 msgbuf.my_msg_type=1;
    
26.                 if(msgsnd(msgid,(void *)&msgbuf,BUFSIZ,0)==-1)
    
27.                         err_exit("msgsend failes\n");
    
28.                 if(strncmp(msgbuf.text,"end",3)==0)
    
29.                         running=0;
    
30.         }
    
31.         exit(EXIT_SUCCESS);
    
32. }
    

复制代码

UnWindows

这个是接收的

1. #include<stdlib.h>
   
2. #include<stdio.h>
   
3. #include<string.h>
   
4. #include<unistd.h>
   
5. #include<sys/types.h>
   
6. #include<sys/ipc.h>
   
7. #include<sys/msg.h>
   
8. #include"err_exit.h"
   
9. 
   
10. struct my_msg{
    
11.         long int my_msg_type;
    
12.         char text[BUFSIZ];
    
13. };
    
14. int main(void)
    
15. {
    
16.         int running=1;
    
17.         int msgid;
    
18.         struct my_msg msgbuf;
    
19.         long int msg_to_receive=0;
    
20.         msgid=msgget((key_t)1234,0666 | IPC_CREAT);
    
21.         if(msgid==-1)
    
22.                 err_exit("msgget failed\n");
    
23.         while(running){
    
24.                 if(msgrcv(msgid,(void *)&msgbuf,BUFSIZ,msg_to_receive,0)==-1)
    
25.                         err_exit("msgrcv failed\n");
    
26.                 printf("you wrote :%s",msgbuf.text);
    
27.                 if(strncmp(msgbuf.text,"end",3)==0)
    
28.                         running=0;
    
29.         }
    
30.         if(msgctl(msgid,IPC_RMID,0)==-1)
    
31.                 err_exit("msgctl(IPC_RMID) failed\n");
    
32.         exit(EXIT_SUCCESS);
    
33. }

复制代码

UnWindows

程序应该是接收用户输入直到输入“end”，然后发送数据给消息队列，然后接收数据直到“end”，但是我怎么编译通过后输入第三个消息后就不可以输入了。

efan

呵呵，我试了一下，没有问题呀。

JBug

你的第三个消息是不是以end开始呀?把输入贴出来.

UnWindows

debian:/home# ./p11-14
enter some text:a
enter some text:b
enter some text:c
                                                         /*没有反应了，ctrl+c退出
debian:/home# ./p11-13
you wrote :a
you wrote :b
                                                          /*没有反应了，ctrl+c退出

efan

这是我运行的结果
send:

[efan@nktest efan]$ ./snd
enter some text:123
enter some text:333
enter some text:444
enter some text:555
enter some text:a
enter some text:b
enter some text:c
enter some text:end

receive:

[efan@nktest efan]$ ./rcv
you wrote :123
you wrote :333
you wrote :444
you wrote :555
you wrote :a
you wrote :b
you wrote :c
you wrote :end

UnWindows

语句还有下面的msgsnd：  if(msgrcv(msgid,(void *)&msgbuf,BUFSIZ,msg_to_receive,0)==-1)
                        err_exit("msgrcv failed\n");
中，为什么用BUFSIZ，为什么不是strlen（）函数查看出msgbuf的大小！？
函数原型为
int msgrcv(int msgid,const void *msgp,size_t msgsz,int msgflg)

JBug

找到你的问题了,你的key: 1234生成的msqid是0,用ipcs -q查看, 每次msgrcv后,消息在消息队列里还存在, 用ipcs查看.
输入a之后,
ipcs -q
------ Message Queues --------
key        msqid      owner      perms      used-bytes   messages
0x000004d2 0          jbug       666        8192          1

运行./rcv之后
ipcs -q
------ Message Queues --------
key        msqid      owner      perms      used-bytes   messages
0x000004d2 0          jbug       666        8192          1

从上面的结果可以看出, 消息根本就没有被取出来,可能是由于msqid是0的原因,

系统启动以后,如果第一次用IPC_PRIVATE产生的msqid,也会产生msqid=0的消息队列,我就遇到过好几次,
最好是用文件名产生key,再用key产生msqid,在这种情况下,没有msqid为0的情况,Linux有这个性质,同一个key,比如1234, 假如第一次生成msqid为
key               msqid  
0x000004d2  262144
将它删除后,再产生一次,其msqid的值就变了.
ipcs -q
key        msqid
0x000004d2 458752