Вопросы по теме 'rabbitmq-exchange'

RabbitMQ объявляет Exchange из терминала - доступ запрещен: /api/exchanges/
Я использую rabbitmq для обработки сообщений между базами данных для корпоративного приложения, над которым я работаю. В рамках этого процесса я пытаюсь помочь автоматизировать настройку серверов (например, написать сценарий). В этом процессе я...
19482 просмотров

Что такое федеративный и альтернативный обмен в RabbitMQ
Я нашел две ссылки на этих биржах. https://www.rabbitmq.com/federated-exchanges.html и https://www.rabbitmq.com/ae.html , но не смог понять, что автор пытался сказать . Есть ли у кого-нибудь идея, связанная с этими двумя Exchange и еще одним...
666 просмотров
schedule 17.05.2023

Обмен заголовком RabbitMQ со списком
У меня возникли некоторые проблемы, пытаясь понять, как работает обмен типами headers . Только одна биржа, myExchange Три очереди: моя очередь1 моя очередь2 моя очередь3 Привязки: myExchange => myQueue1 (x-match: any,...
1610 просмотров

Rabbitmq Подтверждение нескольких потребителей
У меня есть очередь, в которой несколько потребителей работают в циклическом режиме. Delivery_tag используется для подтверждения сообщений после того, как потребитель завершит их обработку. Но несколько потребителей устанавливают одинаковые...
122 просмотров

Использование RabbitMQ — несколько производителей и несколько потребителей
Я хотел бы знать, возможно ли иметь несколько производителей и несколько потребителей? Например: -> Потребитель A получает сообщение только от производителя A -> Потребитель B получает сообщение только от производителя B Или мне нужно...
1049 просмотров
schedule 16.05.2023

Ключ маршрутизации RabbitMQ не маршрутизируется
я пытаюсь создать простую очередь сообщений с помощью RabitMQ, я отправляю сообщение с помощью create_message а затем пытается получить сообщение по ключу маршрутизации. он отлично работает, когда ключ маршрутизации тот же. проблема в том, что...
1199 просмотров

Уведомлять, когда биржа добавляется/удаляется из RabbitMQ?
Можно ли как-то получать уведомления о добавлении и удалении обменов из RabbitMQ? Я хотел бы иметь «клиента» на удаленной машине, который заинтересован в этом, желательно без использования опроса. Причиной этого может быть подписка на ВСЕ сообщения...
215 просмотров
schedule 08.06.2022

Потребитель RabbitMQ в Go
Я пытаюсь написать потребителя RabbitMQ в Go. Что предполагает брать 5 объектов за раз из очереди и обрабатывать их. Более того, предполагается, что в случае успешной обработки, иначе отправка в очередь недоставленных сообщений 5 раз, а затем...
5101 просмотров

Как вернуться к старому кластеру в rabbitmq в случае изменения системы или имени хоста?
Из-за некоторых проблем мы изменили имя сервера и после этого перезапустили сервер. Мы обнаружили, что служба rabbitmq остановлена, и мы запустили службу rabbitmq, но мы потеряли общие данные, связанные с rabbitmq, и похоже, что мы установили новый,...
90 просмотров
schedule 15.11.2022

RabbitMq: есть ли способ применить политику ко всем виртуальным хостам в среде кластера для зеркального отображения очереди?
В RabbitMQ, Если я хочу отразить очередь в среде кластера, я использую следующую команду: rabbitmqctl set_policy ha-all "" '{"ha-mode":"all","ha-sync-mode":"automatic"}' Эта команда применит политику ко всем очередям виртуального хоста...
4029 просмотров
schedule 21.04.2024

несколько очередей Rabbitmq с весенней загрузкой
Из руководства по весенней загрузке: https://spring.io/guides/gs/messaging-rabbitmq/ Они приводят пример создания 1 очереди и только 1 очереди, но что, если я хочу создать более 1 очереди? как это возможно? Очевидно, я не могу просто создать...
12418 просмотров

RabbitMQ задерживает загрузку и ресурсы подключаемого модуля обмена
Мы используем rabbitmq (3.6.6) для отправки анализа (миллионов) в разные анализаторы. Это очень быстро, и мы планировали использовать плагин rabbit-message для планирования мониторинга анализируемых элементов. Мы думали о плагине...
300 просмотров
schedule 26.04.2022

RabbitMQ: лопата для нескольких серверов из одной очереди на основе ключа маршрутизации сообщений
Мой сценарий: Мы используем RabbitMQ для широковещательной рассылки сообщений примерно 300 другим компьютерам в сети. Мы используем RabbitMQ на Windows Server, C#.Net Client (EasyNetQ) базовое решение состоит в том, чтобы назначить ключ...
1201 просмотров

сохранить порядок доставки после requeue
Я разрабатываю приложение для обмена сообщениями с использованием Rabbit MQ. Я использую явный ACK: model.BasicConsume(queueName,false, consumer); и сделайте ACK после обработки сообщения: consumer.Received += (ch, ea) =>...
611 просмотров

Отдельная очередь недоставленных сообщений для каждого получателя сообщений в RabbitMq
У меня есть сценарий публикации-подписки, созданный с использованием RabbitMQ. Существует обмен, при котором сообщения отправляются издателем, и любой потребитель, подписавшийся на этот обмен, получает эти сообщения в своих соответствующих очередях....
652 просмотров

Может ли повторное объявление очереди для каждого сообщения снизить производительность rabbitmq?
Может ли объявление очередей для каждого сообщения снизить производительность rabbitmq? У нас есть сценарий, в котором мы не знаем, существует очередь rabbitmq или нет. Так что объявление очереди для каждого сообщения - хороший подход? Или мы...
146 просмотров
schedule 16.03.2022

Как проверять и отслеживать журналы активности в RabbitMQ
Я хочу знать, есть ли способ получить подробные журналы действий, выполненных в кластере RabbitMQ. Действия включают: - Если я добавляю или удаляю привязку к Exchange, когда эти привязки были добавлены / удалены? Кто создал биндинги? Когда была...
834 просмотров

Spring boot rabbitmq без обмена 'xxxxxxx' в vhost '/'
Пишу простой производитель rabbitmq с пружинным ботинком 2.2.7. На стороне брокера я установил прямой обмен samples , очередь с именем samples.default и связал их вместе с добавлением samples.default ключа bindkey . при запуске...
850 просмотров

Как предотвратить удаление неподтвержденных сообщений RabbitMQ моим java-приложением при остановке программы?
Я написал проект Java, который использует RabbitMQ. Я запускаю свой проект Spring в режиме отладки с точкой останова в строке, которая говорит System.out.println(input); в ListenerExample.java . В другой части приложения я отправляю сообщение в...
71 просмотров