Описание тега rabbitmq
RabbitMQ is an open-source message broker originally implementing the AMQP protocol with additional messaging protocols supported via a plug-in architecture. This tag should be used with questions involving the RabbitMQ server message broker product or questions concerning the source code and implementation of the RabbitMQ product. A specific protocol tag such as amqp or mqtt may also be appropriate as well as the OS and programming language being used.
1
ответ
Проверка подлинности на основе ключа Rabbitmq
Предыстория: я очень новичок в RabbitMq, я просто установил его и попытался поиграть с ним. Итак, у меня есть RabbitMq, работающий на ec2(ubuntu), и сервер node.js в качестве клиента RabbitMq, работающий на локальной машине (для публикации / подписк…
01 мар '13 в 08:19
1
ответ
RabbitMQ для имитации обмена темами с прямым обменом
Есть ли способ, которым я могу иметь прямой обмен, имитирующий обмен темами (я знаю, что можно получить противоположное: см. Здесь), но мой пример использования здесь заключается в том, что я уже развернул прямой обмен с большим количеством очередей…
23 мар '11 в 10:43
1
ответ
Как заставить очередь Rabbit MQ работать в режиме хранения и пересылки?
Я экспериментирую с Rabbit MQ, используя клиент Python Pika. Я хотел бы, чтобы мой отправитель AMQP работал в режиме хранения и пересылки, т. Е. Иметь возможность начинать очередь сообщений, если сервер или сеть не работает, и надежно доставлять их …
17 авг '14 в 02:21
1
ответ
Каково ожидаемое поведение, когда в долговременной очереди RabbitMQ заканчивается ОЗУ?
Мое понимание долговременных очередей RabbitMQ (т. Е. Delivery_mode = 2) состоит в том, что они работают в ОЗУ, но сообщения сбрасываются на диск, чтобы их можно было восстановить в случае перезапуска процесса или перезагрузки компьютера. Однако мне…
22 авг '12 в 00:15
1
ответ
Celery: подключайтесь к удаленному брокеру, чтобы делиться задачами
У меня много трудоемких задач, которые нужно разделить на несколько машин. В настоящее время у меня есть одна мастер-машина, использующая работников Celery для выполнения этой задачи Я использую RabbitMQ в качестве посредника и Redis в качестве бэкэ…
16 июл '15 в 18:06
1
ответ
Объявление очереди на всех узлах в RabbitMQ
У меня есть установка кластера Rabbitmq (без HA). Мои потребители - это пружинные приложения, и он обеспечивает механизм восстановления после сбоя из коробки, где он подключается к следующему доступному узлу. Поскольку очереди не зеркально отражены,…
16 июн '17 в 02:20
1
ответ
Когда rabbitmq использует противодавление tcp?
Согласно документации Pika "брокер RabbitMQ использует TCP Backpressure для замедления вашего клиента, если он слишком быстро доставляет сообщения". Я зарегистрировал обратный вызов, и он еще не вызван. В моей очереди более 40 миллионов сообщений, и…
01 дек '11 в 01:57
1
ответ
RabbitMQ обрабатывает только 50 сообщений, затем блокирует
Я использую RabbitMQ в.net, и я вижу странную проблему, когда я отбрасываю 100 сообщений в очередь. Обрабатывает примерно 50 сообщений, затем Dequeue() метод просто виснет. Если я перезапускаю сервис, он обрабатывает остальные пункты. РЕДАКТИРОВАТЬ:…
31 окт '14 в 14:19
1
ответ
RabbitMQ Эксклюзивная очередь потерянных сообщений
Для потребителя, при объявлении очереди как "исключительной", очередь будет удалена, когда потребитель отключится в соответствии с документацией. Если в очереди ожидают обработки сообщения и потребитель переходит в автономный режим, все сообщения в …
10 июн '16 в 19:39
2
ответа
Ошибка отправки сообщения в очередь
Я использую EasyNetQ для отправки сообщения в очереди кролика. У меня есть такой код using (var bus = RabbitHutch.CreateBus("MyConnection")) { bus.Send("MyCodeName", "MyClass"); } соединение открыто при создании шины, но при отправке сообщения возни…
01 июл '16 в 09:21
1
ответ
Управляющая блокировка на массаж в кролике
Я пытаюсь использовать RabbitMq более нетрадиционным способом (хотя в этот момент я могу выбрать любую другую реализацию очереди сообщений, если это необходимо) мое приложение работает так, у меня есть одна очередь (я могу иметь больше, если нужно),…
26 окт '16 в 10:10
1
ответ
Как установить устойчивость очереди / сообщения в false в Spring AMQP с помощью аннотаций?
Я написал пример Spring Amqp-производителя, который работает на сервере RabbitMQ, который отправляет сообщения и использует эти сообщения, используя MessageListener, используя Spring AMQP. Здесь я хочу установить для очереди и стойкости сообщения зн…
28 авг '13 в 13:03
0
ответов
Проблема с кластером Rabbitmq в Кубернетесе
Я успешно настроил кластер RabbitMQ, используя этот график ( https://github.com/helm/charts/tree/master/stable/rabbitmq-ha) в k8s, но не могу установить соединение с сервером в моем ядре exteranl .net приложение. Получение такого исключения: RabbitM…
21 ноя '18 в 12:30
1
ответ
Конвертировать массив вложенных объектов в Buffer Nodejs
1) почему? Мне нужно передать буфер RabbitMQ, опубликовать метод http://www.squaremobius.net/amqp.node/channel_api.html 2) мои данные выглядят так [ // array of objects { id: 1, name: 'John Doe', prop: { a: [....], // nested b: [....], c: {...} } },…
16 дек '16 в 15:46
1
ответ
MassTransit, как справиться с падением RabbitMQ
Как правильно настроить MassTransit для обеспечения отказоустойчивости, чтобы справляться с периодически возникающими проблемами с подключением RabbitMQ или с полным отказом RabbitMQ? Я настроил кластер RabbitMQ между двумя разными машинами и настро…
30 ноя '16 в 19:17
1
ответ
RabbitMQ - Что значит объявить очередь?
Я новичок в RabbitMQ и у меня есть вопрос. Вот образец фрагмента, который я часто вижу в уроках. public static void Send(string queueName, string data) { using (IConnection connection = new ConnectionFactory().CreateConnection()) { using (IModel cha…
19 июл '18 в 14:42
1
ответ
Установка Джанго в виртуален с парамико
Я использую paramiko и создаю некоторые virtualenvs над ssh, например: from paramiko import SSHClient, SSHConfig def ssh_connect(self): # ssh config file config = SSHConfig() config.parse(open(settings.SSH_CONFIG)) o = config.lookup('my_key') # ssh …
27 авг '12 в 20:48
0
ответов
Потребитель Rabbit MQ как сервис в Ubuntu Linux
У меня есть простое приложение подписчика Rabbit MQ, написанное на.net core 2.0, как указано в следующем коде. static void Main(string[] args) { var factory = new ConnectionFactory() { HostName = "localhost" }; using (var connection = factory.Create…
13 дек '17 в 05:58
1
ответ
Как избежать того, чтобы одно и то же задание в очереди обрабатывалось более одного раза при масштабировании по нескольким динам в Heroku
У нас есть приложение Node.js, работающее с обратной связью, основной целью которого является обработка заказов, полученных от клиента. В настоящее время весь процесс заказа обрабатывается в течение одного http-запроса на выполнение заказа, включая …
26 фев '17 в 20:31
3
ответа
Аргумент команды docker-composr.yml
Есть ли способ заставить эту команду выполняться в контейнере в качестве аргумента docker-compose.yml? команда: "rabbitmqctl set_policy ha "example-queue" '{"ha-mode":"all", "ha-sync-mode":"automatic"}' --priority 1 --apply-to queues" докер-compose.…
16 окт '18 в 12:04