apache__rocketmq_CVE-2023-37582_4-9-6

Apache RocketMQ

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

Она предлагает множество функций:

• Модели обмена сообщениями: публикация/подписка, запрос/ответ и потоковая передача
• Транзакционные сообщения финансового уровня
• Встроенная отказоустойчивость и высокая доступность на основе DLedger
• Встроенная трассировка сообщений с поддержкой OpenTracing
• Интеграция с разнообразными системами больших данных и потоковой обработки
• Возврат сообщений по времени или смещению
• Надежная FIFO и строгая упорядоченная доставка в одной очереди
• Эффективная модель потребления pull и push
• Возможность накопления миллионов сообщений в одной очереди
• Несколько протоколов обмена сообщениями: gRPC, MQTT, JMS и OpenMessaging
• Гибкая распределенная архитектура с горизонтальным масштабированием
• Молниеносная пакетная обработка сообщений
• Различные механизмы фильтрации сообщений: SQL и теги
• Docker-образы для изолированного тестирования и облачных кластеров
• Богатая административная панель для конфигурации, метрик и мониторинга
• Аутентификация и авторизация
• Бесплатные соединители с открытым исходным кодом для источников и приемников
• Легковесные вычисления в реальном времени

---

Быстрый старт

В этом разделе приведены пошаговые инструкции по установке RocketMQ различными способами. Для локальной разработки и тестирования будет создан только один экземпляр каждого компонента.

Запуск RocketMQ локально

RocketMQ работает на всех основных операционных системах и требует только установленной Java JDK версии 8 или выше. Чтобы проверить, выполните java -version:

$ java -version
java version "1.8.0_121"

Для пользователей Windows: нажмите здесь, чтобы загрузить бинарный релиз RocketMQ 4.9.3, распакуйте его в локальную папку, например D:\rocketmq. Для пользователей macOS и Linux выполните следующие команды:

# Загрузка релиза из зеркала Apache
$ wget https://archive.apache.org/dist/rocketmq/4.9.3/rocketmq-all-4.9.3-bin-release.zip

# Распаковка релиза
$ unzip rocketmq-all-4.9.3-bin-release.zip

Подготовьте терминал и перейдите в извлеченную директорию bin:

$ cd rocketmq-4.9.3/bin

1) Запуск NameServer

NameServer будет прослушивать порт 0.0.0.0:9876. Убедитесь, что этот порт не занят другими процессами на локальной машине, и выполните следующие действия.

Для пользователей macOS и Linux:

### Запуск NameServer
$ nohup sh mqnamesrv &

### Проверка успешности запуска NameServer
$ tail -f ~/logs/rocketmqlogs/namesrv.log
The Name Server boot success...

Для пользователей Windows сначала необходимо задать переменные окружения:

• На рабочем столе щелкните правой кнопкой мыши значок «Компьютер».
• Выберите «Свойства» в контекстном меню.
• Нажмите «Дополнительные параметры системы».
• Нажмите «Переменные среды».
• Добавьте переменную окружения ROCKETMQ_HOME="D:\rocketmq".

Затем перейдите в каталог rocketmq, введите и выполните:

$ mqnamesrv.cmd
The Name Server boot success...

2) Запуск Broker

Для пользователей macOS и Linux:

### Запуск Broker
$ nohup sh bin/mqbroker -n localhost:9876 &

### Проверка успешности запуска Broker, например: IP брокера 192.168.1.2, имя брокера broker-a
$ tail -f ~/logs/rocketmqlogs/broker.log
The broker[broker-a, 192.169.1.2:10911] boot success...

Для пользователей Windows:

$ mqbroker.cmd -n localhost:9876
The broker[broker-a, 192.169.1.2:10911] boot success...

Запуск RocketMQ в Docker

Вы можете запустить RocketMQ на своей машине в контейнерах Docker. Сеть host будет использоваться для открытия порта прослушивания внутри контейнера.

1) Запуск NameServer

$ docker run -it --net=host apache/rocketmq ./mqnamesrv

2) Запуск Broker

$ docker run -it --net=host --mount source=/tmp/store,target=/home/rocketmq/store apache/rocketmq ./mqbroker -n localhost:9876

Запуск RocketMQ в Kubernetes

Вы также можете запустить кластер RocketMQ в кластере Kubernetes с помощью RocketMQ Operator. Перед началом работы убедитесь, что на вашей машине установлены kubectl и соответствующий kubeconfig-файл.

1) Установка CRD

### Установка CRD
$ git clone https://github.com/apache/rocketmq-operator
$ cd rocketmq-operator && make deploy

### Проверка успешности установки CRD
$ kubectl get crd | grep rocketmq.apache.org
brokers.rocketmq.apache.org                 2022-05-12T09:23:18Z
consoles.rocketmq.apache.org                2022-05-12T09:23:19Z
nameservices.rocketmq.apache.org            2022-05-12T09:23:18Z
topictransfers.rocketmq.apache.org          2022-05-12T09:23:19Z

### Проверка, работает ли оператор
$ kubectl get pods | grep rocketmq-operator
rocketmq-operator-6f65c77c49-8hwmj   1/1     Running   0          93s

2) Создание экземпляра кластера

### Создание ресурса кластера RocketMQ
$ cd example && kubectl create -f rocketmq_v1alpha1_rocketmq_cluster.yaml

### Проверка, запущены ли ресурсы кластера
$ kubectl get sts
NAME                 READY   AGE
broker-0-master      1/1     107m
broker-0-replica-1   1/1     107m
name-service         1/1     107m