Rabbitmq PHP 每秒消耗一次

Question

通过 php 每秒从队列接收数据的最佳做法是什么？我使用 ajax 查询执行此操作，每秒调用 php 脚本。在那里，每次都会创建一个连接对象并声明一个队列。我试图在第一次之后将其保存在会话变量中，但是当我第二次调用 PHP 脚本时，我无法再接收到任何数据。当我调试通道对象时，我看到 is_open 是假的：

  protected' is_open' => boolean false

这是我的基本 php 测试代码：

<?php


require_once __DIR__ . '/vendor/autoload.php';

use PhpAmqpLib\Connection\AMQPStreamConnection;
use PhpAmqpLib\Message\AMQPMessage;



session_start(); # start session handling.

$id        = $_GET["uid"];
$connected = $_GET["connected"];

if (empty($id)) {
    $id = 0;
}
$queue = 'CyOS EV Queue ' . $id;

$reset = $_GET["reset"];

if ($reset === "true") {
    session_destroy();
    $_SESSION = array();
    echo "session destroyed";
    var_dump($_SESSION);
    exit;

}


$connection;
$channel;


if (!isset($_SESSION['coneccted'])) {

    $_SESSION['coneccted'] = true;

    $connection = new AMQPStreamConnection('localhost', 5672, 'guest', 'guest');


    $channel = $connection->channel();


    $channel->queue_declare($queue, false, false, false, false, false);

    $channel->queue_bind($queue, 'CyOS-EX');

    $_SESSION['connection'] = $connection;
    $_SESSION['channel']    = $channel;




} else {
    echo "already connected \n\r";
    $connection = $_SESSION['connection'];

    $channel = $_SESSION['channel'];

    var_dump($_SESSION);

}

$test = new AMQPMessage();

while ($i < 10) {

echo "try to get data from " . $queue . "\n\r";
$test = $channel->basic_get($queue, true);

$i++;
if (isset($test)) {
    echo "received data";
    break;

   }
 }
echo $test->body;

当我每次调用脚本时都初始化连接和通道时，它就可以工作了。

Answer 1

我想你关心的是这些行：

$connection = new AMQPStreamConnection('localhost', 5672, 'guest', 'guest');
$channel = $connection->channel();
$channel->queue_declare($queue, false, false, false, false, false);
$channel->queue_bind($queue, 'CyOS-EX');

让我们看看这里发生了什么：

连接到 RabbitMQ 服务器。这就像连接到数据库、内存缓存或任何其他外部进程，并且需要在每个 PHP 请求中发生。您不能在会话中存储连接，因为它不是数据，它是一个活动资源，当 PHP 退出时将被关闭。
请求连接上的默认频道。这实际上只是连接代码的一部分，不应占用任何大量时间或资源。
声明队列。这将检查队列是否已经存在，如果存在，则什么也不做。另一方面，如果您知道队列存在（因为它是在管理界面中创建的永久队列，或者您确定另一个进程将创建它），您可以跳过此行.
将队列绑定到交换器。这是队列设置的一部分；如果队列不存在且尚未绑定，则在此行运行之前，队列中没有任何内容可供使用。与上一步一样，如果您知道它发生在其他地方，则可以跳过。

避免 re-connecting（步骤 1 和 2）的正常方法是让消费者运行在后台，例如使用 supervisord 启动 command-line PHP 脚本，该脚本会在消息传入时不断处理消息。但是，如果您需要在数据出现在排队。

每次轮询和创建新 PHP 进程的常见替代方法包括：

长轮询，其中 AJAX 调用会一直等到有东西要 return，而不是 return 得到一个空结果。
流式传输响应（将每个结果从 PHP 回显到浏览器，但不会结束该过程）。
WebSockets（我在 PHP 中没有看到很好的实现，但可能有）。

正如我所说，这些并不是 RabbitMQ 特有的，而是适用于您等待数据库、文件、远程服务等发生某些事情的任何时候。

Rabbitmq PHP 每秒消耗一次

Rabbitmq PHP consume every second

php

rabbitmq

consumer

php-amqplib