Описание тега node-amqplib
Библиотека и клиент AMQP 0-9-1 для Node.JS
2
ответа
Как проверить, живо ли соединение в библиотеке RabbitMq node-amqplib?
Я пишу для продюсера и потребителя, используя библиотеку rabbitMq node-amqplib, я боюсь внезапно потерять соединение с сервером. Как я могу проверить, живо ли соединение или нет?
30 апр '18 в 10:10
0
ответов
NodeJS поддерживает пул соединений amqplib
Итак, у меня есть "работающий" набор потребителей и издателей кроликов, которые обрабатывают данные перед тем, как их переносить. Каждый потребитель выглядит примерно так, разбитый на несколько файлов const amqp = require("amqplib/callback_api"); co…
09 ноя '18 в 16:09
1
ответ
Amqp, rabbit mq и socket.io переподключаются к очереди, даже если клиент закрыт
Я кодирую уведомление браузера, используя rabbitMQ и socket.io. Моя конфигурация работает нормально, за исключением одного случая. Когда я вхожу в свою систему с пользователем, он создает очередь уведомления-UID-IDпользователя (сейчас queueName отпр…
22 авг '18 в 10:42
0
ответов
Как подключить канал asmq в удаленной машине. amqp.connect()
Я могу подключиться к каналу asmq, используя rabbitmq на моей локальной машине, используя приведенный ниже код. но я хочу подключиться к этому каналу на другой машине и получать данные. amqp.connect ('amqp: // localhost', function (err, conn) {});
27 дек '18 в 09:06
0
ответов
Как отделить сердцебиение от собственного потока для соединения RabbitMQ
У меня есть процесс, который использует RabbitMQ и NodeJS для обработки изображений. В связи с интенсивной задачей, я думаю, что у меня та же проблема, что и ссылка здесь https://github.com/squaremo/amqp.node/issues/261 Я пытаюсь выяснить, как реали…
31 янв '19 в 20:06
0
ответов
Сохранить в БД после того, как сервис был недоступен в течение определенного времени, используя RabbitMQ
Я кодирую промежуточное программное обеспечение, которое подключается к различным службам, я использую rabbitmq для постановки в очередь сообщений, которые должны быть отправлены этим службам. Если служба недоступна, сообщение ставится в очередь. Эт…
25 фев '19 в 17:59
0
ответов
Могу ли я динамически создать экскаватор RabbitMQ из моего приложения NodeJS?
Плагин RabbitMQ shovel предоставляет HTTP API для создания и настройки экскаваторов. Предполагая, что я включил плагин управления лопатами и лопатами для своего экземпляра сервера RabbitMQ, могу ли я динамически создавать лопатки из своего приложени…
01 мар '19 в 02:01
0
ответов
Как получить доступ к RabbitMQ без использования IP-адреса с помощью amqplib?
Там, где я работаю, у нас есть облачный сервер, который предоставляет RabbitMQ в качестве сервиса. Когда я настраиваю эту службу и пытаюсь подключиться с помощью amqplib через (localhost, 127.0.0.1 и т. Д.), Она не подключается. Когда я смотрю на пр…
14 янв '19 в 18:15
1
ответ
Как понять вывод команд rabbitmqctl
$rabbitmqctl list_queues Timeout: 60.0 seconds ... Listing queues for vhost / ... privateTransactionQ 2 amq.gen-o9dl3Zj7HxS50gkTC2xbBQ 0 task_queue 0 Вывод rabbitmqctl выглядит следующим образом. Я не могу понять, для чего предназначен каждый столбе…
12 мар '18 в 14:22
0
ответов
Как amqplib доставляет сообщения вашему обработчику приложений
У меня есть следующий код: class Queue extends EventEmitter { async listen(queueName) { await this._channel.prefetch(10); this._channel.consume(queueName, (message) => { if (!message) { return; } this.emit(queueName, new QueueMessage(this._channe…
10 авг '18 в 12:24
0
ответов
Настройка времени ожидания сокета при подключении amqplib
Я использую кластер из 2 серверов RabbitMQ (может быть любым числом), и я реализовал отработку отказа, когда мое приложение зацикливает список RabbitMQ и пытается восстановить соединение при разрыве соединения. Если экземпляр RabbitMQ не работает, к…
16 май '17 в 08:21
1
ответ
Асинхронное / ожидание путаницы с помощью сингелтонов
Таким образом, независимо от того, что я прочитал, даже если я все сделаю правильно, я не могу понять, что такое асинхронность и ожидание. Например, у меня есть это в моем запуске. startup.js await CommandBus.GetInstance(); await Consumers.GetInstan…
30 окт '18 в 13:19
2
ответа
Почему nodejs с функцией потребления amqplib является замыканием?
Я использую модуль nodejs amqplib для подключения rabbitmq. Я обнаружил, что функция потребления стала функцией закрытия, но я не мог понять, почему. Я не использовал закрытие. Мой код ниже. Я нашел корр в returnOK все еще получить значение в первый…
15 дек '17 в 03:25
1
ответ
Приложение Nojjs и RabbitMQ, я передаю кролику подключиться
Я создаю новую службу nodejs, которая получает запросы от внешнего интерфейса, помещает этот запрос в rabbitmq, затем ждет ответа от микросервиса, который обрабатывает этот запрос, и затем отправляет ответ обратно запрашивающему интерфейсу, от котор…
11 мар '18 в 18:30
2
ответа
node-amqp, ограничить время сокета для прослушивания событий
Предполагая, что мне нравится 100000 событий в моей очереди rabbitmq, каков наилучший способ ограничить систему, чтобы обрабатывать их последовательно, а не пытаться использовать все сразу? Я пробую несколько вариантов, однако машина зависает, пытая…
28 янв '18 в 20:58
2
ответа
Ошибка соединения отклонена в RabbitMQ с модулем amqplib npm
Я новичок в RabbitMQ и пробую простой пример в Nodejs. const amqp = require('amqplib/callback_api'); amqp.connect('amqp://guest:guest@localhost:15672',function(err, conn) { console.log("Enter in callback",conn); if (err) { console.error("[AMQP]", er…
26 июн '18 в 12:13
1
ответ
Можно ли отбрасывать сообщения rabbitmq, когда очереди слишком велики, используя amqplib в nodejs?
Я использую amqplib в приложении nodejs. На входной стороне есть некоторая тяжелая обработка, вызывающая некоторую задержку в получении сообщений rabbitmq. При мониторинге моих очередей с rabbitmqctl list_queuesколичество сообщений, ожидающих обрабо…
05 фев '18 в 10:46
1
ответ
Закрытие соединения обещания amqp после публикации?
Я пытаюсь выяснить, как закрыть свои обещания соединений после публикации сообщений. Я попытался экстраполировать общий код для моего отправителя и получателя, поэтому у меня есть файл подключения, подобный этому: connector.js const amqp = require('…
08 янв '18 в 15:22
1
ответ
Node.js amqplib - не удается выполнить переподключение в случае закрытия соединения
Я пытаюсь реализовать механизм переподключения, когда не удается установить соединение с сервером очередей rabbitmq. Этот код предназначен только для потребления сообщений. Ниже приведен мой код (функция Init канала выполняет инициализацию потребите…
12 сен '18 в 09:08
0
ответов
Установить пользовательские попытки доставки сообщений в amqplib(rabbitmq) в узле js
Я использую модуль js amqplib для реализации rabbitmq в моем приложении. Я изучил всю документацию, но не могу выяснить, как мы можем настроить пользовательские попытки отправки сообщений. Также я хочу получить доступ к тем сообщениям в очереди, кот…
01 фев '18 в 07:24