各位大人来讲讲啊..posix ipc消息队列

pandaiam

公司的ipc基本上都是封装的,所以平时没写过,也不怎么熟悉.
并且大致看了下,好像都是system v的...

突然想熟悉下 posix ipc, 直接就用消息队列来学习下了.
代码如下,边写边加信息,比较烂..


send.c
创建消息队列,向里面添加数据.
recv.c
读数据.

问题主要是两个..
1,

1. cc -Wall -g -I./ send.c -o send -lrt
   
2. /tmp/ccbJPjDr.o: In function `main':
   
3. /home/prog/test/c/ipc/send.c:23: warning: warning: mq_getattr is not implemented and will always fail
   
4. /home/prog/test/c/ipc/send.c:27: warning: warning: mq_setattr is not implemented and will always fail

复制代码

mq_open完全没报这个warning啊..
虽然也能运行,但这个warning看着真搁眼..并且不知道为啥报个这东西.

2, 执行起来行为好奇怪..
这个send,应该直接一下就跑完了吧(想象中),实际不是,经常在i=10的时候就阻塞掉了,有一两次在i=0的时候就阻塞了(应该是mq_send阻塞,根据printf打印推断..).
只有启动recv后, send程序才能继续send..
不明白为啥看起来会阻塞..


send.c

1. #include  "inc.h"
   
2. 
   
3. int main(void)
   
4. {
   
5.         mqd_t mq_id,mq_check;
   
6.         int i;
   
7.         char c;
   
8.         struct mq_attr attr;
   
9.         struct mq_attr nattr;
   
10. 
    
11. 
    
12.         setvbuf(stdout, NULL, _IONBF, 0);
    
13. 
    
14.         printf("begin...\n");
    
15.         mq_id = mq_open(MQ_NAME, O_RDWR|O_CREAT, S_IRWXU, NULL);
    
16.         if(mq_id == (mqd_t) -1) {
    
17.                 printf("mq_open err[%d], %s\n",
    
18.                         errno, strerror(errno));
    
19.                 return -1;
    
20.         }
    
21.         mq_getattr(mq_id, &attr);
    
22.         memcpy(&nattr, &attr, sizeof(struct mq_attr));
    
23.         nattr.mq_maxmsg = 100;
    
24.         nattr.mq_msgsize = 100;
    
25.         mq_setattr(mq_id, &nattr, &attr);
    
26. 
    
27.         for(i=0; i<=NUM; i++)  {
    
28.                 c = (char)i+'0';
    
29.                 if(i>=10)
    
30.                         c='a';
    
31.                 printf("%2d ", i);
    
32.                 mq_check = mq_send(mq_id, (char *)&c, sizeof(c), i*10);
    
33.                 if(mq_check == (mqd_t) -1) {
    
34.                         printf("mq_send err[%d], %s\n",
    
35.                                         errno, strerror(errno));
    
36.                         return -1;
    
37.                 }
    
38.                 printf(".\n");
    
39.         }
    
40.         printf("end...\n");
    
41. 
    
42. 
    
43.         return 0;
    
44. }
    

复制代码

recv.c

1. #include  "inc.h"
   
2. 
   
3. int main(void)
   
4. {
   
5.         mqd_t mq_id,mq_check;
   
6.         int i,prio;
   
7.         void *buff;
   
8.         struct mq_attr attr;
   
9. 
   
10.         setvbuf(stdout, NULL, _IONBF, 0);
    
11.         mq_id = mq_open(MQ_NAME, O_RDONLY);
    
12.         if(mq_id == (mqd_t) -1) {
    
13.                 printf("mq_open err[%d], %s\n",
    
14.                         errno, strerror(errno));
    
15.                 return -1;
    
16.         }
    
17.         mq_getattr(mq_id, &attr);
    
18.         buff = malloc(attr.mq_msgsize);
    
19. 
    
20.         for(i=0; i<=NUM; i++)  {
    
21.                 mq_check = mq_receive(mq_id, buff, attr.mq_msgsize, (unsigned *)&prio);
    
22.                 if(mq_check ==  -1) {
    
23.                         printf("mq_receive err[%d], %s\n",
    
24.                                 errno, strerror(errno));
    
25.                         return -1;
    
26.                 }
    
27.                 printf("[%s][%d] : %d %d %c\n",__FILE__,__LINE__, prio, mq_check, ((int *)buff)[0]);
    
28.                 sleep(1);
    
29.         }
    
30.         printf("\n");
    
31. 
    
32. 
    
33.         return 0;
    
34. }
    

复制代码

inc.h

1. #include <stdio.h>
   
2. #include <stdlib.h>
   
3. #include <string.h>
   
4. #include <errno.h>
   
5. 
   
6. 
   
7. #include <mqueue.h>
   
8. 
   
9. 
   
10. #include <sys/types.h>
    
11. #include <unistd.h>
    
12. 
    
13. #define MQ_NAME "/abctest"
    
14. #define PRIO_A 1
    
15. #define NUM 20
    

复制代码