2

我正在开发一个系统，该系统由内置于 CakePHP 框架的前端和基于 Java 的后端组成。这两个生态系统之间的通信是通过从 CakePHP 控制器向 RabbitMQ 代理发送 JSON 消息来实现的。当消息被消费时，结果被发送回前端。现在，我需要使用消息并将结果从控制器推送到用户浏览器。对于 PHP 部分，我使用的是 phpamqplib，但在监听新消息时它需要有一个无限循环：

     $channel->basic_consume('AMQP.COMMAND.OUTPUT.QUEUE', 
            'consumer', 
            false, 
            false, 
            false, 
            false, 
            array($this, 'processMessage'));


    function shutdown($ch, $conn){
        $ch->close();
        $conn->close();
    }
    register_shutdown_function('shutdown', $channel, $conn);

    while (count($channel->callbacks)) {
        $read   = array($conn->getSocket()); // add here other sockets that you need to attend
        $write  = null;
        $except = null;
        if (false === ($num_changed_streams = stream_select($read, $write, $except, 60))) {
            /* Error handling */
        } elseif ($num_changed_streams > 0) {
            $channel->wait();
        }
    }

在我的控制器中，这会引发 Apache 服务器抛出错误，因为超过了 30 秒的最大执行时间。我在这里真的需要帮助。收听新消息然后将结果推送到视图的最佳解决方案是什么？

谢谢

干杯。

4

1 回答 1

0

我强烈建议将其转换为基于 AJAX 的基础架构，并重构您的代码以执行此操作：

  1. CakePHP 每 x 秒进行一次 AJAX 调用以加载页面
  2. AJAX URL 从队列中获取剩余元素，并输出它们

您的代码看起来不完整，因此我无法完全重构它，但您可以更改 AJAX URL 以执行以下操作：

if (count($channel->callbacks)) {
    $read   = array($conn->getSocket()); // add here other sockets that you need to attend
    $write  = null;
    $except = null;
    if (false === ($num_changed_streams = stream_select($read, $write, $except, 60))) {
        /* Error handling */
    }
}

完成后关闭频道。

如果您真的想使用推送，您的另一个选择是使用网络套接字。进行搜索，或者本教程可能会帮助您入门。

于 2012-06-26T20:56:21.940 回答