Мы разрабатываем приложение реального времени, и мы используем модуль потокового потока nginx для части websockets. Во-первых, данные отправляются от клиента к скрипту php, который выполняет некоторую проверку подлинности и хранит необходимую информацию в базе данных, а затем передает информацию в nginx, которая затем отправляет ее подписчикам на определенные сокеты. Довольно часто бывают ситуации, когда 30 […]
Хорошо, вот обзор того, что происходит: M <– Message with unique id of 1234 | +-Start Queue | | | <– Exchange /|\ / | \ / | \ <– bind to multiple queues Q1 Q2 Q3 \ | / <– start of the problem is here \ | / \ | / \|/ | […]
Я пытаюсь установить расширение RabbitMQ PECL, но после запуска sudo pecl install amqp Я получаю следующее загадочное сообщение об ошибке, которое не разрешило обширный поиск в Google. У меня установлены эти пакеты: librabbitmq – сам клиент RabbitMQ C) librabbitmq-dev – dev заголовки и т. д. и RabbitMQ успешно работает на локальном хосте Возможно, это может […]
Я пытаюсь создать оболочку RabbitMQ PHP и оболочку AMPQ PHP в Windows (64) с помощью Cygwin. Я успешно создал базовую библиотеку C (librabbitmq.dll), но я застрял на шаге «phpize»: phpize && ./configure –with-rabbit && make && sudo make install Если я правильно понимаю, в Windows нет «phpize», так как я могу создать свою PHP-оболочку? Обратите […]
Я уже видел этот вопрос . Это предполагает, что расширение AMQP PECL не установлено. Тем не менее, я успешно установил как RabbitMQ, так и построил расширение PECL AMQP. Ниже приведен вывод phpinfo (). Вы можете ясно видеть, AMQP загружен правильно. Однако, когда я пытаюсь установить соединение, он говорит, что PHP Fatal error: Class 'AMQPConnection' не […]
RabbitMQ вызывает функцию обратного вызова для потребителя, когда у него есть какое-то сообщение для него, или потребитель должен опросить клиента RabbitMQ? Итак, на стороне потребителя, если есть PHP-скрипт, RabbitMQ может вызвать его и передать ему сообщение / параметры. например, если рейтинг представлен на осколке 1, а таблица aggregateRating находится на осколке 2, тогда потребитель RabbitMQ […]
Я создал простого издателя и потребителя, который подписывается в очереди, используя basic.consume . Мой потребитель подтверждает сообщения, когда работа выполняется без исключения. Всякий раз, когда я сталкиваюсь с исключением, я не понимаю сообщение и возвращаюсь раньше. Из подтвержденных сообщений исчезают только сообщения с подтвержденными сообщениями, поэтому они работают правильно. Теперь я хочу, чтобы потребитель снова […]
Я хотел бы знать, как задержать Amqpphplib. Я использовал этот большой учебник по сценарию кофе: https://github.com/jamescarr/rabbitmq-scheduled-delivery но он не работает с PHP-amqplib. Сообщение истекает, как я хочу, но кажется, что «x-dead-letter-exchange» не выполняет эту работу. Я использовал консоль управления RabbitMQ, и я вижу все создание и удаление очереди в режиме реального времени. Но мое сообщение […]
Проблема: я хочу реализовать несколько php-рабочих процессов, которые прослушивают очередь MQ-сервера для асинхронных заданий. Проблема в том, что просто запуск этих процессов в качестве демонов на сервере не дает мне никакого контроля над экземплярами (Load, Status, locked) … кроме, возможно, для сброса ps-aux. Из-за этого я ищу среду выполнения, которая позволяет мне контролировать и контролировать […]