rocketmq
rocketmq-all-5.3.1
Apache RocketMQ — это распределенная платформа обмена сообщениями и потоковой передачи с низкой задержкой, высокой производительностью и надежностью, емкостью уровня триллиона и гибкой масштабируемостью.
Он предлагает множество функций:
В этом параграфе описаны этапы установки RocketMQ различными способами. Для локальной разработки и тестирования для каждого компонента будет создан только один экземпляр.
RocketMQ работает во всех основных операционных системах и требует установки только Java JDK версии 8 или выше. Чтобы проверить, запустите java -version :
$ java -version
java version " 1.8.0_121 " Для пользователей Windows: нажмите здесь, чтобы загрузить двоичный выпуск RocketMQ 5.2.0, распакуйте его на локальный диск, например D:rocketmq . Для пользователей macOS и Linux выполните следующие команды:
# Download release from the Apache mirror
$ wget https://dist.apache.org/repos/dist/release/rocketmq/5.2.0/rocketmq-all-5.2.0-bin-release.zip
# Unpack the release
$ unzip rocketmq-all-5.2.0-bin-release.zip Подготовьте терминал и перейдите в извлеченный каталог bin :
$ cd rocketmq-all-5.2.0-bin-release/bin1) Запустите сервер имен.
NameServer будет прослушивать порт 0.0.0.0:9876 , убедитесь, что этот порт не используется другими на локальном компьютере, а затем сделайте следующее.
Для пользователей MacOS и Linux:
# ## start Name Server
$ nohup sh mqnamesrv &
# ## check whether Name Server is successfully started
$ 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) Запустить брокера
Для пользователей MacOS и Linux:
# ## start Broker
$ nohup sh bin/mqbroker -n localhost:9876 &
# ## check whether Broker is successfully started, eg: Broker's IP is 192.168.1.2, Broker's name is 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, сеть host будет использоваться для предоставления порта прослушивания в контейнере.
1) Запустите сервер имен.
$ docker run -it --net=host apache/rocketmq ./mqnamesrv2) Запустить брокера
$ docker run -it --net=host --mount source=/tmp/store,target=/home/rocketmq/store apache/rocketmq ./mqbroker -n localhost:9876 Вы также можете запустить кластер RocketMQ в кластере Kubernetes с помощью оператора RocketMQ. Перед началом работы убедитесь, что на вашем компьютере установлены kubectl и связанный с ним файл kubeconfig.
1) Установите CRD
# ## 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 93s2) Создать экземпляр кластера
# ## 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, версия 2.0. Авторские права (C) Apache Software Foundation.
Этот дистрибутив включает криптографическое программное обеспечение. Страна, в которой вы в настоящее время проживаете, может иметь ограничения на импорт, владение, использование и/или реэкспорт в другую страну программного обеспечения для шифрования. ПЕРЕД использованием любого программного обеспечения для шифрования, пожалуйста, ознакомьтесь с законами, правилами и политиками вашей страны, касающимися импорта, владения или использования и реэкспорта программного обеспечения для шифрования, чтобы узнать, разрешено ли это. Дополнительную информацию см. на http://www.wassenaar.org/.
Министерство торговли США, Бюро промышленности и безопасности (BIS), классифицировало это программное обеспечение как контрольный номер экспортного товара (ECCN) 5D002.C.1, что включает в себя программное обеспечение информационной безопасности, использующее или выполняющее криптографические функции с асимметричными алгоритмами. Форма и способ распространения этого дистрибутива Apache Software Foundation позволяют экспортировать его в соответствии с исключением License Exception ENC Technology Software Unrestricted (TSU) (см. Правила управления экспортом BIS, раздел 740.13) как для объектного, так и для исходного кода.
Ниже представлена более подробная информация о включенном в комплект криптографическом программном обеспечении:
Это программное обеспечение использует Apache Commons Crypto (https://commons.apache.org/proper/commons-crypto/) для поддержки аутентификации, а также шифрования и дешифрования данных, передаваемых по сети между службами.
