rocketmq
rocketmq-all-5.3.1
Apache RocketMQ es una plataforma de transmisión y mensajería distribuida con baja latencia, alto rendimiento y confiabilidad, capacidad de billones de niveles y escalabilidad flexible.
Ofrece una variedad de características:
Este párrafo lo guía a través de los pasos para instalar RocketMQ de diferentes maneras. Para el desarrollo y las pruebas locales, solo se creará una instancia para cada componente.
RocketMQ se ejecuta en todos los principales sistemas operativos y solo requiere la instalación de Java JDK versión 8 o superior. Para comprobarlo, ejecute java -version :
$ java -version
java version " 1.8.0_121 " Para usuarios de Windows, haga clic aquí para descargar la versión binaria 5.2.0 RocketMQ, descomprímala en su disco local, como D:rocketmq . Para usuarios de macOS y Linux, ejecute los siguientes comandos:
# 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 Prepare una terminal y cambie al directorio bin extraído:
$ cd rocketmq-all-5.2.0-bin-release/bin1) Iniciar el servidor de nombres
NameServer escuchará en 0.0.0.0:9876 , asegúrese de que otras personas en la máquina local no utilicen el puerto y luego haga lo siguiente.
Para usuarios de macOS y 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...Para los usuarios de Windows, primero deben configurar las variables de entorno:
ROCKETMQ_HOME="D:rocketmq" .Luego cambie el directorio a rocketmq, escriba y ejecute:
$ mqnamesrv.cmd
The Name Server boot success...2) Iniciar corredor
Para usuarios de macOS y 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...Para usuarios de Windows:
$ mqbroker.cmd -n localhost:9876
The broker[broker-a, 192.169.1.2:10911] boot success... Puede ejecutar RocketMQ en su propia máquina dentro de los contenedores Docker; la red host se utilizará para exponer el puerto de escucha en el contenedor.
1) Iniciar el servidor de nombres
$ docker run -it --net=host apache/rocketmq ./mqnamesrv2) Iniciar corredor
$ docker run -it --net=host --mount source=/tmp/store,target=/home/rocketmq/store apache/rocketmq ./mqbroker -n localhost:9876 También puede ejecutar un clúster RocketMQ dentro de un clúster de Kubernetes utilizando RocketMQ Operador. Antes de realizar sus operaciones, asegúrese de que kubectl y el archivo kubeconfig relacionado estén instalados en su máquina.
1) Instalar 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) Crear una instancia de clúster
# ## 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 107mSiempre damos la bienvenida a nuevas contribuciones, ya sea para limpiezas triviales, nuevas funciones importantes u otras recompensas materiales; consulte más detalles aquí.
Licencia Apache, Versión 2.0 Copyright (C) Apache Software Foundation
Esta distribución incluye software criptográfico. El país en el que reside actualmente puede tener restricciones sobre la importación, posesión, uso y/o reexportación a otro país de software de cifrado. ANTES de utilizar cualquier software de cifrado, consulte las leyes, regulaciones y políticas de su país relativas a la importación, posesión o uso y reexportación de software de cifrado para ver si esto está permitido. Consulte http://www.wassenaar.org/ para obtener más información.
La Oficina de Industria y Seguridad (BIS) del Departamento de Comercio del Gobierno de EE. UU. ha clasificado este software como Número de control de productos de exportación (ECCN) 5D002.C.1, que incluye software de seguridad de la información que utiliza o realiza funciones criptográficas con algoritmos asimétricos. La forma y el modo de esta distribución de Apache Software Foundation la hacen elegible para la exportación bajo la excepción de Licencia de Excepción ENC Technology Software Unrestricted (TSU) (consulte las Regulaciones de Administración de Exportaciones de BIS, Sección 740.13) tanto para el código objeto como para el código fuente.
A continuación se proporcionan más detalles sobre el software criptográfico incluido:
Este software utiliza Apache Commons Crypto (https://commons.apache.org/proper/commons-crypto/) para admitir la autenticación y el cifrado y descifrado de datos enviados a través de la red entre servicios.
