RabbitMQ- все статьи тега
Asyncio и rabbitmq (asynqp): как потреблять из нескольких очередей одновременно
Я пытаюсь использовать несколько очередей одновременно, используя python, asyncio и asynqp. Я не понимаю, почему мой вызов функции asyncio.sleep() не имеет никакого эффекта. Код на этом не останавливается. Честно говоря, я на самом деле не понимаю, в каком контексте выполняется обратный вызов, и могу ли я вообще передать управление bavck циклу событий (так что вызов asyncio.sleep() будет иметь смысл). Что, если бы мне пришлось использовать вызов функции aiohttp.ClientSession.get() в моей функ ...
Использование rabbitmq с twisted
Я разрабатываю tcp / ip сервер, цель которого-принимать пакеты от клиента, анализировать их, делать некоторые вычисления(по данным, поступающим в пакет) и хранить их в базе данных. До сих пор все делалось с помощью одного серверного приложения, написанного с использованием twisted python. Теперь я нахожусь через RabbitMQ, поэтому мой вопрос заключается в том, возможно ли это и приведет ли это к лучшей производительности, если мое приложение twisted server просто получает пакеты от клиентов и пер ...
Существует ли способ отладки RabbitMQ Consumer (php-ampqlib) с помощью PhpStorm и Xdebug?
Вот моя настройка dev: IDE: PhpStorm 9.0.2отладчик: Xdebug 2.3.3сервер очереди сообщений: RabbitMQ 3.5.6PHP Lib для подключения к серверу RabbitMQ: php-ampqlib Для запуска моего потребителя я использую задачу CakePHP и выполняю ее следующим образом: ../lib / Cake / Console/cake cron message_trigger_consumer Когда я выполняю эту команду, мой потребитель встает и ждет сообщения, которое придет от производитель (например: кнопка сохранить форму, которая отправляет электронное письмо ...
Проблема подключения RabbitMQ C# при использовании имени пользователя и пароля
Я здесь в растерянности, поэтому я обращаюсь к коллективному знанию в надежде на чудо. Я установил RabbitMQ на Linux box, используя значения по умолчанию. Когда я использую этот код (и конфигурацию установки RabbitMQ по умолчанию), все работает хорошо. var connectionFactory = new ConnectionFactory(); connectionFactory.HostName = "192.168.0.12"; IConnection connection = connectionFactory.CreateConnection(); Но когда я добавляю пользователя в RabbitMQ и пытаюсь использовать следующий код (имя ...
Удалить все очереди из RabbitMQ?
Я установил rabbitmqadmin и смог перечислить все биржи и очереди. Как я могу использовать rabbitmqadmin или rabbitmqctl для удаления всех очередей. ...
Удаление всех отложенных задач в celery / rabbitmq
Как я могу удалить все отложенные задачи, не зная task_id для каждой задачи? ...
Проверьте версию в RabbitMQ
Как я могу проверить, какая версия rabbitmq работает на сервере? есть ли команда, чтобы проверить, что rabbitmq работает? ...
RabbitMQ и связь между каналом и соединением
The RabbitMQ Java client имеет следующие понятия: Connection - подключение к экземпляру сервера RabbitMQ Channel -??? пул потоков потребителя-пул потоков, которые потребляют сообщения от очередей сервера RabbitMQ Queue-структура, которая содержит сообщения в порядке FIFO Я пытаюсь понять связь, и что еще более важно, ассоциации между ними. Я все еще не совсем уверен, что a Channel это, кроме того, что это структура, которую вы публикуете и потребляете, и что она создается из открытого сое ...
Какие порты использует RabbitMQ?
какие порты использует RabbitMQ Server или должны быть открыты в брандмауэре для кластера узлов? мой /usr/lib/rabbitmq/bin/rabbitmq-env устанавливается ниже, которые я предполагаю, необходимы (35197). SERVER_ERL_ARGS="+K true +A30 +P 1048576 -kernel inet_default_connect_options [{nodelay,true}] -kernel inet_dist_listen_min 35197 -kernel inet_dist_listen_max 35197" Я не трогал rabbitmq.config установить tcp_listener поэтому он должен слушать по умолчанию 5672. вот соответствующ ...
JMS и AMQP-RabbitMQ
Я пытаюсь понять, что такое JMS и как это связано с терминологией AMQP. Я знаю, что JMS-это API, а AMQP-протокол. вот мои предположения (а также вопросы) RabbitMQ использует протокол AMQP (скорее реализует протокол AMQP) клиенты Java должны использовать клиентские библиотеки протокола AMQP для подключения / использования RabbitMQ где JMS API вступает в игру здесь? JMS API должен использовать клиентские библиотеки AMQP для подключения чтобы в RabbitMQ? обычно мы используем JMS для подключения ...
RabbitMQ / AMQP: одна очередь, несколько потребителей для одного сообщения?
Я только начинаю использовать RabbitMQ и AMQP в целом. у меня есть очередь сообщений у меня есть несколько потребителей, которые я хотел бы сделать разные вещи с тот же. большая часть документации RabbitMQ, по-видимому, ориентирована на циклический перебор, т. е. когда одно сообщение потребляется одним потребителем, а нагрузка распределяется между каждым потребителем. Это действительно то поведение, которое я наблюдаю. пример: производитель имеет одну очередь, и отправлять сообщения кажды ...
Размер и типы сообщений RabbitMQ
какие сообщения могут храниться в очередях RabbitMQ? Только струны? Или я могу выбрать, какой тип я хочу сохранить: int, binary, string и т. д.? каков максимальный размер одного сообщения? сколько очередей или обменов может быть создано? Или это зависит от мощности сервера? ...
Как установить плагин управления rabbitmq (rabbitmq-plugins)
Краткая: Есть ли способ установить RabbitMQ-плагины через пакет ubuntu? детали: У меня rabbitmq работает нормально в моей системе ubuntu, и теперь я пытаюсь отслеживать, что происходит с помощью плагина управления. Я следую rabbitmq.com/management.html инструкции, но не может выполнить rabbitmq-plugins enable rabbitmq_management потому что моя система не имеет rabbitmq-Плагины установлены. Это Ubuntu 1110, и поставляется с rabbitmq установлен в качестве пакета (aptitude install rabbitmq-se ...
Работа в PHP по протоколу Stomp
В последнее время все более активно продвигается идея построения событийно-ориентированной архитектуры программного обеспечения. Такая архитектура предполагает, что её компоненты - отдельные сервисы, общаются между собой путем отправки асинхронных событий через общую шину ESB. Событие – это сообщение (напри ...