Jak używać php-amqplib rabbitMQ na przeglądarce internetowej

Question

Próbuję użyć php-amqplib do wysyłania i odbierania wiadomości. Działa wysyłanie/odbieranie na terminalu. Ale po przejściu do przeglądarki internetowej, nie może odbierać z kolejki, ciągle czeka na wiadomość. Użyłem poniżej kod do 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(); 

Robi się pierwszy komunikat z kolejki, jeśli mogę użyć poniżej zamiast funkcji zwrotnej, ale nie spożywać z kolejki

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

Oznacza to wiadomości są dostępne w kolejce " test22 '. daj mi jakąkolwiek wskazówkę.

Answer 1

Zmień echo $msg->body; na error_log($msg->body); (lub inny system logowania, którego używasz). Myślę, że prawdopodobnie zobaczysz wiadomości w dziennikach. W przeglądarce internetowej strona jest już załadowana, więc nie zmieni się, nawet jeśli skrypt otrzyma wiadomość.