Брокер [broker-a, 192.169.1.2:10911] успешно загрузился...

Запуск 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) Установите CRDs:

### install CRDs
$ git clone https://github.com/apache/rocketmq-operator
$ cd rocketmq-operator && make deploy

### check whether CRDs is successfully installed
$ 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

### check whether operator is running
$ kubectl get pods | grep rocketmq-operator
rocketmq-operator-6f65c77c49-8hwmj   1/1     Running   0          93s

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

### create RocketMQ cluster resource
$ cd example && kubectl create -f rocketmq_v1alpha1_rocketmq_cluster.yaml

### check whether cluster resources is running
$ kubectl get sts
NAME                 READY   AGE
broker-0-master      1/1     107m
broker-0-replica-1   1/1     107m
name-service         1/1     107m

Сообщество Apache RocketMQ

• RocketMQ Streams: Лёгкий вычислительный движок на основе потоков Apache RocketMQ.
• RocketMQ Flink: Соединитель Apache Flink для Apache RocketMQ, который поддерживает источник и соединитель приёмника в потоке данных и таблице.
• RocketMQ APIs: Протокол protobuf Apache RocketMQ.
• RocketMQ Clients: Клиенты gRPC/protobuf для Apache RocketMQ.
• Клиенты на основе удалённого взаимодействия RocketMQ:
  • Клиент CPP RocketMQ
  • Клиент Go RocketMQ
  • Клиент Python RocketMQ
  • Клиент Nodejs RocketMQ
• RocketMQ Spring: Проект, помогающий разработчикам быстро интегрировать Apache RocketMQ с Spring Boot.
• RocketMQ Exporter: Экспортёр Apache RocketMQ для Prometheus.
• RocketMQ Operator: Предоставляет способ запуска кластера Apache RocketMQ на Kubernetes.
• RocketMQ Docker: Git-репозиторий образа Docker для Apache RocketMQ.
• RocketMQ Dashboard: Консоль управления и обслуживания Apache RocketMQ.
• RocketMQ Connect: Инструмент для масштабируемой и надёжной потоковой передачи данных между Apache RocketMQ и другими системами.
• RocketMQ MQTT: Новая модель архитектуры протокола MQTT, на основе которой Apache RocketMQ может лучше поддерживать сообщения от терминалов, таких как устройства IoT и мобильные приложения.
• RocketMQ EventBridge: EventBridge упрощает создание событийно-управляемого приложения.
• Инкубационные проекты сообщества Apache RocketMQ: Инкубатор проектов сообщества Apache RocketMQ, включая logappender.