如何查询POSIX及System V消息队列中的剩余消息数量

原生系统调用方案（优先使用） #

• 直接调用msgctl系统调用的IPC_STAT操作即可获取队列的实时消息数，该方法无额外性能开销、统计结果为原子快照，完全满足你指定时刻统计存量的需求。
  System V消息队列的元数据由内核统一维护，通过msgctl读取到的struct msqid_ds结构体中，msg_qnum字段即为当前队列中未被消费的消息总数。
  参考实现代码：

#include <sys/msg.h>
#include <errno.h>

/**
 * @brief 获取System V消息队列的当前消息存量
 * @param msgqid 已打开的消息队列ID
 * @return >=0 为消息数，<0 为系统错误码
 */
int get_sysv_msgq_pending_count(int msgqid) {
    struct msqid_ds q_stat;
    int ret = msgctl(msgqid, IPC_STAT, &q_stat);
    if (ret != 0) {
        return -errno;
    }
    return (int)q_stat.msg_qnum;
}

调用注意事项：

• 调用进程需要持有目标消息队列的读权限，否则会返回EACCES错误
• 你可以批量遍历所有业务使用的消息队列ID，调用上述接口获取存量后排序，即可实现最长队列优先的消费调度逻辑

全局批量统计方案 #

• 如果你需要统计系统内所有System V消息队列的存量、无需提前持有队列ID，可以直接解析/proc/sysvipc/msg文件，该文件由内核实时生成，记录了所有活跃消息队列的元数据，其中qnum列即为对应队列的消息数。
  文件内容样例：

key      msqid perms      cbytes       qnum lspid lrpid   uid   gid  cuid  cgid      stime      rtime      ctime
0x00001234       33   664        2048          6  2345  2348  1001  1001  1001  1001 1701234567 1701234569 1701234500

上述样例中ID为33的消息队列当前有6条未消费消息。

补充：POSIX消息队列兼容方案 #

如果你后续需要适配POSIX类型的消息队列，可以使用mq_getattr()接口，返回的struct mq_attr结构体中的mq_curmsgs字段即为队列当前消息数，调用逻辑和System V版本一致。

内容的提问来源于stack exchange，提问作者Guardian