完全删除消息队列

Question

我在 PHP 中有一个用于处理任务的消息队列，我在插入任务时导致了一个错误，它刚刚插入了一堆布尔值（我通常通过它传递对象）。

我杀死了读取队列的进程，因为它由于未删除项目而挂起。

我在很长一段时间内运行良好的典型代码是：

    $mqst = msg_stat_queue($mqh);

    while ($mqst['msg_qnum']) {
        output('Queue is populated', O_DEBUG);
        msg_receive($mqh, 0, $msgtype, 2048, $data, true);
        $mqst = msg_stat_queue($mqh);
        if ($data instanceof \Core\Image) {
            $new_tasks[] = $data;
        } else {
            output('Got some odd data.. ' . print_r($data, true), O_ERROR);
        }
    }

从我的终端：

$ php -r '$mqh = msg_get_queue(12345, 0666);
          $mqst = msg_stat_queue($mqh); 
          $i = $mqst["msg_qnum"]; while ($i--) {
             msg_receive($mqh, 0, $type, 2048, $data, true);
             var_dump($type, $data); 
          }'

输出：

int(0)
bool(false)
int(0)
bool(false)
int(0)
bool(false)
int(0)
bool(false)
int(0)
bool(false)
int(0)
bool(false)
int(0)
bool(false)

我可以无限期地重复这一点，他们不会让步。我试图删除队列但没有成功，文档指出：

msg_remove_queue() 销毁队列指定的消息队列。仅当所有进程都处理完消息队列并需要释放它所占用的系统资源时才使用此功能。

但是，我已经终止了该进程，并且在释放资源方面并不是很具体。我不确定为什么在收到消息后没有将消息从队列中弹出。也许我错过了一些简单的东西

Answer 1

编辑这个答案是错误的。

仔细研究问题后，我认为问题出在：队列中的第一条消息大于2048个字节，导致msg_receive返回错误。因此，消息永远不会从队列中删除，所以它会保持原样。

下次调用该函数时，它会尝试获取相同的条目，因此会再次失败。

我最初的建议是让msg_receive 函数成为while 循环的条件会立即说明这一点。 （如果确实是解决方案）。

解决方案：现在，将MSG_NOERROR 标志添加到msg_receive 函数中，只是为了查看下一条消息是否确实太大，然后从那里进行调试。