Chinaunix首页 | 论坛 | 博客

oops

首页　| 　博文目录　| 　关于我

王贤才

  • 博客访问： 1177013
  • 博文数量： 573
  • 博客积分： 0
  • 博客等级： 民兵
  • 技术积分： 66
  • 用 户 组： 普通用户
  • 注册时间： 2016-06-28 16:21
文章分类

全部博文（573）

文章存档

2018年（3）

2016年（48）

2015年（522）

我的朋友
最近访客
推荐博文
相关博文
消息队列

分类： LINUX

2015-12-02 15:19:35

queue.c文件

点击(此处)折叠或打开

  1. #include <stdio.h>
  2. #include <stdlib.h>
  3. #include <string.h>
  4. #include <sys/msg.h>
  5. #include <sys/ipc.h>

  7. #define IPCKEY 0x12

  9. /*消息数据类型可以自己定义：
  10. 注意：
  11. 1，必须包含：正的整形消息类型+其后紧跟着的消息数据
  12. 2，该结构的成员可以有多个，不是只能有2个
  13. 3，msgsnd函数的第3个长度值：一定是除了long之外，剩下的长度都是我们的消息的长度，以字节为单位换个说法：是long之外，结构体其他成员的总长，不是其他成员实际数据的长度。*/
  14. typedef struct mymesg
  15. {
  16.         long mtype;
  17.         char name[128];
  18.         char value[128];
  19. }MYMESG;

  21. int main(int argc, char * * argv)
  22. {
  23.         int ret;
  24.         struct msqid_ds msg_info;
  25.         /*消息队列标示符属性结构体:每个队列都有一个 struct msqid_ds 与其相关联*/

  27.         char path[1024];
  28.         memset(path, 0, sizeof(path));
  29.         strcpy(path, "/etc/hosts");
  30.         printf("path=[%s]\n", path);

  32.         key_t key = 0;
  33.         printf("key=[%x]\n", key);
  34.         /*path必须是已经存在的文件名，将path文件的索引节点号取出，
  35.         前面加上子序号IPCKEY，得到key_t的返回值。
  36.         功能：可以保证两个不同用户下的两组相同程序获得互不干扰的IPC键值
  37.         */
  38.         key = ftok(path, IPCKEY);
  39.         if(key < 0)
  40.         {
  41.                 printf("ftok err!\n");
  42.                 exit(-1);
  43.         }
  44.         printf("key=[%x]\n", key);

  46.         int msgid;
  47.         /*功能：创建 或者 获取一个消息队列ID，返回值就是消息队列标示符，同一进程内部就靠这个ID来识别。
  48.         IPC_CREAT : 队列不存在，则创建，队列存在，则打开。
  49.         IPC_CREAT|IPC_EXCL : 队列不存在，则创建，队列存在，则报错
  50.         单独使用IPC_EXCL，没什么意义*/
  51.         msgid = msgget(key, IPC_CREAT|0666);
  52.         if(msgid < 0)
  53.         {
  54.                 printf("msgget err!\n");
  55.                 exit(-1);
  56.         }
  57.         MYMESG mymesg1;
  58.         mymesg1.mtype = 1;
  59.         memset(mymesg1.name, 0, sizeof(mymesg1.name));
  60.         strcpy(mymesg1.name, "zhuren");
  61.         memset(mymesg1.value, 0, sizeof(mymesg1.value));
  62.         strcpy(mymesg1.value, "wangxiancai");
  63.         
  64.         /*msgsnd功能：向消息队列发送消息，发送的消息总在队列的尾端。
  65.                         当msgsnd成功返回，内核将与消息队列相关的 struct msqid_ds结构得到更新。
  66.         第3个参数：消息数据的长度:是long之外，结构体其他成员的总长。
  67.         第4个参数：0：若队列已满，则调用msgsnd的进程将会挂起阻塞，直到消息可以写入到队列中。
  68.                             IPC_NOWAIT：若队列已满，那么此消息则不会写到消息队列中，将出错返回。
  69.         */
  70.         ret = msgsnd(msgid, &mymesg1, sizeof(struct mymesg)-sizeof(long), 0);
  71.         if(ret < 0)
  72.         {
  73.                 printf("msgsnd err!\n");
  74.                 exit(-1);
  75.         }
  76.         sleep(2);
  77.         
  78.         /*msgctl函数*/
  79.         ret = msgctl(msgid, IPC_STAT, &msg_info);
  80.         if(ret < 0)
  81.         {
  82.                 printf("msgctl err!\n");
  83.                 exit(-1);
  84.         }
  85.         printf("向消息队列中加入了1条消息之后的属性：\n");
  86.         printf("the message number is:队列中消息的个数:[%d]\n",msg_info.msg_qnum);
  87.         printf("the crow max number is:系统限制队列的最大数:[%d]\n",msg_info.msg_qbytes);
  88.         printf("the last message's pid is:最后向消息队列中发送数据的进程号:[%d]\n",msg_info.msg_lspid);
  89.         printf("the last receve meassage's pid is:最后从消息队列中取得数据的进程号:[%d]\n",msg_info.msg_lrpid);
  90.         printf("the last send time is:最后向消息队列中发送数据的时间:[%s]\n",ctime(&(msg_info.msg_stime)));
  91.         printf("the last receve time is:最后从消息队列中取得数据的时间:[%s]\n",ctime(&(msg_info.msg_rtime)));
  92.         printf("the last changed time is:消息队列最后发生数据变化的时间:[%s]\n",ctime(&(msg_info.msg_ctime)));
  93.         printf("the message UID is 用户ID: [%d]\n",msg_info.msg_perm.uid);
  94.         printf("the message GID is 组ID: [%d]\n",msg_info.msg_perm.gid);
  95.         
  96.         mymesg1.mtype = 2;
  97.         memset(mymesg1.name, 0, sizeof(mymesg1.name));
  98.         strcpy(mymesg1.name, "puren");
  99.         memset(mymesg1.value, 0, sizeof(mymesg1.value));
  100.         strcpy(mymesg1.value, "zhangqiuping");
  101.         ret = msgsnd(msgid, &mymesg1, sizeof(struct mymesg)-sizeof(long), 0);
  102.         if(ret < 0)
  103.         {
  104.                 printf("msgsnd err!\n");
  105.                 exit(-1);
  106.         }
  107.         sleep(3);
  108.         
  109.         /*msgctl函数
  110.         IPC_STAT:取得此队列的struct msqid_ds结构，存放在msg_info中
  111.         IPC_SET:按照msg_info 结构中的值，设置此队列的 struct msqid_ds结构
  112.         IPC_RMID:从系统中删除消息队列，及仍然留在该队列中的所有的数据，这种删除是立即生效的    */
  113.         ret = msgctl(msgid, IPC_STAT, &msg_info);
  114.         if(ret < 0)
  115.         {
  116.                 printf("msgctl err!\n");
  117.                 exit(-1);
  118.         }
  119.         printf("向消息队列中加入了第2条消息之后的属性：\n");
  120.         printf("the message number is:队列中消息的个数:[%d]\n",msg_info.msg_qnum);
  121.         printf("the crow max number is:系统限制队列的最大数:[%d]\n",msg_info.msg_qbytes);
  122.         printf("the last message's pid is:最后向消息队列中发送数据的进程号:[%d]\n",msg_info.msg_lspid);
  123.         printf("the last receve meassage's pid is:最后从消息队列中取得数据的进程号:[%d]\n",msg_info.msg_lrpid);
  124.         printf("the last send time is:最后向消息队列中发送数据的时间:[%s]\n",ctime(&(msg_info.msg_stime)));
  125.         printf("the last receve time is:最后从消息队列中取得数据的时间:[%s]\n",ctime(&(msg_info.msg_rtime)));
  126.         printf("the last changed time is:消息队列最后发生数据变化的时间:[%s]\n",ctime(&(msg_info.msg_ctime)));
  127.         printf("the message UID is 用户ID: [%d]\n",msg_info.msg_perm.uid);
  128.         printf("the message GID is 组ID: [%d]\n",msg_info.msg_perm.gid);
  129.         
  130.         MYMESG mymesg2;
  131.         /*msgrcv功能：从消息队列获取消息。每成功获取一条消息，消息队列中的消息就会少一条。
  132.                                     当msgsnd成功返回，内核将与消息队列相关的 struct msqid_ds结构得到更新。
  133.         第3个参数：消息数据的长度:是long之外，结构体其他成员的总长。
  134.         第4个参数：与自定义消息数据类型的，第一个成员的值相对应。
  135.         第5个参数：0：若队列没有指定的消息，则调用msgrcv的进程将会挂起阻塞，直到队列中有指定的消息，或者队列被删除了，msgrcv出错返回
  136.                             IPC_NOWAIT：若队列没有指定的消息，则调用msgrcv的进程将出错返回。
  137.                             MSG_NOERROR:若设置了这个标志，若实际返回的消息大于第3个参数，则该消息被截短，消息已经不再队列中了。
  138.                                                     若未设置这个标志，实际返回的消息又大于第3个参数，则出错返回，消息任留在队列中。
  139.         */
  140.         ret = msgrcv(msgid, &mymesg2, sizeof(struct mymesg)-sizeof(long), 1, 0);
  141.         printf("ret=[%d]\n", ret);
  142.         if(ret < 0)
  143.         {
  144.                 printf("msgrcv err!\n");
  145.                 exit(-1);
  146.         }
  147.         printf("从消息队列中取得一条数据如下：\n");
  148.         printf("mymesg2.mtype=[%d]\n", mymesg2.mtype);
  149.         printf("mymesg2.name=[%s]\n", mymesg2.name);
  150.         printf("mymesg2.value=[%s]\n", mymesg2.value);
  151.         
  152.                 /*msgctl函数
  153.         IPC_STAT:取得此队列的struct msqid_ds结构，存放在msg_info中
  154.         IPC_SET:按照msg_info 结构中的值，设置此队列的 struct msqid_ds结构
  155.         IPC_RMID:从系统中删除消息队列，及仍然留在该队列中的所有的数据，这种删除是立即生效的    */
  156.         ret = msgctl(msgid, IPC_STAT, &msg_info);
  157.         if(ret < 0)
  158.         {
  159.                 printf("msgctl err!\n");
  160.                 exit(-1);
  161.         }
  162.         printf("从消息队列中取走了1条消息之后的属性：\n");
  163.         printf("the message number is:队列中消息的个数:[%d]\n",msg_info.msg_qnum);
  164.         printf("the crow max number is:系统限制队列的最大数:[%d]\n",msg_info.msg_qbytes);
  165.         printf("the last message's pid is:最后向消息队列中发送数据的进程号:[%d]\n",msg_info.msg_lspid);
  166.         printf("the last receve meassage's pid is:最后从消息队列中取得数据的进程号:[%d]\n",msg_info.msg_lrpid);
  167.         printf("the last send time is:最后向消息队列中发送数据的时间:[%s]\n",ctime(&(msg_info.msg_stime)));
  168.         printf("the last receve time is:最后从消息队列中取得数据的时间:[%s]\n",ctime(&(msg_info.msg_rtime)));
  169.         printf("the last changed time is:消息队列最后发生数据变化的时间:[%s]\n",ctime(&(msg_info.msg_ctime)));
  170.         printf("the message UID is 用户ID: [%d]\n",msg_info.msg_perm.uid);
  171.         printf("the message GID is 组ID: [%d]\n",msg_info.msg_perm.gid);
  172.         
  173.         while(1);
  174.     
  175.         return 0;
  176.         
  177. }
queue2.c文件

点击(此处)折叠或打开

  1. #include <stdio.h>
  2. #include <stdlib.h>
  3. #include <string.h>
  4. #include <sys/msg.h>
  5. #include <sys/ipc.h>

  7. #define IPCKEY 0x12

  9. /*消息数据类型可以自己定义：
  10. 注意：
  11. 1，必须包含：正的整形消息类型+其后紧跟着的消息数据
  12. 2，该结构的成员可以有多个，不是只能有2个
  13. 3，msgsnd函数的第3个长度值：一定是除了long之外，剩下的长度都是我们的消息的长度，以字节为单位换个说法：是long之外，结构体其他成员的总长，不是其他成员实际数据的长度。*/
  14. typedef struct mymesg
  15. {
  16.         long mtype;
  17.         char name[128];
  18.         char value[128];
  19. }MYMESG;

  21. int main(int argc, char * * argv)
  22. {
  23.         int ret;
  24.         struct msqid_ds msg_info;
  25.     
  26.         char path[1024];
  27.         memset(path, 0, sizeof(path));
  28.         strcpy(path, "/etc/hosts");
  29.         printf("path=[%s]\n", path);
  30.         
  31.         key_t key = 0;
  32.         printf("key=[%x]\n", key);
  33.         /*path必须是已经存在的文件名，将path文件的索引节点号取出，
  34.         前面加上子序号IPCKEY，得到key_t的返回值。
  35.         可以保证两个不同用户下的两组相同程序获得互不干扰的IPC键值
  36.         */
  37.         key = ftok(path, IPCKEY);
  38.         if(key < 0)
  39.         {
  40.                 printf("ftok err!\n");
  41.                 exit(-1);
  42.         }
  43.         printf("key=[%x]\n", key);
  44.         
  45.         int msgid;
  46.         /*创建 或者 获取一个消息队列ID，返回值就是消息队列标示符。
  47.         IPC_CREAT : 队列不存在，则创建，队列存在，则打开。
  48.         IPC_CREAT|IPC_EXCL : 队列不存在，则创建，队列存在，则报错*/
  49.         msgid = msgget(key, IPC_CREAT|0666);
  50.         if(msgid < 0)
  51.         {
  52.                 printf("msgget err!\n");
  53.                 exit(-1);
  54.         }
  55.         
  56.         MYMESG mymesg2;
  57.         /*msgrcv功能：从消息队列获取消息。每成功获取一条消息，消息队列中的消息就会少一条。
  58.                                     当msgsnd成功返回，内核将与消息队列相关的 struct msqid_ds结构得到更新。
  59.         第3个参数：消息数据的长度:是long之外，结构体其他成员的总长。
  60.         第4个参数：与自定义消息数据类型的，第一个成员的值相对应。
  61.         第5个参数：0：若队列没有指定的消息，则调用msgrcv的进程将会挂起阻塞，直到队列中有指定的消息，或者队列被删除了，msgrcv出错返回
  62.                             IPC_NOWAIT：若队列没有指定的消息，则调用msgrcv的进程将出错返回。
  63.                             MSG_NOERROR:若设置了这个标志，若实际返回的消息大于第3个参数，则该消息被截短，消息已经不再队列中了。
  64.                                                     若未设置这个标志，实际返回的消息又大于第3个参数，则出错返回，消息任留在队列中。
  65.         */
  66.         ret = msgrcv(msgid, &mymesg2, sizeof(struct mymesg)-sizeof(long), 1, 0);
  67.         printf("ret=[%d]\n", ret);
  68.         if(ret < 0)
  69.         {
  70.                 printf("msgrcv err!\n");
  71.                 exit(-1);
  72.         }
  73.         printf("从消息队列中取得一条数据如下：\n");
  74.         printf("mymesg2.mtype=[%d]\n", mymesg2.mtype);
  75.         printf("mymesg2.name=[%s]\n", mymesg2.name);
  76.         printf("mymesg2.value=[%s]\n", mymesg2.value);
  77.         
  78.         /*msgctl函数
  79.         IPC_STAT:取得此队列的struct msqid_ds结构，存放在msg_info中
  80.         IPC_SET:按照msg_info 结构中的值，设置此队列的 struct msqid_ds结构
  81.         IPC_RMID:从系统中删除消息队列，及仍然留在该队列中的所有的数据，这种删除是立即生效的
  82.         */
  83.         ret = msgctl(msgid, IPC_STAT, &msg_info);
  84.         if(ret < 0)
  85.         {
  86.                 printf("msgctl err!\n");
  87.                 exit(-1);
  88.         }
  89.         printf("从消息队列中取走了1条消息之后的属性：\n");
  90.         printf("the message number is:队列中消息的个数:[%d]\n",msg_info.msg_qnum);
  91.         printf("the crow max number is:系统限制队列的最大数:[%d]\n",msg_info.msg_qbytes);
  92.         printf("the last message's pid is:最后向消息队列中发送数据的进程号:[%d]\n",msg_info.msg_lspid);
  93.         printf("the last receve meassage's pid is:最后从消息队列中取得数据的进程号:[%d]\n",msg_info.msg_lrpid);
  94.         printf("the last send time is:最后向消息队列中发送数据的时间:[%s]\n",ctime(&(msg_info.msg_stime)));
  95.         printf("the last receve time is:最后从消息队列中取得数据的时间:[%s]\n",ctime(&(msg_info.msg_rtime)));
  96.         printf("the last changed time is:消息队列最后发生数据变化的时间:[%s]\n",ctime(&(msg_info.msg_ctime)));
  97.         printf("the message UID is 用户ID: [%d]\n",msg_info.msg_perm.uid);
  98.         printf("the message GID is 组ID: [%d]\n",msg_info.msg_perm.gid);
  99.         
  100.         while(1);
  101.     
  102.         return 0;
  103. }

阅读(547) | 评论(0) | 转发(0) |
0

上一篇：popen用法

下一篇：信号量集合

给主人留下些什么吧！~~
关于我们 | 关于IT168 | 联系方式 | 广告合作 | 法律声明 | 免费注册

Copyright 2001-2010 ChinaUnix.net All Rights Reserved 北京皓辰网域网络信息技术有限公司. 版权所有

感谢所有关心和支持过ChinaUnix的朋友们

16024965号-6