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

Обмен привязкой Rabbitmq к обмену
Я ищу способ защитить систему обмена сообщениями на моем веб-сайте, чтобы пользователи получали только те данные, к которым у них должен быть доступ. Имея это в виду, я подумал о системе, в которой у меня есть главный обмен темами, на который мой...
4741 просмотров

RabbitMQ, обмен темами
У меня есть обмен темами на моем RabbitMQ. Ошибка при отправке сообщения. EXCHANGE_NAME = "EX_TEST"; Раздел получения: ConnectionFactory connectionFactory = new ConnectionFactory(); connectionFactory.setHost(mServer); mConnection =...
1439 просмотров
schedule 09.06.2023

RabbitMQ PHP для динамического обновления сообщений
Я изучаю RabbitMQ и думал об использовании его для предоставления пользователям обновлений «динамических сообщений», очень похоже на то, как facebook дает динамические ленты от друзей. Моя идея была: Каждый раз, когда создается...
580 просмотров

Чтобы использовать очередь rabbitmq, мне действительно нужно объявлять обмен и очередь?
Во всех примерах, которые я нахожу в Интернете, я вижу, что обмен и очередь объявляются до того, как сообщения будут использованы. Объявление обмена кажется странным, потому что зачем мне это делать? Я использую очередь, которая может быть связана с...
965 просмотров
schedule 15.12.2022

Цель объявления обмена на потребителе RabbitMQ
У меня есть потребительское приложение Java, которое подключается к неудаляемому разветвленному обмену RabbitMQ (3.2.4) под названием «my_exhange_foo»: Connection connection = connectionFactory.newConnection(consumerPool); Channel channel =...
166 просмотров
schedule 13.04.2023

RabbitMQ создает временную очередь, но не знает, как и когда
Я использую Mule ESB с двумя приложениями (одно публикует статус другому через rabbitMQ). ТОЛЬКО в моей производственной среде эти очереди amqp.gen- появляются, но они заблокированы, и я не вижу, что внутри них. Они привязаны к моей бирже...
1014 просмотров
schedule 06.08.2022

RabbitMQ: Как удалить / переместить сообщения в очереди из curl
У меня несколько серверов RabbitMQ. Мне нужен интерфейс (с JSP), где я могу управлять (удалять очереди / обмены / сообщения) всеми этими серверами. Внутри я буду вызывать команды curl для выполнения операций. Пример: создать очередь curl...
2638 просмотров

Как прервать код при публикации сообщения в несуществующей очереди в rabbitmq
Я написал приложение сервер-клиент. На стороне сервера сервер инициализирует очередь queue1 с ключом маршрутизации key1 при прямом обмене . После инициализации и объявления он потребляет данные всякий раз, когда кто-то пишет на них....
2057 просмотров
schedule 17.01.2023

Причины не использовать обмен по умолчанию на RabbitMQ?
Я начал работать с RabbitMQ, и мой вариант использования довольно прост - производители помещают сообщения в очереди для обработки потребителями. Каждое сообщение обрабатывается не более чем одним потребителем, и сообщения направляются от...
726 просмотров
schedule 12.03.2022

RabbitMQ, как удалить сообщение после n попытки повторной постановки в очередь
Я пытаюсь создать своего рода асинхронный сервер, используя RabbitMQ вместе с JAVA. У меня две биржи Original_Exch и Dead_Exch, и в каждой по одной очереди. Оба обмена объявлены DLX (обмен недоставленными сообщениями очереди друг друга). Теперь...
678 просмотров
schedule 22.10.2022

Как получить доступ к каналам/очередям, открытым в сеансе Bunny?
Я использую Ruby-клиент Rabbit MQ (Bunny). Я переместил конфиг Bunny и процесс инициализации в файл initializer. Как я могу получить доступ к каналам/очередям, открытым в соединении Bunny, изнутри контроллера или библиотеки? Я получаю...
718 просмотров

Сообщения Rabbit mQ перемещаются из очереди готовности в очередь распаковки
У меня есть отдельный издатель и потребитель. Я запускаю издателя и публикую сообщения. Теперь я запускаю потребителя, и проблема в том, что сообщения перемещаются из очереди готовности в очередь распаковки, помечая сообщения как повторно...
793 просмотров

Как настроить MassTransit в ненадежной сетевой среде?
Я пытаюсь разобраться с MassTransit в сочетании с RabbitMQ. Основные концепции работают в тестовом проекте, но мне нужно следующее: В моей системе будет один или несколько серверов, которые реагируют на события реальной жизни (телефония). Эти...
175 просмотров

Как опубликовать Json с помощью команды rabbitmqadmin
Я хочу опубликовать сообщение Json с помощью командной строки rabbitmqadmin. Как мы можем это сделать, как я читал, мы можем отправлять только строковые сообщения в полезной нагрузке, как показано ниже Rabbitmqadmin publish exchange = default...
3643 просмотров

Подключение Java-клиента RabbitMQ к нескольким очередям
Я использую amqp-client-4.0.2. У меня есть один обмен темами, который направляет сообщения в несколько очередей. Очереди названы в соглашении x.x.x.x. Мой Java-клиент должен иметь возможность потреблять сообщения из нескольких очередей. Я хотел бы...
140 просмотров

MassTransit использует сообщение, отличное от MassTransit
У меня есть консольное приложение, которое публикует сообщения для обмена RabbitMQ. Может ли подписчик, созданный с помощью MassTransit, использовать это сообщение? Это код издателя: public virtual void Send(LogEntryMessage message) {...
1442 просмотров
schedule 12.05.2023

RabbitMq Прямой ответ, также известный как Fast Rpc с 2 серверами
Можно ли настроить 2 сервера Rmq для использования прямого ответить на через них? e.g. RpcClient подключается к серверу 1 и вызывает RpcServer, который подключен к серверу 2. Можно ли перелопатить/объединить псевдо-очередь...
289 просмотров

RabbitMQ Machine Restart все обмены, очереди, виртуальный хост исчезли
Вчера мы применили исправление уязвимости к нашему блоку контроля качества, и машина была перезагружена. Это означало, что сервер RabbitMQ и служба также не работали. Когда мы запустили службу сегодня утром, я зарегистрировал ее. Он потерял все...
435 просмотров
schedule 19.08.2022

Как отслеживать события жизненного цикла обмена RabbitMQ
Я работаю с набором продуктов, который использует RabbitMQ в качестве серверной части для обмена сообщениями служебной шины. Многие клиенты используют программное обеспечение (NeuronESB), которое должно автоматически настраивать обмены, очереди и...
716 просмотров
schedule 29.03.2023

Перегрузка потребителя RabbitMQ
Я читал о принципах обмена сообщениями AMQP. ( https://www.rabbitmq.com/confirms.html ). Действительно полезная и хорошо написанная статья, но одна конкретная вещь о признании потребителей действительно сбивает с толку, вот цитата: Еще...
1415 просмотров