unix XSI IPC-消息队列例程

unix XSI IPC-消息队列例程

注意事项：

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

#include "msg.h" #include  #include  #include   int main(int argc, char** argv) {       int queid = open_msg("/root",100);              while(1)       {             fputs("请输入要发送的类型：1 or 2\n", stdout);             int type;             scanf("%d",&type);                          switch(type)             {                   case MYTYPE_ONE:                        {                               msg_send(queid,"MYTYPE_ONE", MYTYPE_ONE);                               break;                        }                   case MYTYPE_TWO:                        {                               msg_send(queid,"MYTYPE_TWO", MYTYPE_TWO);                               break;                        }                   default:                         {                               fputs("输入类型错误，请重新输入\n",stdout);                               break;                         }                                            }                          fputs("输入：q 为退出，其它表示继续\n",stdout);             if(getchar() == 'q')             {                   fputs("退出成功！\n",stdout);                   break;             }             else             {                   fputs("继续发送消息\n",stdout);             }            } //不发送退出需要奖队列移除             del_que(queid);              return 0; }

client.c

#include "msg.h" #include  #include  #include   int main(int argc, char** argv) {       int queid = open_msg("/root",100);              while(1)       {             fputs("请接收要发送的类型：1 or 2\n", stdout);             int type;             scanf("%d",&type);                          switch(type)             {                   case MYTYPE_ONE:                        {                               msg_rec(queid,MYTYPE_ONE);                               break;                        }                   case MYTYPE_TWO:                        {                               msg_rec(queid,MYTYPE_TWO);                               break;                        }                   default:                         {                               fputs("输入类型错误，请重新输入\n",stdout);                               break;                         }                                            }                          fputs("输入：q 为退出，其它表示继续\n",stdout);             if(getchar() == 'q')             {                   fputs("退出成功！\n",stdout);                   break;             }             else             {                   fputs("继续发送消息\n",stdout);             }            } //队列移除             del_que(queid);              return 0; }

msg.c

#include  #include  #include  #include  #include  #include  #include #include"msg.h"   //如果存在队列则打开，没有则创建 int open_msg(char* path, int id) {       //获取IPC对象的一个键       key_t key = ftok(path, id);       if(-1 == key)       {             perror("ftok\n");             exit(1);       }       //创建一个队列       int queid = msgget(key, IPC_CREAT|0666);       if(-1 == queid)       {             perror("msgget\n");             exit(1);       }        return queid; }  //发送消息到队列 void msg_send(key_t key,char* text, long msgtype) {       //初始化内容       struct MSG tmp;       memset(&tmp,sizeof(struct MSG),0);       tmp.mytype = msgtype;       strcpy(tmp.mytext,text);        //发送消息       if(msgsnd(key, &tmp, TEXTSIZE, 0))       {             perror("msgsnd\n");             exit(1);       } }  //从消息队列获取消息并显示 void msg_rec(key_t key,long msgtype) {       struct MSG tmp;       if(-1 == msgrcv(key, &tmp, TEXTSIZE, msgtype, MSG_NOERROR))       {             perror("msgrcv\n");             exit(1);       }       printf("receive content: %s\n",tmp.mytext); }  //删除队列，即使队列里面还有消息也一起删除 void del_que(key_t key) {       if(msgctl(key,IPC_RMID,NULL))       {             perror("msgsnd\n");             exit(1);             } }

msg.h

#ifndef MSG_H #define MSG_H  #include   #define TEXTSIZE 100 #define ARRYSIZE 2 #define MYTYPE_ONE 1 #define MYTYPE_TWO 2  struct MSG {       long mytype;       char mytext[TEXTSIZE]; };  int open_msg(char*,int); void msg_send(key_t,char*,long);   #endif // end MSG_H

版权声明：本文内容由网络用户投稿，版权归原作者所有，本站不拥有其著作权，亦不承担相应法律责任。如果您发现本站中有涉嫌抄袭或描述失实的内容，请联系我们jiasou666@gmail.com 处理，核实后本网站将在24小时内删除侵权内容。