RabbitMQ - это брокер сообщений с открытым исходным кодом, первоначально реализующий протокол AMQP с дополнительными протоколами обмена сообщениями, поддерживаемыми через архитектуру подключаемых модулей. Этот тег следует использовать с вопросами, касающимися продукта брокера сообщений сервера RabbitMQ, или с вопросами, касающимися исходного кода и реализации продукта RabbitMQ. Определенный тег протокола, такой как amqp или mqtt, также может быть подходящим, как и используемая ОС и язык программирования.
В настоящее время этот вопрос не очень подходит для нашего формата вопросов и ответов. Мы ожидаем, что ответы будут подтверждены фактами, ссылками или опытом, но этот вопрос, скорее всего, вызовет дебаты, споры, опрос или расширенное обсуждение. Если вы считаете, что этот вопрос можно улучшить и,...
Меня попросили оценить RabbitMQ вместо Kafka, но мне было трудно найти причину, по которой он делает что-то лучше, чем Kafka. Кто-нибудь знает, действительно ли он лучше по пропускной способности, долговечности, задержке или простоте...
Я новичок в брокерах сообщений, таких как RabbitMQ, которые мы можем использовать для создания задач / очередей сообщений для системы планирования, такой как Celery . Теперь вот вопрос: Я могу создать таблицу в PostgreSQL, к которой можно добавлять новые задачи и использовать такую...
Я установил последний сервер RabbitMQ (rabbitmq-server-3.3.0-1.noarch.rpm) на свежую виртуальную машину Centos 5.10 в соответствии с инструкциями на официальном сайте. Я делал это много раз во время разработки, и у меня никогда не было проблем. Однако на этот раз я не могу войти в веб-интерфейс...
Как я могу удалить все отложенные задачи, не зная task_idдля каждой
Я установил rabbitmqadminи смог перечислить все биржи и очереди. Как я могу использовать rabbitmqadminили rabbitmqctlудалить все очереди.
Клиент RabbitMQ Java имеет следующие понятия: Connection - соединение с экземпляром сервера RabbitMQ Channel - ??? Пул потребительских потоков - пул потоков, которые принимают сообщения из очередей сервера RabbitMQ Очередь - структура, которая содержит сообщения в порядке FIFO Я пытаюсь понять...
Я только начинаю использовать RabbitMQ и AMQP в целом. У меня очередь сообщений У меня несколько потребителей, которым я хотел бы делать разные вещи с одним и тем же сообщением . Большая часть документации RabbitMQ, по-видимому, ориентирована на циклический перебор, то есть когда отдельное...
Как я могу проверить, какая версия rabbitmq работает на сервере? Есть ли команда для проверки работоспособности
Как удалить все сообщения из одной очереди, используя cli? У меня есть имя очереди, и я хочу его
Какие порты использует или должен открыть 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...
Я пытаюсь понять, что такое JMS и как это связано с терминологией AMQP. Я знаю, что JMS - это API, а AMQP - это протокол. Вот мои предположения (и вопросы тоже) RabbitMQ использует протокол AMQP (скорее реализует протокол AMQP) Клиенты Java должны использовать клиентские библиотеки протокола AMQP...
Можно ли просматривать содержимое сообщения RabbitMQ непосредственно из командной строки? sudo rabbitmqctl list_queues перечисляет очереди. Есть какая-нибудь команда вроде sudo rabbitmqctl list_queue_messages <queue_name>?...
Какие сообщения можно хранить в очередях RabbitMQ? Только струны? Или я могу выбрать тип, который я хочу сохранить: int, binary, string и т. Д.? Каков максимальный размер одного сообщения? Сколько очередей или обменов можно создать? Или это зависит от мощности сервера?...
Я получаю исключение ниже org.springframework.amqp.AmqpAuthenticationException: com.rabbitmq.client.AuthenticationFailureException: ACCESS_REFUSED - в входе было отказано с использованием механизма аутентификации PLAIN. Подробнее см. Файл журнала брокера. Конфигурация: RabbitMQ 3.3.5 для windows В...
У меня есть несколько очередей с RabbitMQ. Некоторые из них сейчас бесполезны, как их удалить? К сожалению, я не выбрал auto_deleteопцию. Если я установлю сейчас, он будет удален? Есть ли способ удалить эти очереди сейчас?...
Мы определяем архитектуру для сбора информации журналов поставщиками Logstash, которые установлены на различных машинах, и централизованно индексируют данные на одном сервере elasticsearch и используют Kibana в качестве графического слоя. Нам нужна надежная система обмена сообщениями между...
Мне нужно создать очередь на обработку. Сама очередь имеет относительно небольшой объем. В него может быть записано около 1000 записей в час. Выполнение каждой задачи может занять около минуты каждая и обрабатываются почти сразу после добавления элемента в очередь. Есть ли причина, по которой я...
Используя rabbitmq, мы можем установить плагин управления. Затем мы получаем доступ через браузер, http://localhost:55672/используя guest: guest. Проблема в том, что я больше не могу войти в систему, потому что я сменил пароль и ввел пустое поле для роли. Есть ли способ сбросить пользователя для...