Я запускаю клиент node.js amqp-node на сервере RabbitMQ. Я настроил простой тест публикации / потребления двумя разными способами - каждый дает разную задержку, и я не могу понять, почему. Задержка измеряется с момента отправки сообщения до момента...

Кажется, я не могу получить подтверждение, когда публикую на бирже по умолчанию. В настоящее время я использую главную ветвь node-amqp, предложенную этот пост . Код: var amqp = require('amqp'); var conn = amqp.createConnection({ host:...

У меня есть приложение angularjs с узлом и экспрессом на стороне сервера. У меня также есть node-amqp и socket.io Я хочу реализовать следующее поведение Приложение имеет страницу (маршрут, угловое представление), которая отображает таблицу с...

Ищу несколько примеров кода для решения этой проблемы: - Хотел бы написать код (Python или Javascript), который действовал бы как подписчик на очередь RabbitMQ, чтобы при получении сообщения он транслировал сообщение через веб-сокеты любому...

Мое приложение использует очередь RabbitMQ для хранения сообщений, затем у меня есть рабочий процесс, потребляющий эти сообщения и вставляющий их в базу данных. Цель состоит в том, чтобы не нагружать базу данных пиковыми нагрузками. Проблема, с...

У меня есть два потребителя, которым нужно обрабатывать сообщения из одной очереди, но только один из них в любое время. Последовательность того, что я пытаюсь выполнить, выглядит следующим образом: (начало) Ни один из потребителей не подписался...

Я использую библиотеку node-amqp для своего проекта nodejs. Я также разместил проблему на странице проекта github. Он продолжает создавать новые каналы, и они остаются бездействующими навсегда. Через час каналов было ~12000. Я проверил варианты...

Я пытаюсь сделать что-то, что кажется простым, но оказывается на удивление трудным. У меня есть функция для подписки на очередь RabbitMQ. В частности, это функция Channel.consume здесь:...

Предполагая, что мне нравится 100000 событий в моей очереди rabbitmq, каков наилучший способ ограничить систему для обработки их последовательно, а не пытаться потреблять все сразу? Я пробую несколько вариантов, однако машина зависает, пытаясь...

я создаю новую службу nodejs, которая будет получать запросы от внешнего интерфейса, размещая этот запрос на rabbitmq, затем жду ответа от микросервиса, который обрабатывает этот запрос, а затем отправляет ответ обратно запрашивающему интерфейсу,...