POSIX消息队列调用mq_send时报错‘Message too long’问题排查

核心原因 #

这个问题大概率是消息队列已存在，且其消息长度限制远小于你设置的6200，而本次mq_open调用复用了旧队列，忽略了新的属性设置。POSIX消息队列的关键规则：

• 仅当队列首次创建时，mq_open传入的mq_attr才会生效。
• 若队列已存在（比如之前测试遗留的队列），mq_open直接打开旧队列，无视本次传入的属性参数。

另一种可能是mq_open调用时未正确传递mq_attr参数（比如误传NULL），导致队列使用系统默认的极小消息长度限制。

解决步骤 #

1. 清理残留消息队列
   查看系统中已有的POSIX消息队列：

   ls /dev/mqueue/
   

   删除对应队列：

   rm /dev/mqueue/你的队列名称
   

   也可以在代码中调用mq_unlink，确保程序退出时清理队列。

2. 强制创建新队列
   调用mq_open时同时指定O_CREAT和O_EXCL标志，确保队列不存在时才创建，避免复用旧队列：

   struct mq_attr attr = {0};
   attr.mq_msgsize = 6200;
   attr.mq_maxmsg = 10; // 根据业务需求设置最大消息数
   mqd_t mq = mq_open("/your_queue", O_WRONLY | O_CREAT | O_EXCL, 0666, &attr);
   if (mq == (mqd_t)-1) {
       perror("mq_open failed");
       exit(EXIT_FAILURE);
   }
   

   加O_EXCL后，若队列已存在，mq_open会直接报错，避免意外复用旧队列。

3. 验证队列实际属性
   创建队列后，用mq_getattr确认mq_msgsize是否正确设置：

   struct mq_attr actual_attr;
   if (mq_getattr(mq, &actual_attr) == -1) {
       perror("mq_getattr failed");
       exit(EXIT_FAILURE);
   }
   printf("实际消息长度限制: %ld\n", actual_attr.mq_msgsize);
   

额外提示 #

• POSIX消息队列的名称必须以/开头（如/my_queue），不能用相对路径。
• 系统对消息队列有全局限制，可通过/proc/sys/fs/mqueue/下的参数调整，但默认值通常足够满足需求。

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