Linux系统编程—消息队列

消息队列本质上是位于内核空间的链表，链表的每个节点都是一条消息。每一条消息都有自己的消息类型，消息类型用整数来表示，而且必须大于 0。每种类型的消息都被对应的链表所维护：

其中数字 1 表示类型为 1 的消息，数字2、3、4 类似。彩色块表示消息数据，它们被挂在对应类型的链表上。

值得注意的是，刚刚说过没有消息类型为 0 的消息，实际上，消息类型为 0 的链表记录了所有消息加入队列的顺序，其中红色箭头表示消息加入的顺序。

无论你是发送还是接收消息，消息的格式都必须按照规范来。简单的说，它一般长成下面这个样子：

所以，只要你保证首4字节(32 位 linux 下的 long)是一个整数就行了。

举个例子：

从上面可以看出，正文部分是什么数据类型都没关系，因为消息队列传递的是 2 进制数据，不一定非得是文本。

msgsnd 函数用于将数据发送到消息队列。如果该函数被信号打断，会设置 errno 为 EINTR。

参数 msqid：ipc 内核对象 id

参数 msgp：消息数据地址

参数 msgsz：消息正文部分的大小（不包含消息类型）

参数 msgflg：可选项

该值为 0：如果消息队列空间不够，msgsnd 会阻塞。

IPC_NOWAIT：直接返回，如果空间不够，会设置 errno 为 EAGIN.

返回值：0 表示成功，-1 失败并设置 errno。

msgrcv 函数从消息队列取出消息后，并将其从消息队列里删除。

参数 msqid：ipc 内核对象 id

参数 msgp：用来接收消息数据地址

参数 msgsz：消息正文部分的大小（不包含消息类型）

参数 msgtyp：指定获取哪种类型的消息

msgtyp = 0：获取消息队列中的第一条消息

msgtyp >0：获取类型为 msgtyp 的第一条消息，除非指定了 msgflg 为MSG_EXCEPT，这表示获取除了 msgtyp 类型以外的第一条消息。

msgtyp <0：获取类型 ≤|msgtyp|≤|msgtyp| 的第一条消息。

参数 msgflg：可选项。

如果为 0 表示没有消息就阻塞。

IPC_NOWAIT：如果指定类型的消息不存在就立即返回，同时设置 errno 为 ENOMSG

MSG_EXCEPT：仅用于 msgtyp >0 的情况。表示获取类型不为 msgtyp 的消息

MSG_NOERROR：如果消息数据正文内容大于 msgsz，就将消息数据截断为 msgsz

程序 msg_send 和 msg_recv 分别用于向消息队列发送数据和接收数据。

msg_send 程序定义了一个结构体 Msg，消息正文部分是结构体 Person。该程序向消息队列发送了 10 条消息。

msg_send.c

程序 msg_send 第一次运行完后，内核中的消息队列大概像下面这样：

msg_recv 程序接收一个参数，表示接收哪种类型的消息。比如./msg_recv 4 表示接收类型为 4 的消息，并打印在屏幕。

先运行 msg_send，再运行 msg_recv。

接收所有消息

接收类型为 4 的消息

获取和设置消息队列的属性

msqid：消息队列标识符

cmd：控制指令

IPC_STAT:获得msgid的消息队列头数据到buf中

IPC_SET：设置消息队列的属性，要设置的属性需先存储在buf中，可设置的属性包括：msg_perm.uid、msg_perm.gid、msg_perm.mode以及msg_qbytes

buf：消息队列管理结构体。

返回值：

成功：0

出错：-1，错误原因存于error中

EACCESS：参数cmd为IPC_STAT，确无权限读取该消息队列

EFAULT：参数buf指向无效的内存地址

EIDRM：标识符为msqid的消息队列已被删除

EINVAL：无效的参数cmd或msqid

EPERM：参数cmd为IPC_SET或IPC_RMID，却无足够的权限执行

问题：

在Linux 系统中通过消息队列进行进程间的通讯时，只要定义的BufSize小于1024，队列就能正常读写，当Size定义大于1024时，队列就无法成功。

处理步骤：

SystemV的消息队列

/etc/sysctl.conf

修改

kernel.msgmni=1000

kernel.msgmax=81920

kernel.msgmnb=163840

msgmni为MSGMNI，即系统的消息队列数目。平台每个DTA需要使用3个消息队列，即最大DTA数为1000/3。该参数应该比平台最大队列个数参数配置大。

msgmax为MSGMAX，即一个消息的字节大小。目前扩展值为8k，平台一个交易消息为4个字节，不会超过限制。

msgmnb为MSGMNB，即队列存放消息的总字节数。

POSIX消息队列

修改

fs.mqueue.msg_max=1000  <-消息个数

fs. mqueue. msgsize_max=8192 <-消息长度

另外 *** 作系统对文件大小的限制ulimit -q你可以看到POSIX消息队列的最大容量

cat /proc/sys/kernel/msgmax

cat /proc/sys/kernel/msgmni

cat /proc/sys/kernel/msgmnb

1、无名管道通信

无名管道(pipe)：管道是一种半双工的通信方式，数据只能单向流动，而且只能在具有亲缘关系的进程间使用，进程的亲缘关系通常是指父子进程关系。

2、高级管道通信

高级管道(popen)：将另一个程序当做一个新的进程在当前程序进程中启动，则它算是当前程序的子进程，这种方式我们称为高级管道方式。

3、有名管道通信

有名管道(named pipe)：有名管道也是半双工的通信方式，但是它允许无亲缘关系进程间的通信。

4、消息队列通信

消息队列(message

queue)：消息队列是由消息的链表，存放在内核中并由消息队列标识符标识，消息队列克服了信号传递信息少、管道只能承载无格式字节流以及缓冲区大小受限等缺点。

5、信号量通信

信号量(semophore)：信号量是一个计数器，可以用来控制多个进程对共享资源的访问，它常作为一种锁机制，防止某进程正在访问共享资源时，其他进程访问该资源。因此，主要作为进程间以及同一进程内不同线程之间的同步手段。

6、信号

信号(sinal)：信号是一种比较复杂的通信方式，用于通知接收进程某个事件已经发生。

7、共享内存通信

共享内存(shared

memory)：共享内存就是映射一段能被其他进程所访问的内存，这段共享内存由一个进程创建，但多个进程都可以访问。共享内存是最快的IPC方式，它是针对其他进程间通信方式运行效率低而专门设计的。它往往与其他通信机制，如信号量，配合使用，来实现进程间的同步和通信。

8、套接字通信

套接字(socket)：套接字也是一种进程间通信机制，与其他通信机制不同的是，它可用于不同机器间的进程通信。

---