Я реализовал простую службу сообщений с rabbitMq и php-клиентом videlalvaro / php-amqplib. Но когда я отправляю два сообщения, мой получатель теряет одно. Есть идеи, что могло случиться? Код используется ниже.
send.php
require_once __DIR__ . '/vendor/autoload.php';
use PhpAmqpLib\Connection\AMQPConnection;
use PhpAmqpLib\Message\AMQPMessage;
$connection = new AMQPConnection('127.0.0.1', 5672, 'guest', 'guest');
$channel = $connection->channel();
$channel->queue_declare('hello', false, false, false, false);
for ($i=0; $i < 10; $i++) {
$text = "SEND MESSAGE ".$i;
$msg = new AMQPMessage($text);
$channel->basic_publish($msg, '', 'hello');
echo " [x] SEND MESSAGE ".$i."\n";
}
$channel->close();
$connection->close();
receiver.php
require_once __DIR__ . '/vendor/autoload.php';
use PhpAmqpLib\Connection\AMQPConnection;
$connection = new AMQPConnection('127.0.0.1', 5672, 'guest', 'guest');
$channel = $connection->channel();
$channel->queue_declare('hello', false, false, false, false);
echo ' [*] Waiting for messages. To exit press CTRL+C', "\n";
$callback = function($msg) {
echo " [x] Received: ", $msg->body, "\n";
};
$channel->basic_consume('hello', '', false, true, false, false, $callback);
while(count($channel->callbacks)) {
$channel->wait();
}
$channel->close();
$connection->close();
send.php распечатать ответ
[x] ОТПРАВИТЬ СООБЩЕНИЕ 0receive.php распечатать ответ
[x] Получено: ОТПРАВИТЬ СООБЩЕНИЕ 1Были те же проблемы и потерял много времени в поисках решения. Наконец, это был недостаток свободного места на диске, где был установлен Rabbit Server. Там написано «50 МБ водяного знака», но проблемы начинаются с 1 ГБ свободного места. Сообщения куда-то идут.
И попробуйте красный журнал сервера, может быть, вы найдете подсказку.
Других решений пока нет …