什么是消息队列

消息队列可以分为队列和消息

• 队列 队列是从开始到结束，有序地排放消息。消息队列是用来在应用程序发送消息的，队列中存放了一些待处理的消息。
• 消息 消息用来在接受者和发送者之间传输，它本质上是一个字节数组，上面有一些头信息。一个消息示例可以是任何告诉一个系统开始处理任务或完成任务的信息。

嵌入式进阶教程分门别类整理好了，看的时候十分方便，由于内容较多，这里就截取一部分图吧。

需要的朋友私信【内核】即可领取。

内核学习地址：Linux内核源码/内存调优/文件系统/进程管理/设备驱动/网络协议栈-学习视频教程-腾讯课堂

消息队列的基本结构是简单的，有一个客户端应用程序称为生产者，创建消息，并将它们传送到消息队列。其他应用程序，称为消费者，连接到队列，并得到要处理的消息。放置在队列上的消息被存储，直到用户处理它们为止。

消息队列API

• 创建新消息队列或取得已存在的消息队列

#include <sys/msg.h>
------------------------------------
int msgget(key_t key, int msgflg);

• 向队列读或者写数据

#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);

 struct msgbuf 
 {
      long mtype;       /* message type, must be > 0 */
      char mtext[1];    /* message data */
 };

• 设置消息队列属性

#include <sys/msg.h>
---------------------
int msgctl(int msqid, int cmd, struct msqid_ds *buf);

进一步对cmd名字做详细解释

kernel关于IPC参数

以上信息可以根据ipcs -l获得系统的信息

------ Messages: Limits --------
max queues system wide = 2779
max size of message (bytes) = 8192
default max size of queue (bytes) = 16384

根据kernel.txt可以得知，auto_msgmni的值默认是1，当设置为0的时候，就不能自动获取msgmni

root@test:# cat /proc/sys/kernel/auto_msgmni 
1
root@test:# 

而在K4.4版本中。你会发现auto_msgmni居然是0，而且设置1设置失败。

root@test:/ # cat /proc/sys/kernel/auto_msgmni 
0
root@test:/ # echo 1 > /proc/sys/kernel/auto_msgmni
root@test:/ # cat /proc/sys/kernel/auto_msgmni     
0
root@test:/ # 

这到底是什么原因？ 可以通过查看kernel的代码得知。

kernel/ipc_sysctl.c
------------------------
{
        .procname   = "auto_msgmni",
        .data       = NULL,
        .maxlen     = sizeof(int),
        .mode       = 0644,
        .proc_handler   = proc_ipc_auto_msgmni,
        .extra1     = &zero,
        .extra2     = &one,
},

以上是auto_msgmni的默认配置信息，而proc_ipc_auto_msgmni是设置auto_msgmni的回调函数。

 static int proc_ipc_auto_msgmni(struct ctl_table *table, int write,      void __user *buffer, size_t *lenp, loff_t *ppos)
 {
    struct ctl_table ipc_table;
    int dummy = 0;
    memcpy(&ipc_table, table, sizeof(ipc_table));
    ipc_table.data = &dummy;

    if (write)
        pr_info_once("writing to auto_msgmni has no effect");

    return proc_dointvec_minmax(&ipc_table, write, buffer, lenp, ppos);
 }

可以看到一句打印： 设置auto_msgmni已经没有作用了。

原文地址：https://cloud.tencent.com/developer/article/1995965 (版权归原作者所有，侵删)