Описание тега node-amqp
NoneNode-amqp - это клиент AMQP для nodejs.
2
ответа
Зачем мне нужна очередь в публикации RabbitMQ?
Я использую Node.js с node-amqp для создания простой очереди сообщений. Большинство примеров, которые я вижу, делают следующее: Создать соединение Создать обмен Создайте очередь и привяжите ее к Exchange Опубликовать через биржу В моем коде я опуска…
31 окт '15 в 19:23
1
ответ
Должен ли я закрывать канал / соединение после каждой публикации?
Я использую amqplib в Node.js, и мне не ясны лучшие практики в моем коде. По сути, мой текущий код вызывает amqp.connect() когда сервер Node запускается, а затем использует разные каналы для каждого производителя и каждого потребителя, никогда не за…
04 июн '17 в 19:40
1
ответ
Очередь задач в RabbitMQ
Я пытаюсь настроить постановку задач в очередь с rabbitMQ в сочетании с Node.js & React.js. Мне трудно понять, как на самом деле работает управление задачами, и я не могу найти хороший пример в Интернете. Я пытаюсь отправить задачу (например, создат…
24 июл '17 в 07:50
1
ответ
Ошибка аутентификации при работе с библиотекой node-amqp при переключении на stomp-client, работает
Я использую библиотеку node-amqp для подключения к онлайновой службе stomp. До того, как я использовал stomp-client, она была подключена очень успешно, но она не поддерживает автоматическое обнаружение сбоев и повторное подключение, поэтому я хочу п…
04 апр '13 в 12:27
0
ответов
Могу ли я динамически создать экскаватор RabbitMQ из моего приложения NodeJS?
Плагин RabbitMQ shovel предоставляет HTTP API для создания и настройки экскаваторов. Предполагая, что я включил плагин управления лопатами и лопатами для своего экземпляра сервера RabbitMQ, могу ли я динамически создавать лопатки из своего приложени…
01 мар '19 в 02:01
2
ответа
Node-amqp - отклонение сообщения после X попыток
Как реализовать механизм, который отклоняет сообщение после нескольких настраиваемых попыток запроса? Другими словами, если я подписываюсь на очередь, я хочу гарантировать, что одно и то же сообщение не будет доставлено более X раз. Мой пример кода:…
13 фев '14 в 16:27
1
ответ
amqp.node не обнаружит разрыв соединения
У нас есть скрипт node.js, на котором запущен сервер socket.io, клиенты которого получают сообщения из очереди RabbitMQ. Мы недавно перешли на Amazon AWS, и RabbitMQ теперь представляет собой кластер из двух машин (избыточные экземпляры). Соединение…
05 янв '15 в 11:01
0
ответов
RabbitMQ (через node-amqp): необработанная ошибка соединения: UNEXPECTED_FRAME - ожидаемый заголовок содержимого для класса 60, вместо него получен кадр заголовка без содержимого
Я использую node-amqp для подключения к RabbitMQ. Установка выглядит следующим образом: два сервера RabbitMQ (далее "кролики"), один из которых называется "входящий", другой - "уведомитель". Данные публикуются "входящему" кролику, и мое приложение б…
27 мар '15 в 14:08
1
ответ
Ошибка: прочитать ETIMEOUT, происходящее через некоторое время, с помощью node-amqp
У меня есть виртуальная машина с запущенным экземпляром RabbitMQ и отдельная виртуальная машина с процессом Node, который будет потреблять вещи из очереди. После некоторого времени бездействия мой процесс Node просто завершится и отобразит ошибку. Я…
22 окт '15 в 16:24
0
ответов
RabbitMQ Durable Queue ACK не работает в узле
Я изучаю интеграцию RabbitMQ с Node и пишу POC для проверки подписки с длительной очередью. Хотя я установил autoAck: true в consumer.js, но он все равно получает старые сообщения всякий раз, когда я выполняю этот файл js. Могу ли я знать, почему мо…
30 окт '17 в 21:47
0
ответов
Как перепривязать / использовать очередь из канала?
Я использую amqplib для передачи сообщений на моем сервере node.js. Вот мой код для прослушивания в очереди: channel.consume(queue, handler1, { noAck: true }) Теперь я хочу обновить потребителя, чтобы прослушать ту же очередь Как это: channel.consum…
17 янв '18 в 09:05
0
ответов
Как проверить, является ли канал живым или нет в библиотеке RabbitMq node-amqplib?
Я делаю программу для производителя и потребителя, используя библиотеку RabbitMq node-amqplib. В таком случае, могу ли я проверить, активен ли канал после создания соединения?
30 апр '18 в 11:16
1
ответ
RabbitMQ и Node.js, как обрабатывать сценарии отработки отказа?
Я использую RabbitMQ (кластер) и подключаюсь к нему с помощью клиента Node.js (node-amqp - https://github.com/postwait/node-amqp). Документы RabbitMQ гласят, что обработка сценария отработки отказа (сбой узла кластера) должна выполняться клиентом, ч…
24 июн '14 в 17:37
0
ответов
node-amqp: возникают проблемы с двумя потребителями, подписывающимися на одну и ту же очередь по одному
У меня есть два потребителя, которым нужно обрабатывать сообщения из одной очереди, но только одного из них в любое время. Последовательность того, что я пытаюсь выполнить, выглядит следующим образом: (начало) Ни один из потребителей не подписался н…
14 ноя '14 в 16:55
1
ответ
RabbitMQ / AMQP: несколько очередей, один потребитель
Я хочу создать потребителя, который обрабатывает сообщения из нескольких переменных числа источников, которые подключаются или отключаются динамически. Мне нужно, чтобы каждый потребитель располагал по приоритетам первые N сообщений каждого источник…
02 май '18 в 17:44
1
ответ
Зачем "закрывать" событие, когда что-то идет не так с node-amqp?
(Я использую сервер node-amqp и rabbitmq.) Я пытаюсь угадать, почему у меня закрытое событие, если что-то идет не так. Например, если я пытаюсь открыть соединение с очередью (с неверными параметрами), я получаю сообщение об ошибке. Что это прекрасно…
10 янв '14 в 11:15
2
ответа
Высокая производительность на сервере Nodejs RabbitMQ
Я создаю систему анализа с миллионами пользователей онлайн одновременно. Я использую RabbitMQ, например, брокер сообщений, чтобы уменьшить емкость сервера Вот моя диаграмма Моя система включает в себя 3 компонента. Сервер издателя: (Производитель) Э…
28 дек '16 в 09:03
1
ответ
Нет исключений, когда node-amqp
Я пытаюсь использовать node-amqp. Когда в разделе соединения с кроликом выдается исключение, я могу получить это исключение, но оно навсегда перезапускает соединение с Кроликом. Посмотри на это: amqp = require("amqp") # Open a connection conn = amqp…
08 сен '14 в 16:18
2
ответа
Как преобразовать буфер сообщений AQMP в объект JSON при использовании модуля node.js amqp?
Я использую модуль node.js amqp для чтения сообщений из очереди. Ниже приводится обратный вызов, который вызывается, когда в очереди доступно сообщение: function onMessage(message, headers, deliveryInfo) { console.log(message); //This prints buffer …
17 дек '13 в 06:39
1
ответ
nodejs amqp может получить сообщение только один раз
var amqp=require('amqp'); var conn=amqp.createConnection({/**/}); conn.on('ready',function() { console.log('Server Connected'); conn.exchange('order',options={type:'topic'},function(exchange) { console.log('Exchange connected'); conn.queue('order-co…
13 апр '15 в 17:55