Linux进程间通信-消息队列 原创 Linux平台 2022年2月16日 20:34 夏至未至 1399 当前内容 6400 字，在路上，马上到，马上到 ### 目录 [TOC] ### 何为消息队列 #### 定义 消息队列是消息的链接表 ,存放在内核中并由消息队列标识符标识，它是systemV风格中一种进程间通信的方式，提供了一种从一个进程向另一个进程发送一个数据块的方法。 #### 原理 其在Linux下是以双向链表的形式实现，可以把消息看作一个记录，具有特定的格式以及特定的优先级。对消息队列有写权限的进程可以向其中按照一定的规则添加新消息；对消息队列有读权限的进程则可以从消息队列中读走消息 #### 与管道异同 消息队列与管道不同的是，消息队列是基于消息的， 而管道是基于字节流的，且消息队列的读取不一定是先入先出。消息队列与命名管道有一样的不足，就是每个消息的最大长度是有上限的（MSGMAX），每个消息队列的总的字节数是有上限的（MSGMNB），系统上消息队列的总数也有一个上限（MSGMNI） [root@localhost /]# [root@localhost /]# cat /proc/sys/kernel/msgmax 65535 [root@localhost /]# cat /proc/sys/kernel/msgmnb 65535 [root@localhost /]# cat /proc/sys/kernel/msgmin 1735 [root@localhost /]# ### ipc对象数据结构 struct ipc_perm { key_t __key; /* Key supplied to xxxget(2) */ uid_t uid; /* Effective UID of owner */ gid_t gid; /* Effective GID of owner */ uid_t cuid; /* Effective UID of creator */ gid_t cgid; /* Effective GID of creator */ unsigned short mode; /* Permissions */ unsigned short __seq;/* Sequence number */ }; 消息队列，共享内存和信号量都有这样一个共同的数据结构。 ### 消息队列结构  可以看到第一个条目就是IPC结构体，即是共有的，后面的都是消息队列所私有的成员，消息队列是用链表实现的。 ### 消息队列实现 #### msgget 函数 该函数用来创建和访问一个消息队列。它的原型为： int msgget(key_t, key, int msgflg); 与其他的IPC机制一样，程序必须提供一个键来命名某个特定的消息队列。 ##### 入参 1.msgflg是一个权限标志，表示消息队列的访问权限，它与文件的访问权限一样。 2.msgflg可以与IPC_CREAT做或操作，表示当key所命名的消息队列不存在时创建一个消息队列，如果key所命名的消息队列存在时，IPC_CREAT标志会被忽略，而只返回一个标识符。 ##### 返回 它返回一个以key命名的消息队列的标识符（非零整数），失败时返回-1. #### msgsnd 函数 该函数用来把消息添加到消息队列中。它的原型为： int msgsnd(int msgid, const void *msg_ptr, size_t msg_sz, int msgflg); ##### 入参 1.msgid是由msgget函数返回的消息队列标识符。 2.msg_ptr是一个指向准备发送消息的指针，但是消息的数据结构却有一定的要求，指针msg_ptr所指向的消息结构一定要是以一个长整型成员变量开始的结构体； // 接收函数将用这个成员来确定消息的类型。所以消息结构要定义成这样： struct my_message{ long int message_type; /* The data you wish to transfer*/ }; 3.msg_sz 是 msg_ptr 指向的消息的长度，注意是消息的长度，而不是整个结构体的长度，也就是说msg_sz是不包括长整型消息类型成员变量的长度。 4.msgflg 用于控制当前消息队列满或队列消息到达系统范围的限制时将要发生的事情。 ##### 返回 如果调用成功，消息数据的一分副本将被放到消息队列中，并返回0，失败时返回-1. #### msgrcv函数 该函数用来从一个消息队列获取消息，它的原型为： int msgrcv(int msgid, void *msg_ptr, size_t msg_st, long int msgtype, int msgflg); ##### 入参 1.command是将要采取的动作，它可以取3个值， - IPC_STAT：把msgid_ds结构中的数据设置为消息队列的当前关联值，即用消息队列的当前关联值覆盖msgid_ds的值。 - IPC_SET：如果进程有足够的权限，就把消息列队的当前关联值设置为msgid_ds结构中给出的值 - IPC_RMID：删除消息队列 2.buf是指向msgid_ds结构的指针，它指向消息队列模式和访问权限的结构。msgid_ds结构至少包括以下成员： struct msgid_ds { uid_t shm_perm.uid; uid_t shm_perm.gid; mode_t shm_perm.mode; }; ##### 返回 成功时返回 0，失败时返回 -1. ### 代码上机实操 用消息队列实现进程间通信, 主要是两个.C文件，两个main函数即两个进程，一个服务端进程发送，一个客户端进程接受，模拟实现连个进程间的通信 #### 公共实现 comm.h #pragma once #include<stdio.h> #include<sys/types.h> #include<sys/ipc.h> #include<sys/msg.h> #include<string.h> #include<errno.h> #define _PROJ_NAME_ "/lining" #define _PROJ_ID_ 0x6666 #define _SIZE_ 1024 #define _SERVER_TYPE_ 1 #define _CLIENT_TYPE_ 2 //自定义结构体 struct msgbuf { long mtype; //消息类型 必须>0 char mtext; //信息内容 }; //函数申明 //创建消息队列 int create_msg_queue(); //取得消息队列 int get_msg_queue(); //销毁消息队列 int destroy_msg_queue(int msg_id); //接受 int recv_msg(int msg_id,int t,char* out); //发送 int send_msg(int msg_id,int t,const char* msg); comm.c #include"comm.h" static int com_msg_queue(int flags) { key_t _key = ftok(_PROJ_NAME_,_PROJ_ID_); if(_key < 0) { perror("ftok"); return -1; } int msg_id = msgget(_key,flags); // if(msg_id < 0) { perror("msgget"); } return msg_id; } int create_msg_queue() { int flags = IPC_CREAT | IPC_EXCL | 0644; return com_msg_queue(flags); } int get_msg_queue() { int flags = IPC_CREAT; return com_msg_queue(flags); } int destroy_msg_queue(int msg_id) { if(msgctl(msg_id,IPC_RMID,NULL) < 0) { perror("msgctl"); return -1; } return 0; } int send_msg(int msg_id,int t,const char* msg) { struct msgbuf _msg; _msg.mtype = t; strncpy(_msg.mtext,msg,strlen(msg)+1); if(msgsnd(msg_id,&_msg,sizeof(_msg.mtext),0) < 0) { perror("msgsnd"); return -1; } return 0; } int recv_msg(int msg_id,int t,char* out) { struct msgbuf _msg; _msg.mtype = t; memset(_msg.mtext,'\0',sizeof(_msg.mtext)); if(msgrcv(msg_id,&_msg,sizeof(_msg.mtext),t,0) < 0) { perror("msgrcv"); return -1; } else { strcpy(out,_msg.mtext); } return 0; } #### 服务端 server.c #include"comm.h" int main() { int msg_id = get_msg_queue(); char buf[_SIZE_]; while(1) { printf("请输入：\n"); fflush(stdout); read(0,buf,sizeof(buf)-1); send_msg(msg_id,_CLIENT_TYPE_,buf); memset(buf,'\0',sizeof(buf)); recv_msg(msg_id,_SERVER_TYPE_,buf); printf("sever -> client:%s\n",buf); } return 0; } #### 客户端 client.c #include"comm.h" int main() { int msg_id = create_msg_queue(); char buf[_SIZE_]; while(1) { memset(buf,'\0',sizeof(buf)); sleep(20); recv_msg(msg_id,_CLIENT_TYPE_,buf); printf("client -> server:%s\n",buf); printf("请输入："); fflush(stdout); read(0,buf,sizeof(buf)-1); send_msg(msg_id,_SERVER_TYPE_,buf); } destroy_msg_queue(msg_id); return 0; } ### 消息队列与命名管道的比较 #### 异同 消息队列跟命名管道有不少的相同之处，与命名管道一样，消息队列进行通信的进程可以是不相关的进程，同时它们都是通过发送和接收的方式来传递数据的。 在命名管道中，发送数据用write，接收数据用read，则在消息队列中，发送数据用msgsnd，接收数据用msgrcv。而且它们对每个数据都有一个最大长度的限制。 #### 优势 与命名管道相比，消息队列的优势在于： 1. 消息队列也可以独立于发送和接收进程而存在，从而消除了在同步命名管道的打开和关闭时可能产生的困难。 2. 同时通过发送消息还可以避免命名管道的同步和阻塞问题，不需要由进程自己来提供同步方法。 3. 接收程序可以通过消息类型有选择地接收数据，而不是像命名管道中那样，只能默认地接收。 本文标题： Linux进程间通信-消息队列 本文作者： 夏至未至 发布时间： 2022年2月16日 20:34 最近更新： 2022年2月18日 10:25 原文链接： 许可协议： 署名-非商业性-禁止演绎 4.0 国际(CC BY-NC-ND 4.0) 请按协议转载并保留原文链接及作者 进程间通信(8) 消息队列(1) 上一个 Linux下进程间通信-共享内存 下一个 谷歌浏览器离线安装标签自动刷新插件安装 当前文章评论暂未开放,请移步至留言处留言。
