0

我在 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() 销毁队列指定的消息队列。仅当所有进程都处理完消息队列并需要释放它所占用的系统资源时才使用此功能。

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

4

1 回答 1

-2

编辑这个答案是错误的。

更深入地研究了这个问题，我认为问题如下：队列中的第一条消息大于2048个字节，导致msg_receive返回错误。因此，消息永远不会从队列中删除，因此它会保持原样。

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

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

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

于 2012-08-18T22:07:27.190 回答