Articles of message queue

Вот моя ситуация: У меня есть скрипт, который получает необработанные данные, сохраняет его в базе данных, получает идентификатор элемента, а затем отправляет его в очередь азатонов SQS. У меня есть другой скрипт (написанный на PHP), который извлекает необработанные данные из db и обрабатывает его. (обычно требуется несколько минут. Недостающая часть – это способ получения сообщений […]

Я пытаюсь настроить API, который использует систему очередей на другом сервере для обработки запросов. Позвольте мне начать то, что я пытаюсь выполнить без системы очередей (нет разрешения на ее простоту): используя Postman, например, делая запрос GET на URL-адрес https://example.com/products , возвращается строка JSON, например [ { "id": 1, "name": "some name", … }, { "id": […]

Я получил эту ошибку, когда пытаюсь подключиться с помощью php-amqp: Fatal error: Class 'AMQPConnection' не найден в $credentials =array('host' => 'localhost','port' => 5672); $cnn = new AMQPConnection($credentials); $cnn->connect();

Я ищу, чтобы реализовать RabbitMQ в моем приложении PHP, и использую расширение php–amqp. Мой единственный вопрос в том, как я могу легко запросить возврат содержимого очереди в PHP? php-amqp, похоже, не позволяет мне это делать. Если я ошибаюсь, пожалуйста, помогите мне здесь 🙂

Я пытаюсь обернуть голову вокруг модели очереди сообщений и заданий, которые я хочу реализовать в приложении PHP: Моя цель – выгрузить сообщения / данные, которые необходимо отправить нескольким сторонним API, поэтому доступ к ним не замедляет работу клиента. Поэтому отправка данных в очередь сообщений является идеальной. Я считал, что просто использовал Gearman для хранения MQ […]

Мне нужна простая таблица, которая действует как очередь. Мое ограничение сервера MySQL – я не могу использовать таблицы InnoDB, только MyISAM. Клиенты / работники будут работать в одно и то же время, и им нужно будет получать разные задания каждый раз. Моя идея – сделать следующее (псевдокод): $job <- SELECT * FROM queue ORDER BY […]

Я новичок в очередях обмена сообщениями, и сейчас я использую ZeroMQ на своем Linux-сервере. Я использую PHP для написания как клиента, так и сервера. Это в основном используется для обработки push-уведомлений. Как я уже ZMQContext , я использую базовый шаблон формальной связи REQ REP ZMQContext экземпляров ZMQContext ввода-вывода. Вот минимальный код zeromqServer.php : include("someFile.php"); $context […]