Популярные вопросы по тегу RABBITMQ
AMQP 0-9-1 против 1-0
... 5 технологии. Я вижу в спецификациях RabbitMQ, что 4 на данный момент предоставляется только 3 модель AMQP 0-9-1. Это шоу-стопор? Может 2 ...
RabbitMQ имеет ошибку Nodedown
... т, похоже, связан 48 с кластеризацией, которой у меня нет. Более 47 того, этот другой автор может обойти свою 46 проблему, перезапустив службу RabbitMQ; этот 45 подход мне не подходит. Моя проблема "nodedown" очевидна 44 в командной строке RabbitMQ: C: \ Program 43 Files (x86) \ RabbitMQ Server \ rabbitmq_ ...
Как работает балансировщик нагрузки в RabbitMQ
... дного узла rabbitMQ и создаем на нем 10 100 очередей. Теперь производители стали 9 отправлять сообщения быстрее. Чтобы справиться 8 с этой нагрузкой, мы добавляем дополнительные 7 узлы и создаем кластер. Но очереди существуют 6 только на первом узле. Как теперь балансируется 5 нагрузка между узлами? И если нам нужно 4 добавить больше очередей, на каком узле 3 мы должны их добавить? Или м ...
Сообщения с истечением срока действия не удаляются из RabbitMQ
... expiration, присвоенным значению. Затем 12 с помощью команды rabbitmqctl list_queues я отслеживаю статус сообщений. Я 11 обнаружил, что если я сначала отправляю 10 обычное сообщение, а затем сообщение с expiration, rabbitmqctl list_queues всегда 9 показывает мне 2 сообщения, ожидающих в 8 очереди. Когда я их ...
Как передать содержимое файла в Helm values.yaml
... /rabbitmq --name testrmq --namespace rmq -f rabbit-values.yaml rabbit-values.yaml: rabbitmq: plugins: "rabbitmq_management rabbitmq_federation rabbitmq_federation_management rabbitmq_shovel rabbitmq_shovel_management rabbitmq_mqtt rabbitmq_web_stomp rabbitmq_peer_discovery_k8s" advancedConfiguration: |- {{ .Files.Get "rabbitmq.config" | quote}} И 1 что я получаю за advancedConfiguratio ...
RabbitMQ: Как указать очередь для публикации?
... RabbitMQ Channel#basicConsume дает нам следующие аргументы: channel.basicConsume(queueName, autoAck, consumerTag, noLocal, exclusive, arguments, callback); Это 5 дает нам возможность сообщить RabbitMQ, из 4 ка ...
Spring amqp: как я могу прочитать MessageProperties в MessageListenerAdapter
... ge MessageListenerAdapter? public class EventMessageAdapter { public void handleMessage(MessageProperties messageProperties, Event event) { ... String id = ...
RabbitMQ использует немедленные и обязательные биты
... установил для поля немедленное значение 12 true и попытался отправить 50 000 сообщений. Используя 11 rabbitmqctl list_queues, я увидел, что количество сообщений в очереди 10 ноль . Затем я изменил флаг немедленно на false и снова попытался 9 отправить 50 000 сообщений. Используя rabbitmqctl list_queues, я 8 увидел, что в общей сложности 100 000 сообщений 7 находятся в ...
Какую форму подключения использовать с pika
... этими двумя (т.е. что 10 такое блокировка BlockingConnection? и т. д.) В 9 документации для pika говорится, что SelectConnection является 8 предпочтительным способом подключения к 7 rabbit, поскольку он предоставляет «несколько 6 методов уведомления о событиях, включая 5 select, epoll, kqueue и ...
Подключение к серверу Rabbitmq внезапно закрывается
... ыглядит следующим образом: =INFO REPORT==== 19-Dec-2012::06:25:44 === accepted TCP connection on [::]:5672 from <host>:42048 =INFO REPORT==== 19-Dec-2012::06:25:44 === starting TCP connection <0.357.0> from <host>:42048 =WARNING REPORT==== 19-Dec-2012::06:25:44 === exception on TCP connection <0.357.0> from <host>:42048 connection_closed_abruptly = ...
Удаление всех незавершенных задач в celery / rabbitmq
... оженные задачи, не зная 1 tas ...
Pika + RabbitMQ: установка для basic_qos значения prefetch = 1 по-прежнему потребляет все сообщения в очереди
... ery_tag = method.delivery_tag) if __name__ == '__main__': for i in range(worker_count): worker = multiprocessing.Process(target=mqworker) worker.start() У меня проблема заключается в том, что, несмотря 10 на настройку basic_qos на канале, первый 9 запущенный рабочий процесс принимает все 8 сообщения из очереди, в то время как остальные 7 сидят там без дела. Я в ...
Практические примеры использования идентификатора корреляции в обмене сообщениями?
... того, как в производственной среде можно 14 использовать идентификатор корреляции? Я 13 читал, что он используется в сообщениях 12 типа запрос / ответ, но я не понимаю, где 11 бы я его использовал? Один пример (который 10 может быть неправильным), который я могу 9 придумать, - это сценарий публикации с подпиской, где 8 у меня может быть 5 подписчиков, и если 7 я получу 5 ответов с одинаковым идентификатором 6 корреляции, я ...
Сценарии, где использовать какой тип обмена (прямой, разветвленный, тема, заголовки) в RabbitMQ?
... кие сценарии использования 2 различных типов обме ...
Используя RabbitMQ, есть ли способ просмотреть содержимое очереди без операции удаления из очереди?
... олучать фактические 11 сообщения, чтобы я мог показать, какой фильм 10 или телешоу еще ожидает кодирования. Идея 9 состоит в том, что диспетчер очередей будет 8 получать сообщения от клиентов кодировщика 7 после завершения задания, а затем обновлять 6 список очереди. Я знаю, что существует запутанный 5 способ синхронизировать список диспетчера 4 очередей с фактической рабочей очередью, но 3 я бы хотел, ч ...
RabbitMQ против Socket.io?
... ьзователи браузера должны 10 иметь возможность общаться друг с другом 9 через сервер node.js. Один из пользователей 8 пишет сообщение, и все остальные пользователи 7 его получат. Я не совсем понимаю, как работает 6 RabbitMQ. Но при быстром чтении кажется, что 5 он обрабатывает публикацию / подписку на 4 сообщения. Пользователь (в браузере) что-то 3 публикует, и подписчики (в других браузерах) получают 2 это сообщение. Разве ...
Разница между потоковой обработкой и обработкой сообщений
... обработки, но по сути kafka - это 5 среда обмена сообщениями, похожая на ActivMQ, RabbitMQ 4 и т. Д. Почему мы обычно не говорим, что 3 ActiveMQ хорош и для потоковой обработки. Скорость, с 2 которой сообщения потребляются, опреде ...
Как включить статистику в пользовательском интерфейсе управления RabbitMQ
... /rabbitmq/rabbitmq.conf 6 довольно прост: loopback_users.guest = false listeners.tcp.default = 5672 management.tcp.port = 15672 management.disable_stats = false Я могу получить доступ к ...
RabbitMQ использует настраиваемые заголовки для хранения параметров сообщения
... овую 11 службу, которая слушает очередь, но я несколько 10 застрял в том, где мне следует поместить 9 параметры, которые имеет моя служба (пункт 8 назначения, тема, .. .) Должен ли я помещать 7 их в какой-то закодированный формат (json), внутри 6 моих сообщений или использовать конструкцию 5 заголовка, как в следующем примере: string message = "Hel ...
Как запросить сообщения в RabbitMQ
... оверка 5 не удается, мы хотим, чтобы сообщение было 4 возвращено в очередь, из которой оно было 3 изначально получено. Я прочитал документацию 2 RabbitMQ. Но меня смущает разница м ...
Какой вариант больше подходит для микросервиса? GRPC или брокеры сообщений, такие как RabbitMQ
... о RabbitMQ 3 и обмене сообщениями NATS а также GRPC Какой 2 вариант больше подходит для микросервиса? и 1 почему? Заранее сп ...
RabbitMQ - получить общее количество сообщений в очереди
... rabbitAdmin; .......... DeclareOk declareOk = rabbitAdmin.getRabbitTemplate().execute(new ChannelCallback<DeclareOk>() { public DeclareOk doInRabbit(Channel channel) throws Exception { return channel.queueDeclarePassive("test.pending"); } }); return declareOk.getMessageCount(); Я 2 хочу получить дополнительные ...
NestJS - объедините HTTP с RabbitMQ в микросервисах
... икации и маршрутизации в систему. Сервисы, стоящие 20 за шлюзом, в основном представляют собой 19 простые CRUD-сервисы. Каждая служба предоставляет 18 свой собственный API, и они синхронно обмениваются 17 данными через HTTP. Все эти службы, включая 16 API-Gateway, являются приложениями NestJS 15 по умолчанию. Давайте возьмем пример с кошками. Всякий 14 раз, когда Cat-Serv ...
RabbitMQ и круговой обмен темами
... иклическим перебором передавался 12 в каждую очередь потребителей по «той же» теме, например, *.log. Я 11 пробовал несколько комбинаций и, похоже, могу 10 одновременно доставлять сообщения в очереди 9 потребителей, что фактически означает, что 8 я обрабатываю сообщение дважды, по одному 7 разу для каждого потребителя. Для ясности 6 у меня также есть разветвленная биржа, которую 5 я исп ...
Ответ об ошибке от демона: не удается остановить контейнер - процесс инициализации сигнализирует о том, что в разрешении отказано
... nt: Version: 18.06.0-ce API version: 1.38 Go version: go1.10.3 Git commit: 0ffa825 Built: Wed Jul 18 19:09:54 2018 OS/Arch: linux/amd64 Experimental: false Server: Engine: Version: 18.06.0-ce API version: 1.38 (minimum version 1.12) Go version: go1.10.3 Git commit: ...
Как направить цепочку задач в определенную очередь в сельдерее?
... ueue='beetroot') Но если я создам цепочку: chain = task | task А 6 потом я пишу chain.apply_async(queue='beetroot') Похоже, что ключевое слово очереди 5 игнорируется и на ...
Какие языковые и продуктовые альтернативы Akka?
... бы вы рассказать мне, какие есть альтернативы 4 на других языках или в других продуктах? Чем 3 отличается RabbitMQ от этого? Много ли совпадени ...
Ошибка пути при запуске rabbitmq-server
... ,"init.erl"},{line,1053}]},{init,start_em,1[{file,"init.erl"},{line,1034}]}]}} init terminating in do_boot () C:\rabbitmq-server-3.6.0\scripts>rabbitmq-server realpath' is not recognized as an internal or external command, operable program or batch file. {"init terminating in do_boot",{undef,[{rabbit_prelaunch,start,[],[]},{init,start_it,1,[{file,"init.erl"},{line,1053}]},{init,start_em,1[{file,"init.erl"},{line,1034}]}]}} Crash dump ...
Есть ли способ ограничить количество потребителей в очереди RabbitMQ?
... . Это 15 не проблема как таковая, но мы рискуем случайно 14 запустить второго потребителя в очереди, что 13 было бы плохо. Там много очередей и много 12 серверов приложений, и нам потребуется всего 11 лишь небольшая опечатка, чтобы оказаться 10 в такой ситуации. Прежде чем я потрачу время 9 на изменение программного об ...
Поддержка асинхронного режима RabbitMQ
... контекст, это 2 пример того, как я работаю с RabbitMQ в 1 данный момент (код взят из моего блога): var factory = new ConnectionFactory() { HostName = "localhost" }; using (var connection = factory.CreateConnection()) { using (var channel = connection.CreateModel()) { channel.QueueDeclare("testqueue", true, false, false, null); var consumer = new EventingBasicConsumer(channel); consumer. ...
RabbitMQ точка-точка или pub-sub
... л конфигурации, и все 4 они, похоже, поддерживают модель точка-точка, а 3 не pub-sub. то есть сообщение удаляется 2 из очереди после использования и недоступн ...
RabbitMQ как задушить потребителя
... есть проблема, когда, если я попадаю в ситуацию, когда 14 в очереди много сообщений, то потребитель 13 (служба Windows) пытается получить их все, а 12 затем просто удерживает их, но никогда не 11 предпринимает действий и не подтверждает 10 их. Когда количество сообщений в состоянии 9 готовности низкое, потребители справляются 8 со снижением пропускной способ ...
В чем разница между assertQueue и отправкой в очередь в RabbitMq
... t('amqp://localhost', function(err, conn) { //amqp://localhost conn.createChannel(function(err, ch) { var q = 'hello'; ch.assertQueue(q, {durable: false}); console.log(" [*] Waiting for messages in %s. To exit press CTRL+C", q); ch.consume(q, function(msg) { console.log(" [x] Received %s", msg.content.toString()); }, ...
rabbitmq несколько потребителей в очереди - только один получает сообщение
... бщения из одной очереди, я делаю 13 это, используя что-то похожее на this example, за исключением 12 того, что я использую basic.get в бесконечном 11 цикле для опроса. Есть идеи, как предотвратить 10 скачки между всеми потребителями, когда 9 только один потребитель получит сообщение, а 8 другой будет п ...
Запланированный / отложенный обмен сообщениями в Spring AMQP RabbitMq
... сил пытаюсь найти способ для 13 запланированных / отложенных сообщений в 12 Spring AMQP / Rabbit MQ. После адских поисков 11 я все еще не могу сделать это в Spring AMQP. Может 10 ли кто-нибудь рассказать мне, как сделать 9 x-delay в Spring AMQP. ...
RabbitMQ "Что такое сообщения" Готовые "и" Неупакованные "?
... общений в RabbitMQ. Я 6 видел, что в некоторых из моих очередей 5 есть 0 сообщений "Без упаковки" и 1000 сообщений 4 "Готово", а в некоторых - 1000 сообщений 3 "Без упаковки" и 0 сообщений "Гото ...
RabbitMQ использует одно сообщение, если существует, и завершает работу.
... есть ли возможность просто проверить, есть 8 ли сообщение, и если его нет, просто прекратите 7 прослушивание? Как мне изменить базовый 6 пример «Hello world» для такой задачи? В 5 настоящее время мне удается прекратить потребление, если 4 я получаю сообщение, но если сообщений нет, мой 3 метод receive() просто продолжает ждать. Как 2 заставить его не ждать, если сообщений нет? Или, может 1 быть, подождать только опр ...
RabbitMQ undefined: нет шаблона в js / tmpl / login.ejs
... 5 к RabbitMQ, он отображает только это на 4 экране: undefined: в js / tmpl / login.ejs 3 нет шабл ...
Как обрабатывать ошибки с помощью EasyNetQ / RabbitMQ
... Q на C# с библиотекой 3 EasyNetQ. Я использую здесь шаблон pub / sub. У 2 меня все еще есть несколько проблем, с которыми, надеюсь, кто-нибудь 1 сможет мне помочь: Если при использовании сообщения возникает ошибка, оно автоматически перемещается в очередь ошибок. Как я могу реализовать повторные попытки (чтобы он снова помещался в исходную очередь ...
Подключение к контейнеру RabbitMQ с помощью docker-compose
... er_1 worker_1 | dial tcp 127.0.0.1:5672: connect: connection refused ci_worker_1 exited with code 1 Мне это инт ...
Что MassTransit добавляет в RabbitMQ?
... едственно 8 поверх RabbitMQ? Я считаю, что одним из преимуществ 7 MassTransit является обмен «типом» (публикация, подписка 6 по интерфейсу / типу), поэтому содержимое 5 сообщения структури ...
Чтение из нескольких очередей, RabbitMQ
... .time); System.Console.WriteLine(" Value: {0}", m.value); } System.Console.WriteLine("Another queue name to subscribe to: "); string QueueName2 = (System.Console.ReadLine()).ToString(); obj1.subscribeToQueue( ...
Redis Pub / Sub против Rabbit MQ
... в. В настоящее время мы используем 10 Redis Pub / Sub в качестве брокера сообщений 9 для некоторых устаревших частей нашей системы. Мои 8 коллеги считают, что использование Redis 7 в качестве служебной шины является естествен ...
Увеличьте пропускную способность с RabbitMQ
... ите. Итак, вопрос: Чтобы 10 получить максимальную пропускную способность 9 / производительность при передаче сообщений 8 (например, 400 000 сообщений в секунду), сколько 7 очередей лучше всего? Означает ли это увеличение 6 количества очередей лучшую пропускную способнос ...
Ошибка epmd для хоста myhost: адрес (не удается подключиться к хосту / порту) в Windows 10
... ntacted. --offline - do not try to contact broker. C:\Program Files (x86)\RabbitMQ Server\rabbitmq_server-3.5.6\sbin>rabbitmq-server restart ERROR: epmd error for host INLN50899724A: address (cannot connect to host/port) Нажмите ниже, чтобы увидеть изображение 1 с ошибкой. Error ...
Не удается включить плагин rabbitmq-management в Windows
... Я выполнил следующие шаги: apt-get install pkg-config automake autoconf libsigc++-2.0-dev git clone git://github.com/alanxz/rabbitmq-c.git cd rabbitmq-c # Enable and update the codegen git submodule git submodule init git submodule upd ...
Ошибка RabbitMQ в файле конфигурации "/etc/rabbitmq/rabbitmq.config": синтаксическая ошибка до: ']'
... efault user is configured, or you have configured use SSL client %% certificate based authentication, you can choose to allow clients to %% omit the CONNECT frame entirely. If set to true, the client is %% automatically connected as the default user or user supplied in the %% SSL certificate whenever the first frame sent on a session is not a %% CONNECT frame ...
Есть ли хорошие альтернативы RabbitMQ для бюджетных установок?
... ство использования, трудно оправдать 12 использование MQ для решения, которое обрабатывает 11 всего пару тысяч сообщений в день, просто 10 потому, что поддержка RabbitMQ - это очень 9 много работы. Кто-нибудь знает реализацию 8 AMQP с простым процессом установки и обслуживания? Для 7 тех, кто этого не знает, RabbitMQ - это 6 реализация AMQP, написанная на Erlang. Предполагается, что 5 он будет очень стабильным, но это действительно 4 так, ...
Отложенное сообщение в RabbitMQ
... чу 3 завершить сеанс клиента через 30 минут и 2 отправляю соо ...
RabbitMQ / AMQP - Очередь передового опыта / Тематический дизайн в архитектуре MicroService
... er.deleted") public void handleEvent(UserDeletedEvent event){... Не 13 лучше ли иметь что-то вроде «user-service-notifications» в 12 качестве одной очереди, а затем отправлять все 11 уведомления в эту очередь? Я все еще хотел 10 бы регистрировать слушателей только для 9 подмножества всех событий, так как это решить? Мой 8 второй вопрос: если я хочу прослушивать 7 очередь, которая не была создана раньше, я 6 получу исключение в Rabbit ...
