Описание тега php-amqplib
This library is a pure PHP implementation of the Advanced Message Queuing Protocol (AMQP)
0
ответов
Исключение: слишком много попыток чтения обнаружено в StreamIO /var/www/html/vendor/php-amqplib/php-amqplib/PhpAmqpLib/Wire/IO/StreamIO.php 252
Исключение: слишком много попыток чтения обнаружено в StreamIO /var/www/html/vendor/php-amqplib/php-amqplib/PhpAmqpLib/Wire/IO/StreamIO.php
17 дек '18 в 08:38
1
ответ
Как выполнить блокирующий вызов basic_get с помощью videlalvaro/php-amqplib
Я использую https://github.com/videlalvaro/php-amqplib для выполнения работы rabbitmq: Я пытаюсь создать блокирующую версию basic_get (или версию basic_consume, которую я могу вызывать многократно и получать только одно сообщение каждый раз), котора…
29 ноя '15 в 04:22
0
ответов
Пример неблокирующего php-amqplib выдает предупреждения
Я пытаюсь использовать библиотеку videlalvaro/php-amqplib для связи AMQP, но не могу заставить работать неблокирующую версию. При запуске demo/amqp_consumer_non_blocking.php постоянно отображается следующее сообщение об ошибке: PHP Warning: stream_s…
31 окт '14 в 17:19
3
ответа
Как в RabbitMQ и PHP вернуть задачу обратно в очередь?
Как мне вернуть сообщение обратно в очередь, если результат обработки меня не устроил. Нашел только информацию о подтверждении сообщения, но думаю, что оно меня не устраивает. Мне нужно, что если в результате обработки я получаю параметр RETRY, сооб…
18 сен '17 в 01:16
1
ответ
Json парсинг или передача заголовков в RabbitMQ
Я хочу передать множественное значение в очередь, которая предоставляется RabbitMQ через PHP. Это отправитель SMS с номером мобильного телефона и контентом. Лучше ли отправлять эти два параметра в виде строки json в полезную нагрузку очереди и на ст…
26 июл '16 в 15:07
1
ответ
Как я могу получить одно сообщение из очереди rabbitMq, используя PHP?
Мне нужно поймать только одно реальное сообщение из одной очереди. Кролик пытается поймать их всех. Упрощенный код ниже: private function getSingleTask(){ $connection = new AMQPConnection('localhost', 5672, 'guest', 'guest'); $channel = $connection-…
23 сен '15 в 18:38
2
ответа
PHP AMQP передает заголовки в запросе
Я пытаюсь отправить запрос в AMQP, застрял в том, как добавить заголовок к сообщению запроса, ниже приведена обертка, которую мы имеем $message = ‘{"empId": ‘.$empId.', “empName”:”my name"}’; $resData = $rpcClient->call($message, self::EXCHANGE, …
09 июл '15 в 10:18
2
ответа
RabbitMQ: связывание с DLX
Я искал эту информацию (включая документы) и не могу ее найти. Я использую последнюю версию php-amqplib с RabbitMQ v. 2.7.1. У меня три очереди и три обмена: // Declare the exchanges $this->channel->exchange_declare(self::EXCHANGE_TO_PROCESS, …
04 июн '14 в 18:40
1
ответ
php-amqplib - фатальная ошибка: вызов функции-члена basic_get() для ресурса
Использование системы очередей для обработки заданий. Мы запускаем cron один раз каждое утро в 1:00, и он публикует все наши необходимые вызовы API. У нас есть другой потребительский cron, который запускается каждые пять минут и обрабатывает запросы…
22 янв '19 в 19:59
1
ответ
Чтение сообщений из RabbitMQ с помощью php-amqlib не работает
Я работаю над взаимодействием клиент-сервер с PHP и RabbitMQ, используя php-amqplib. У меня есть сценарий продюсера, который выглядит нормально, но мой потребитель ничего не получает. Я проверил записи в очереди с sudo rabbitmqctl list_queues и посл…
23 авг '17 в 09:48
1
ответ
Что если соединение не закрыто явно с помощью php amqplib?
Предположим, в моем скрипте php я открыл соединение с rabbitmq с помощью клиента php-amqplib. И после публикации сообщения я явно не закрываю канал и соединение. Я не вижу никакого таймаута в конфиге rabbitmq для соединений. Что происходит с соедине…
27 фев '18 в 15:10
1
ответ
Как настроить Consumer, запускается один раз и продолжается вечно без перерыва.
Я очень новичок в RabbitMQ и использую RabbitMQ 3.5.3, Erlang R14B04 и библиотеку Альваро Видела ( https://github.com/videlalvaro/php-amqplib) для очередей в RabbitMQ. Мне нужно постоянно поддерживать связь с потребителями, а не с производителем. Пр…
08 июл '15 в 09:05
2
ответа
Тайм-аут ошибки RabbitMQ
Я настроил RabbitMQ, чтобы анализировать около 20000 запросов от внешнего API, но время ожидания истекает через несколько минут. Это дает возможность правильно проанализировать около 2000 из 20000 запросов. Файл журнала говорит: =INFO REPORT==== 16-…
16 фев '16 в 17:12
1
ответ
Ошибка подключения php-amqplib
Я просто делаю тест, чтобы попытаться заставить RabbitMQ работать с php-amqplib, Я только что отредактировал вопрос, чтобы он использовал правильный порт. Есть идеи по этому поводу? Это мой файл PHP... 1 #!/usr/bin/env php 2 <?php 3 4 require __D…
12 июн '18 в 11:43
2
ответа
Доступ к обмену сообщениями, отправленными до привязки очереди
У меня есть вопрос, касающийся третьего урока RabbitMQ. Я пытаюсь реализовать нечто подобное, за исключением того, что нет никакой гарантии, что потребитель (-и) будет работать в то время, когда производитель отправляет сообщение на биржу. Итак, у м…
25 окт '16 в 12:34
1
ответ
rabbitMQ не может заставить пульс работать с php-amqplib
Я наблюдал, как RabbitMQ "застрял" с непрочитанными сообщениями. Очередь показывает потребителя, которого больше нет, и я предполагаю, что RabbitMQ продолжает доставлять сообщения этому потребителю. Они показывают как постоянно увеличивающееся колич…
17 авг '16 в 21:39
1
ответ
Потребитель PHP Ampqlib умирает: Ошибка чтения данных. Получено 0 вместо ожидаемых 1 байтов
ОК, это часть сценария командной строки Symfony2. Пока скрипт ждет, он умирает с этим исключением. [PhpAmqpLib\Exception\AMQPRuntimeException] Error reading data. Received 0 instead of expected 1 bytes Я искал в Google и нашел упоминание heartbeat и…
10 авг '15 в 15:52
0
ответов
Нет сообщения в очереди, если я установил дополнительные свойства для моего сообщения
Я использую symfony 3.4 с RMQ 3.6.14, Я имел дело с дополнительными свойствами, но, как ни странно, сообщение так и не дошло RMQ сервер. Я везде ставлю какую-то точку отладки, но не могу это объяснить. я использую php-amqlib 2.7.2, если я сделаю: $t…
09 авг '18 в 13:44
1
ответ
PHP драйвер RabbitMQ (AMQP): обработка заблокированных соединений
Я пытаюсь создать значимый код для обработки ситуации, когда RabbitMQ начинает блокировать соединения из-за уровня диска или предупреждения о водяных знаках памяти. Есть возможность добавить обработчик для уведомлений о переводе соединения в заблоки…
09 май '16 в 22:35
1
ответ
Что означает значение $channel->wait() в RabbitMQ
Я совершенно новый в RabbitMQ. Я работаю с библиотекой php-amqplib с codeigniter и до сих пор интересуюсь некоторыми знаниями, которых мне не хватает. Зачем $channel->wait() используется? Почему он всегда находится внутри бесконечного цикла while…
20 янв '17 в 12:07