Как использовать сообщение в RabbitMq Laravel с помощью пакета bschmitt / laravel-amqp

Question

Я использую пакет Laravel https://github.com/bschmitt/laravel-amqp/ для публикации и использования сообщения с использованием RabbitMQ в приложении на основе Microservices. Я публикую сообщение в сервисе и пытаюсь использовать его в другом сервисе.

Документация достаточно ясна в коде для использования опубликованного сообщения в очереди. Однако в традиционном процессе очереди Laravel мы описали бы процесс, выполняемый внутри метода handle (). И вызовите команду php artisan queue: work для выполнения очереди.

Но здесь, в документации, код понятен для использования сообщения, но как использовать сообщение и выполнить то же самое с помощью команды artisan, сбивает с толку.

где бы я написал код, приведенный ниже, в приложении Laravel и прослушал его на рабочем сервере:

Amqp :: потребление ('queue-name', функция ($ message, $ resolver)) {

var_dump ($ message-> body);

$ resolver-> Подтверждение ($ message);

});

Пока, я использую сообщение из очереди в методе boot () файла AppServiceProvider.php. Но не уверен, что это правильный путь.

Answer 1

Способ использования сообщений заключается в создании специальной команды для прослушивания очереди. Нам нужно запустить команду и самим поддерживать жизнь, так как пакет не предоставляет шаблон для этого. Соединение можно сохранить живым, сделав параметр «Постоянный для истинного» в конфигурации.