前面文章介绍了 Linux 下进程的创建，管理，陆续介绍了进程间通信的方式：管道、内存映射、共享内存等。这篇文章继续介绍 Linux 的进程间通信方式消息队列。
1. 消息队列介绍
消息队列通过名字字面意思理解就是队列排队-和平常超市买东西排队付款一样结构，消息队列与 FIFO 很相似，都是一个队列结构，都可以有多个进程往队列里面写信息，多个进程从队列中读取信息。但 FIFO 需要读、写的两端事先都打开，才能够开始信息传递工作。而消息队列可以事先往队列中写信息，需要时再打开读取信息。
注意事项:
消息队列属于顺序队列形式的结构，向队列里写的每一条消息，会追加到队列后面，读取一个就从队列里消除一个。
写函数不会阻塞，除非队列里存放的消息数量已经满了，才会导致写阻塞。
读函数，从队列里读取不到数据时，会阻塞。
查看当前系统所有的消息队列:
[root@wbyq 20181005]# ipcs -q
------ Message Queues --------键值 消息队列ID 使用的字节数量 队里现存的消息数量 key msqid owner perms used-bytes messages 0x000004d3 0 root 666 65532 192 0x00003044 32769 root 666 65424 564 0x0a120534 65538 root 0 2352 21 0x0a00000f 196611 root 0 65520 2730 0xffffffff 163844 root 0 0 0
复制代码
查看消息队列的详细信息：
[root@wbyq 20181005]# ipcs -l
------ Shared Memory Limits --------max number of segments = 4096max seg size (kbytes) = 4194303max total shared memory (kbytes) = 1073741824min seg size (bytes) = 1
------ Semaphore Limits --------max number of arrays = 128max semaphores per array = 250max semaphores system wide = 32000max ops per semop call = 32semaphore max value = 32767
------ Messages: Limits --------max queues system wide = 1736 【系统最多的消息队列数量（最多支持同时1736个消息队列）】max size of message (bytes) = 65536 【单个消息的最大字节数】default max size of queue (bytes) = 65536 【默认的单个队列的大小65536】
默认单个队列总字节大小为: 65535字节。消息队列的最大字节数量和消息的最大条数加起来的总字节数不能超过65535字节。
复制代码
**System V IPC 机制消息队列相关的函数接口: ** 这里先列出所有函数，下面会详细介绍每个函数的用法。
#include <sys / types.h>#include <sys / ipc.h>#include <sys / msg.h>int msgget(key_t key, int msgflg);int msgsnd(int msqid, struct msgbuf * msgp, size_t msgsz, int msgflg);ssize_t msgrcv(int msqid, struct msgbuf * msgp, size_t msgsz, long msgtyp, int msgflg);int msgctl(int msqid, int cmd, struct msqid_ds * buf);
复制代码
2. 消息队列相关函数介绍
2.1 msgget 函数
函数原型:
#include <sys/types.h>#include <sys/ipc.h>#include <sys/msg.h>int msgget(key_t key, int msgflg);
复制代码
功能 msgget 用于创建和访问一个消息队列。参数（1） key：是唯一标识一个消息队列的关键字，如果为 IPC_PRIVATE(值为 0，用创建一个只有创建者进程才可以访问的消息队列),表示创建一个只由调用进程使用的消息队列，非 0 值的 key(可以通过 ftok 函数获得)表示创建一个可以被多个进程共享的消息队列；（2） msgflg：指明队列的访问权限和创建标志，创建标志的可选值为 IPC_CREAT 和 IPC_EXC，如果单独指定 IPC_CREAT，msgget 要么返回新创建的消息队列 id，要么返回具有相同 key 值的消息队列 id；如果 IPC_EXCL 和 IPC_CREAT 同时指明，则要么创建新的消息队列，要么当队列存在时，调用失败并返回-1。
/*1. 创建消息队列*/int msgid = msgget((key_t)1235,0666 | IPC_CREAT);
复制代码
返回值成功执行时，返回消息队列标识值（0 也是成功的）。
失败返回-1，errno 被设为以下的某个值。
EACCES：指定的消息队列已存在，但调用进程没有权限访问它，而且不拥有CAP_IPC_OWNER权能EEXIST：key指定的消息队列已存在，而msgflg中同时指定IPC_CREAT和IPC_EXCL标志ENOENT：key指定的消息队列不存在同时msgflg中不指定IPC_CREAT标志ENOMEM：需要建立消息队列，但内存不足ENOSPC：需要建立消息队列，但已达到系统的最大消息队列容量
复制代码
2.2 msgsnd 和 msgrcy 函数
原型:
#include <sys/types.h>#include <sys/ipc.h>#include <sys/msg.h>int msgsnd(int msqid, const void *msgp, size_t msgsz, int msgflg);ssize_t msgrcv(int msqid, void *msgp, size_t msgsz, long msgtyp,int msgflg);
复制代码
功能
函数 msgsnd 和 msgrcy 用来将消息添加到消息队列中和从一个消息队列中获取信息。
参数
（1）msgid：指明消息队列的 ID; 通常是 msgget 函数成功的返回值。
（2）msgbuf：是消息结构体，它的长度必须小于系统规定的上限，必须以一个长整型成员变量开始，接收函数将用这个成员变量来确定消息的类型。必须重写这个结构体，其中第一个参数类型不能改，其他可以自定义。
如下：
struct msgbuf { long mtype; /* type of message */ char mtext[1]; /* message text */};
复制代码
字段 mtype 是用户自己指定的消息类型（通常是 1—5 中的任意一个数值），该结构体第 2 个成员仅仅是一种说明性的结构，实际上用户可以使用任何类型的数据，就是消息内容；
（3）msgsz 是消息体的大小，每个消息体最大不要超过 4K; 不含消息类型占用的 4 个字节,即 mtext 的长度
（4）msgtyp 有 3 种选项：
msgtyp == 0 接收队列中的第1个消息，不区分消息类型msgtyp > 0 接收对列中的第1个类型等于msgtyp的消息msgtyp < 0 接收其类型小于或等于msgtyp绝对值的第1个最低类型消息
复制代码
（5）msgflg 有 3 种选项:
0：当消息队列满时，msgsnd将会阻塞，直到消息能写进消息队列IPC_NOWAIT：当消息队列已满的时候，msgsnd函数不等待立即返回IPC_NOERROR：若发送的消息大于size字节，则把该消息截断，截断部分将被丢弃，且不通知发送进程。
复制代码
2.3 msgctl 函数
原型:
#include <sys/types.h>#include <sys/ipc.h>#include <sys/msg.h>int msgctl(int msqid, int cmd, struct msqid_ds *buf);
复制代码
功能
msgctl 是消息队列的控制函数，常用来删除消息队列。
参数
（1）msqid：由 msgget 返回的消息队列标识符。
（2）cmd：通常为 IPC_RMID 表示删除消息队列。
（3）参数 buf 通常为 NULL。
通过命令查看系统消息信息
（1）ipcs -q 命令查看系统的消息队列
（2）ipcs -m 查看系统的共享内存
（3）ipcs -s 查看系统的信号量集。
3. 案例代码: 消息队列示例 1
下面两个程序分别编译，依次运行，不分先后顺序，就可以看到效果了。
3.1 发送消息
#include <stdio.h>#include <string.h>#include <stdlib.h>#include <errno.h>#include <sys/types.h>#include <sys/ipc.h>#include <sys/msg.h>#include <sys/stat.h>#define BUFFER 255struct msgtype { //重新定义该结构体 long mtype; //第一个参数类型不变 char buf[BUFFER];};
int main(int argc,char **argv){ if(argc!=3) { printf("./app <消息> <消息类型-整数>\n"); return 0; } /*1. 创建消息队列*/ int msgid = msgget((key_t)1235,0666 | IPC_CREAT); /*2. 向消息队列发送消息*/ struct msgtype msg; memset(&msg,0,sizeof(struct msgtype)); msg.mtype = atoi(argv[2]); //给结构体的成员赋值 strncpy(msg.buf,argv[1],BUFFER); msgsnd(msgid,&msg,sizeof(struct msgtype),0); return 0;}
复制代码
3.2 读取消息
#include <stdio.h>#include <string.h>#include <stdlib.h>#include <errno.h>#include <unistd.h>#include <sys/types.h>#include <sys/ipc.h>#include <sys/stat.h>#include <sys/msg.h>#define BUFFER 255struct msgtype { long mtype; char buf[BUFFER];};
int main(int argc,char **argv){ if(argc!=2) { printf("./app <消息类型-整数>\n"); return 0; } /*1. 创建消息队列-如果存在就打开消息队列*/ int msgid = msgget((key_t)1235, 0666 | IPC_CREAT); //获得消息队列 struct msgtype msg; memset(&msg,0,sizeof(struct msgtype)); while(1) { /*2. 从消息队列里读取指定消息类型*/ msgrcv(msgid,&msg,sizeof(struct msgtype),atoi(argv[1]),0); printf("读取的消息: %s\n", msg.buf); } return 0;}
复制代码
4. 案例代码: 消息队列基本使用
下面两个例子，一个例子用于创建队列，并向队列里写数据，另一个例子从队列里读取数据。
4.1 向队列写入消息
程序运行需要传入两个额外的参数。一个是消息的类型，一个是具体的内容。
./app 1 hello./app 2 123456789
复制代码
示例代码:
#include <stdio.h>#include <unistd.h>#include <string.h>#include <sys/types.h>#include <sys/stat.h>#include <fcntl.h>#include <dirent.h>#include <stdlib.h>#include <sys/mman.h>#include <sys/wait.h>#include <sys/shm.h>#include <sys/types.h>#include <sys/ipc.h>#include <sys/msg.h>#include <stdlib.h>
struct msgbuf{ long mtype; /* message type, must be > 0 */ char mtext[1024]; /* message data */};
int main(int argc,char **argv){ if(argc!=3) { printf("./app <消息类型> <消息内容>\n"); return 0; } /*1. 创建消息队列*/ int msqid=msgget(123456,0666|IPC_CREAT); /*2. 向消息队列里加入数据*/ struct msgbuf msg_buf; msg_buf.mtype=atoi(argv[1]); //消息类型 1、2、3、4、5 strcpy(msg_buf.mtext,argv[2]); //消息内容 msgsnd(msqid,&msg_buf,sizeof(struct msgbuf),0); printf("消息发送成功:%s,%s\n",argv[1],argv[2]); return 0;}
复制代码
4.2 从队列读取消息
#include <stdio.h>#include <unistd.h>#include <string.h>#include <sys/types.h>#include <sys/stat.h>#include <fcntl.h>#include <dirent.h>#include <stdlib.h>#include <sys/mman.h>#include <sys/wait.h>#include <sys/shm.h>#include <sys/types.h>#include <sys/ipc.h>#include <sys/msg.h>#include <stdlib.h>
struct msgbuf{ long mtype; /* message type, must be > 0 */ char mtext[1024]; /* message data */};
int main(int argc,char **argv){ if(argc!=2) { printf("./app <消息类型>\n"); return 0; } /*1. 创建消息队列*/ int msqid=msgget(123456,0666|IPC_CREAT); /*2. 从消息队列里取出数据*/ struct msgbuf msg_buf; msgrcv(msqid,&msg_buf,sizeof(struct msgbuf),atoi(argv[1]),0); printf("消息读取成功:%d,%s\n",msg_buf.mtype,msg_buf.mtext); return 0;}
复制代码
评论