Описание тега php-amqp
The PECL package implementing AMQP ("Advanced Message Queue Protocol") as a PHP extension. For the implementation in pure PHP, use [tag:php-amqplib].
1
ответ
Как выполнить блокирующий вызов basic_get с помощью videlalvaro/php-amqplib
Я использую https://github.com/videlalvaro/php-amqplib для выполнения работы rabbitmq: Я пытаюсь создать блокирующую версию basic_get (или версию basic_consume, которую я могу вызывать многократно и получать только одно сообщение каждый раз), котора…
29 ноя '15 в 04:22
0
ответов
RabbitMQ PHP (pecl php-amqp) чтение занимает более 1,5 секунды (во время небольшого теста)
У нас есть тест, запущенный с RabbitMQ, но каким-то образом достигнут "порог", который замедляет RabbitMQ. Что мы сделали, мы настроили сервер RabbitMQ и создали небольшой PHP-скрипт, который использует pecl-amqp для подключения (без pconnect) к сер…
29 дек '15 в 14:42
1
ответ
Как использовать php-amqplib rabbitMQ в веб-браузере
Я пытаюсь использовать php-amqplib для отправки и получения сообщения. Работает отправка / получение на терминале. Но когда веб-браузер идет, не в состоянии получить из очереди, он постоянно ждет сообщения. Я использовал приведенный ниже код для rec…
09 янв '15 в 13:15
2
ответа
Как задержать? - php-amqplib
Я хотел бы знать, как отложить с Amqpphplib. Я использовал этот замечательный учебник сценариев кофе: https://github.com/jamescarr/rabbitmq-scheduled-delivery но, похоже, он не работает с PHP-amqplib. Срок действия сообщения истекает, как я хочу, но…
21 фев '14 в 18:13
1
ответ
PECL AMQP против php-amqp
Я собираюсь реализовать систему на основе PHP, которая использует RabbitMQ. Я могу сказать, что есть две зрелые библиотеки: PECL AMQP и php-amqp. Я буду использовать PHP как для клиента, так и для работника. У кого-нибудь есть практический опыт рабо…
27 фев '15 в 10:42
1
ответ
Какой транспорт ActiveMQ я должен выбрать?
Мы используем ActiveMQ, php и stomp. И мы обнаружили, что при перезагрузке ActiveMQ потребители, работающие через stomp, не могут распознать потерянное соединение. Я обнаружил, что только Stomp 1.2 поддерживает сердцебиение. А ActiveMQ использует st…
11 дек '15 в 11:07
1
ответ
Механизм повтора RabbitMQ
Я использую rabbitMQ, я беру каждое сообщение из очереди с basic_get без автоматической процедуры подтверждения, что означает, что сообщение остается в очереди до тех пор, пока я не получу подтверждение или не получу сообщение. Иногда у меня есть со…
01 мар '15 в 12:09
1
ответ
Исключение "Ошибка сокета: не удалось подключиться к хосту" в php-amqp
Я написал функцию, которая проверяет, запущен ли rabbitmq. function getBrokerStatus() { log_message("info", "Checking if broker is running...."); try { $amqpConnection = new AMQPConnection(); $amqpConnection->setLogin("guest"); $amqpConnection-&g…
07 мар '14 в 10:14
1
ответ
Как запустить несколько параллельных потребителей Rabbitmq/AMQP в PHP и / или Symfony2?
У меня есть сборщик новостей /RSS-агрегация, где я транслирую сообщения через эту библиотеку. https://github.com/videlalvaro/php-amqplib/ В настоящее время у меня есть 1 вещатель / производитель и 1 потребитель. Есть ли способ, чтобы несколько потре…
09 фев '14 в 17:41
1
ответ
rabbitmq и php - обрабатывают несколько очередей с одним работником (брокером)
У меня 1000 очередей с конкретными именами. поэтому я хочу обработать эти очереди с одним брокером. Является ли это возможным? имена очередей хранятся в mysql db, поэтому я должен выбрать тему и запустить брокер для каждого. и, конечно, он должен ра…
20 июн '17 в 08:38
0
ответов
php-amqplib: как предотвратить бесконечную загрузку веб-страницы?
Я использую облачный сервис для обработки RabbitMQ. Целью является отправка и получение сообщений от смарт-объектов, использующих MQTT. Все работает, но... formPage.php при отправке запускает команду shellexec, которая выполняет initRpc.php. В initR…
22 фев '19 в 17:25
1
ответ
PHP-AMQPLIB: RPC -> очередь RPC оставляет нераспакованные сообщения позади
У меня есть пара потребителей (брокеров) типа PHP RPC, которые прикреплены к RMQ для получения событий. Один посредник находится в удаленной системе - однако для целей разработки / тестирования я запускаю "удаленный" посредник локально. Есть брокеры…
14 июл '15 в 22:46
1
ответ
rabbitmq + phalconphp как потребитель (с фоновыми заданиями)
Как связать phalconphp как потребитель с rabbitmq? Как я понял, мне нужно запустить фоновый процесс для phalconphp, чтобы иметь возможность прослушивать события / сообщения от rabbitmq и обрабатывать некоторые трудоемкие задачи (отправка почты, запи…
05 фев '15 в 21:34
2
ответа
Можно ли получить неразведенные сообщения в amqp?
Использование веб-интерфейса RabbitMQ. Когда я публикую в обмене темами без текущих привязок очереди, rabbitmq говорит, что сообщение было опубликовано, но не перенаправлено. Используя amqp.node, когда я связываю очередь с обменом и начинаю использо…
17 авг '16 в 04:40
1
ответ
Как добавить php-amqp в CircleCI config.yml?
Я попытался добавить в мой config.yml следующую команду: docker-php-ext-install amqp но CircleCI говорит: ошибка: /usr/src/php/ext/amqp не существует Это мой полный файл config.yml: # Файл конфигурации PHP CircleCI 2.0 # # Проверьте https://circleci…
06 окт '18 в 04:13
1
ответ
PHP AQMP формат сообщения
Могу ли я поставить в очередь PHP objects или я должен сериализовать их, прежде чем поставить в очередь, а затем десериализовать? Как обрабатывать сообщения из очередей?
14 ноя '13 в 16:29
0
ответов
Ошибка PHP AMQP (не phpamqplib) при использовании потока
Я пытаюсь превратить простой клиент AMQP в многопоточность. Следующий код работает, если я не расширяю Publish with Thread: <?php include ('../JS-amqp-include.php'); $mypid = getmypid(); echo "PID: $mypid\n"; class Publish extends Thread { privat…
15 ноя '15 в 07:42
1
ответ
RabbitMQ PHP для динамического обновления сообщений
Я изучаю RabbitMQ и подумал о том, чтобы использовать его для предоставления пользователям "динамических сообщений", очень похоже на то, как Facebook дает динамические каналы от друзей. Моя идея была: Каждый раз, когда создается пользователь, я созд…
03 окт '14 в 04:06
1
ответ
RabbitMQ - постоянная связь между производителем и потребителем
У меня вопрос - как сохранить постоянную связь между потребителем и производителем? Я имею в виду, когда производитель отправляет сообщения - потребитель обрабатывает их и отправляет обратно с очередью обратного вызова, если я использовал процедуру …
10 апр '14 в 11:15
1
ответ
Тайм-аут плагина LaravelQueueRabbitMQ на StreamIO.php
У меня проблемы с настройкой плагина LaravelQueueRabbitMQ в проекте Laravel 5.1. Вот хранилище для плагина: https://github.com/vladimir-yuldashev/laravel-queue-rabbitmq/tree/v5.1 Я установил пакет, добавил требуемого поставщика услуг в файл app.php,…
13 сен '16 в 14:31