Как организовать работу PHP и RabbitMQ?
Необходимо при возникновении определенного события отправлять запросы на обработку данных на сторонний сервер, который периодически "отваливается", а кроме того имеет ограничение - принимать в минуту не более 5 запросов. Событий может возникать больше 5 в минуту, поэтому было принято решение использовать очереди (RabbitMQ).
Большинство примеров использования очередей сводится к банальному:
- запустил в одной консоли скрипт, в котором установил соединение, задал точку обмена, очередь и отправил сообщение "Hello World!"
- запустил во второй конcоли скрипт, в котором также установил соединение, задал точку обмена, очередь, подписался на сообщения этой очереди и задал бесконечный цикл:
while ($channel->is_consuming()) { $channel->wait(); }
while ($channel->is_consuming()) { $channel->wait(); }
- Как ограничить количество прочтенных сообщений получателем, чтобы их было не более 5 в минуту, чтобы соблюсти наложенное ограничение сторонним сервером?
- Как несмотря на наличие ограничения на количество читаемых сообщений в минуту, сделать бесконечно ожидающего слушателя? Держать на проде постоянно запущенный в консоли скрипт - это плохое решение.
- Как быть с получением и обработкой сообщений, если сторонний сервер вообще на какое-то время "отвалился"?
Дополнительно:
1. Где-то хранить данные по владельцам сообщений и в случае оверквоты - откладывать на минуту. Какой нибудь редис вполне покатит.
2. Не понял? Вы не хотите держать демона разгребающего очередь? А что вы хотите?
3. Откладывать задачу на какое то время - если задача обязательно должна быть обработана. Или выкидывать ее в ведро, если похрен
- Не совсем понятна Ваша идея с Redis в сочетании с тем, что сообщения-задания данные будут на Rabbitе храниться
- Демонов на PHP не приходилось реализовывать. Насколько они стабильно работают и не отваливаются? Была идея по крону запускать скрипт получателя, потом спустя время завершать его, а потом сразу снова запускать. Но такая идея выглядит очень костыльной.
1. Ну а что будет знать сообщение о том сколько задач от этого пользователя за последнюю минут обработалось? Ничего. Она собственно и не может знать - потому что этап постановки задачи != этапу обработки задачи.
Значит скрипт который обрабатывает джобы из очереди после каждой обработки должен куда то запомнить сколько задач от этого пользователя он за последнюю минуту обработал.
2. Ну смотря как напишите. Если нормально напишите - будет нормально работать.
Если вы хотите по крону - то нахрена вам очередь вообще? Почему не обычная таблица в базе данных?
2. Очередь нужна за тем, что в будущем нужно будет делать и другие операции, для которых нужна очередь: например, нотификация юзеров. И использовать БД в таких случаях будет слишком тяжеловесно. Поэтому механизм хочется отладить сейчас, чтобы дальше его использовать и в других задачах (более классических).
Опишите проблему, и специалист поможет с настройкой, исправлением ошибки или доработкой сайта. Подберём понятный план работ без лишней переписки.
Пока нет других ответов. Будьте первым, кто поможет автору.
Ответить на вопрос
Для организации работы PHP и RabbitMQ вам понадобится использовать библиотеку php-amqplib, которая позволяет взаимодействовать с RabbitMQ из PHP кода. Вот пример шагов, которые вам нужно выполнить для настройки этой работы:
1. Установите библиотеку php-amqplib с помощью Composer, если у вас еще нет этой зависимости в вашем проекте. Для этого добавьте следующую строку в файл composer.json:
"require": { "php-amqplib/php-amqplib": "^2.11" }
2. Затем запустите команду `composer install`, чтобы установить библиотеку.
3. Создайте файл конфигурации для работы с RabbitMQ. В этом файле вы должны указать параметры подключения к вашему RabbitMQ серверу, например:
$connection = new AMQPStreamConnection('localhost', 5672, 'guest', 'guest'); $channel = $connection->channel();
4. Теперь вы можете опубликовать сообщение в очередь RabbitMQ, используя следующий код:
$channel->queue_declare('hello', false, false, false, false);$msg = new AMQPMessage('Hello World!');
$channel->basic_publish($msg, '', 'hello');
echo " [x] Sent 'Hello World!'