Wie man php-amqplib rabbitMQ im Webbrowser verwendet

Question

Ich versuche, php-amqplib zum Senden und Empfangen von Nachrichten zu verwenden. Es funktioniert Senden/Empfangen am Terminal. Aber wenn Webbrowser gehen, nicht aus der Warteschlange empfangen kann, wartet er kontinuierlich auf eine Nachricht. Früher habe ich unten Code für receive.php

require_once(__DIR__ . '/lib/php-amqplib/amqp.inc'); 
include_once(__DIR__ . '/config/config.php'); 
$connection = new AMQPConnection(HOST, PORT, USER, PASS, VHOST); 
$channel = $connection->channel(); 
$channel->queue_declare('test22');  
$callback = function($msg){ 
echo $msg->body; 
};  
$channel->basic_consume('test22', 'consumer_tag', false, true, false, false, $callback); 

while(count($channel->callbacks)) { 
$channel->wait(); 
}  
$channel->close(); 
$connection->close(); 

Es wird erste Nachricht aus der Warteschlange, wenn ich unten statt Callback-Funktion verwenden, aber nicht verbrauchen aus der Warteschlange

$abc=$channel->basic_get("test22", false, 2);  
if(!empty($abc)) 
{ 
print_r($abc->body); 
} 

Es bedeutet, Nachrichten in der Warteschlange zur Verfügung stehen ' test22 '. geben Sie mir einen Hinweis.

Answer 1

Ändern Sie echo $msg->body; in error_log($msg->body); (oder ein anderes Loggin-System, das Sie verwenden). Ich denke, Sie werden wahrscheinlich die Nachrichten in den Protokollen sehen. Im Webbrowser ist die Seite bereits geladen, so dass sie sich nicht ändert, selbst wenn das Skript die Nachricht empfängt.