Php Rabbitmq Примеры

RabbitMQ является открытым программным обеспечением для обработки сообщений, которое позволяет разработчикам написать программы, которые обмениваются данными с другими приложениями.

С его помощью можно использовать параллельную обработку сообщений и использовать более высокую пропускную способность, что делает его полезным для создания сложных приложений и микросервисов в PHP.

RabbitMQ работает по протоколу AMQP, который использует очереди сообщений для обмена информацией между приложениями.

Вот пример кода на PHP, который использовал бы библиотеку PHP-AMQP для создания очереди и получения сообщений из очереди:

$connection = new AMQPConnection(array(  'host' => 'localhost',  'port' => '5672',  'username' => 'guest',  'password' => '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();