Автор оригинала: Anton Lawrence.
Итак, вы решили, что вам нужно использовать сообщение Broker в вашем приложении, но вам нужно немного толчок, чтобы выяснить, как вы можете на самом деле его интегрировать? Если это так, то продолжайте читать эту статью, и к концу вы будете точно знать, как это сделать.
Хотя там есть много сообщений брокеров, мы сосредоточимся на ActiveMQ в этой статье. Activemq Это отличный сервис обмена сообщениями с открытым исходным кодом, построенный с Java, который может быть благополучно интегрирован в любую архитектуру. Он поддерживает большинство протоколов и идеально подходит для небольших и тяжелых приложений.
Как уже упоминалось, ActiveMQ поддерживает большинство протоколов и может использоваться со всеми языками программирования, которые используют любой из этих протоколов. На протяжении всей этой статьи мы будем использовать Nodejs как язык программирования, Топать в качестве протокола связи и Windows в качестве операционной системы. Если вы используете что-то еще, то не волнуйтесь, потому что изменение одного из этих языков с чем-то другим простым, так как процедура остается прежней.
Шаг 1: Предварительные условия
Activemq – это реализация JMS Поэтому, чтобы использовать его, нам нужно установить Окружающая среда Runtime Java (JRE) Отказ Загрузите JRE для своей операционной системы и следуйте инструкциям из мастера установки.
Как только вы установили этот инструмент, проверьте, если Java_home Переменная среды была правильно установлена в каталог, где установлен JRE.
Чтобы проверить это, простая пресса Ключ Windows + R и введите % Java_home% Отказ Если вы нажмете Enter, и файл Explorer открывается в каталог установки, вы хотите пойти.
Вместо этого появится ошибка, это означает, что вам необходимо вручную установить эту переменную среды. Для этого проверьте эту короткую Статья Отказ
Шаг 2: Установить ActiveMQ
Чтобы установить ActiveMQ, во-первых, иди и Скачать Последняя и устойчивая версия с официального сайта и извлечение zip-файлов в каталог на ваш выбор. Каталог, в котором вы извлеките файлы, будут похожи на «каталог установки», поэтому идите вперед и извлеките его где-то, где вы знаете, что вы не будете случайно удалять его.
Как только файлы извлекаются, откройте командную строку в этом каталоге и запустите следующую команду:
Чтобы убедиться, что каждый работает как ожидалось, перейдите к http://127.0.0.1:8161/Admin/и используйте Админ как учетные данные как для имени пользователя, так и для пароля.
Консоль ActiveMQ должна открываться как таковая:
Шаг 3: Настройка узла JS
Для узла JS мы создадим 2 приложения, потребителя и производитель, чтобы продемонстрировать, как создать простую систему обмена сообщениями.
Следовательно, в новой папке откройте командную строку и запустите следующие команды:
Первая команда создаст новый Package.json Файл и второй установят пакет stomp-клиент что мы будем использовать для общения с использованием STOP протокол.
Шаг 3 – Подключиться к Activemq с помощью STOPP
STOMP включен по умолчанию в ActiveMQ и имеет следующее определение:
Следовательно, для подключения к ActiveMQ с помощью протокола STOMP нам нужно подключиться к Localhost или IP машины, на которой работает ActiveMQ в порту 61613.
Перевод на языке Nodejs, используя stomp-клиент Пакет, похоже следующее:
Этот код будет присутствовать в обоих приложениях.
Шаг 4: потребитель
Первое приложение будет играть роль потребителя. Это приложение будет подписаться на определенную тему и будет слушать все сообщения, которые отправляются.
Создать файл с именем Thumber.js и вставьте следующий код.
В этом приложении мы подписались на очередь назван Уведомления И мы получим все сообщения, которые отправляются в параметре с именем Тело вместе со своими заголовками в параметре по имени Заголовки Отказ
Давайте начнем это приложение, используя следующую команду Узел Coverer.js Отказ
Как только приложение запущено, вы увидите эту новую очередь в веб-консоли ActiveMQ под Очереди вкладка
Количество потребителей Установлено на 1, потому что у нас есть только 1 приложение, которое подписано на эту тему.
Шаг 5: производитель
Далее создайте новый файл с именем Producer.js со следующим кодом:
Здесь вместо того, чтобы подписаться на очередь, мы отправим сообщение. Как только сообщение будет отправлено, мы отключимся.
Сообщение, которое мы отправляем, должно быть строка Поэтому мы хотим отправить объект, нам нужно будет преобразовать в строку.
Это может быть легко достигнуто с использованием Json.stringify () а потом Json.parse () Чтобы преобразовать полученную строку обратно на объект.
Если мы начнем это приложение, используя ту же команду Узел Producer.js Мы должны увидеть следующий вывод в терминале потребителя.
Это обновление также будет отражено в консоли ActiveMQ:
Теперь у нас есть 1 потребитель, 1 сообщение в трансмиссии и 1 сообщений. Другими словами, 1 сообщение было отправлено, и 1 было получено 1 сообщение.
Эта статья должна дать вам начало в создании веб-приложений с Nodejs, которые объединяет Activemq в качестве брокера сообщения, используя протокол STOP в Windows 10. Тем не менее, если вы находитесь в другой ОС, тогда проверьте Эта статья От ActiveMQ, который покажет вам, как установить его в желаемой системе.
Что касается платформы, код будет таким же. Если вы хотите использовать другой протокол вместо STOP, проверьте, какие другие библиотеки там, которые уже есть функциональные возможности, написанные для вашего протокола и языка программирования интересов.
Обложка фото Андрей Лишаков на Несомненно