宜宾网站建设公司

unixXSIIPC-消息队列例程-创新互联

注意事项：

成都创新互联是专业的祥云网站建设公司，祥云接单;提供成都网站建设、网站设计,网页设计,网站设计,建网站,PHP网站建设等专业做网站服务;采用PHP框架,可快速的进行祥云网站开发网页制作和功能扩展;专业做搜索引擎喜爱的网站,专业的做网站团队,希望更多企业前来合作!

linux（2.4.22）限制：

  • 可发送最长消息字节数为8192
  • 队列大容量字节数 16384
  • 队列大队列容量数 16

key_t ftok(char* path,int id)使用说明：

  • ftok创建一个键，是内核中的队列在外部的ID号，由于消息队列处于内核中，只有创建者和内核知道队列在内核里面的ID号，这样其它的进程就无法知道内核里面队列ID号，所以要关联一个外部键进行关联
  • id （1-255）
  • 返回内核消息队列的ID号

其它的注意就查看一下unix高级环境编程吧，或者有些问题需要讨论就回我吧！！

 server.c

  1. #include "msg.h"
  2. #include 
  3. #include 
  4. #include 
  6. int main(int argc, char** argv)
  7. {
  8.       int queid = open_msg("/root",100);
  10.       while(1)
  11.       {
  12.             fputs("请输入要发送的类型：1 or 2\n", stdout);
  13.             int type;
  14.             scanf("%d",&type);
  16.             switch(type)
  17.             {
  18.                   case MYTYPE_ONE:
  19.                        {
  20.                               msg_send(queid,"MYTYPE_ONE", MYTYPE_ONE);
  21.                               break;
  22.                        }
  23.                   case MYTYPE_TWO:
  24.                        {
  25.                               msg_send(queid,"MYTYPE_TWO", MYTYPE_TWO);
  26.                               break;
  27.                        }
  28.                   default:
  29.                         {
  30.                               fputs("输入类型错误，请重新输入\n",stdout);
  31.                               break;
  32.                         }
  34.             }
  36.             fputs("输入：q 为退出，其它表示继续\n",stdout);
  37.             if(getchar() == 'q')
  38.             {
  39.                   fputs("退出成功！\n",stdout);
  40.                   break;
  41.             }
  42.             else
  43.             {
  44.                   fputs("继续发送消息\n",stdout);
  45.             }
  46.       }
  47. //不发送退出需要奖队列移除
  48.       del_que(queid);
  50.       return 0;
  51. }

client.c

  1. #include "msg.h"
  2. #include 
  3. #include 
  4. #include 
  6. int main(int argc, char** argv)
  7. {
  8.       int queid = open_msg("/root",100);
  10.       while(1)
  11.       {
  12.             fputs("请接收要发送的类型：1 or 2\n", stdout);
  13.             int type;
  14.             scanf("%d",&type);
  16.             switch(type)
  17.             {
  18.                   case MYTYPE_ONE:
  19.                        {
  20.                               msg_rec(queid,MYTYPE_ONE);
  21.                               break;
  22.                        }
  23.                   case MYTYPE_TWO:
  24.                        {
  25.                               msg_rec(queid,MYTYPE_TWO);
  26.                               break;
  27.                        }
  28.                   default:
  29.                         {
  30.                               fputs("输入类型错误，请重新输入\n",stdout);
  31.                               break;
  32.                         }
  34.             }
  36.             fputs("输入：q 为退出，其它表示继续\n",stdout);
  37.             if(getchar() == 'q')
  38.             {
  39.                   fputs("退出成功！\n",stdout);
  40.                   break;
  41.             }
  42.             else
  43.             {
  44.                   fputs("继续发送消息\n",stdout);
  45.             }
  46.       }
  47. //队列移除
  48.       del_que(queid);
  50.       return 0;
  51. }

msg.c

  1. #include 
  2. #include 
  3. #include 
  4. #include 
  5. #include 
  6. #include 
  7. #include
  8. #include"msg.h"
  11. //如果存在队列则打开，没有则创建
  12. int open_msg(char* path, int id)
  13. {
  14.       //获取IPC对象的一个键
  15.       key_t key = ftok(path, id);
  16.       if(-1 == key)
  17.       {
  18.             perror("ftok\n");
  19.             exit(1);
  20.       }
  21.       //创建一个队列
  22.       int queid = msgget(key, IPC_CREAT|0666);
  23.       if(-1 == queid)
  24.       {
  25.             perror("msgget\n");
  26.             exit(1);
  27.       }
  28.       return queid;
  29. }
  31. //发送消息到队列
  32. void msg_send(key_t key,char* text, long msgtype)
  33. {
  34.       //初始化内容
  35.       struct MSG tmp;
  36.       memset(&tmp,sizeof(struct MSG),0);
  37.       tmp.mytype = msgtype;
  38.       strcpy(tmp.mytext,text);
  39.       //发送消息
  40.       if(msgsnd(key, &tmp, TEXTSIZE, 0))
  41.       {
  42.             perror("msgsnd\n");
  43.             exit(1);
  44.       }
  45. }
  47. //从消息队列获取消息并显示
  48. void msg_rec(key_t key,long msgtype)
  49. {
  50.       struct MSG tmp;
  51.       if(-1 == msgrcv(key, &tmp, TEXTSIZE, msgtype, MSG_NOERROR))
  52.       {
  53.             perror("msgrcv\n");
  54.             exit(1);
  55.       }
  56.       printf("receive content: %s\n",tmp.mytext);
  57. }
  59. //删除队列，即使队列里面还有消息也一起删除
  60. void del_que(key_t key)
  61. {
  62.       if(msgctl(key,IPC_RMID,NULL))
  63.       {
  64.             perror("msgsnd\n");
  65.             exit(1);
  66.       }
  67. }

msg.h

  1. #ifndef MSG_H
  2. #define MSG_H
  4. #include 
  6. #define TEXTSIZE 100
  7. #define ARRYSIZE 2
  8. #define MYTYPE_ONE 1
  9. #define MYTYPE_TWO 2
  11. struct MSG
  12. {
  13.       long mytype;
  14.       char mytext[TEXTSIZE];
  15. };
  17. int open_msg(char*,int);
  18. void msg_send(key_t,char*,long);
  21. #endif // end MSG_H

附件：http://down.51cto.com/data/2362206

另外有需要云服务器可以了解下创新互联cdcxhl.cn，海内外云服务器15元起步，三天无理由+7*72小时售后在线，公司持有idc许可证，提供“云服务器、裸金属服务器、高防服务器、香港服务器、美国服务器、虚拟主机、免备案服务器”等云主机租用服务以及企业上云的综合解决方案，具有“安全稳定、简单易用、服务可用性高、性价比高”等特点与优势，专为企业上云打造定制，能够满足用户丰富、多元化的应用场景需求。


分享题目：unixXSIIPC-消息队列例程-创新互联
本文路径：http://ybzwz.com/article/hpico.html

其他资讯