apache__rocketmq_CVE-2023-37582_4-9-6

Apache RocketMQ

Apache RocketMQ é uma plataforma de mensagens e streaming distribuída com baixa latência, alto desempenho e confiabilidade, capacidade em nível de trilhões e escalabilidade flexível.

Ela oferece uma variedade de recursos:

• Padrões de mensagens incluindo publicar/assinar, solicitar/responder e streaming
• Mensagem transacional de nível financeiro
• Opções de configuração de tolerância a falhas e alta disponibilidade integradas baseadas em DLedger
• Capacidade de rastreamento de mensagens integrada, também suporta opentracing
• Integração versátil com ecossistemas de big data e streaming
• Retroação de mensagens por tempo ou offset
• Mensagens FIFO confiáveis e estritamente ordenadas na mesma fila
• Modelo eficiente de consumo pull e push
• Capacidade de acumulação de mensagens em nível de milhões em uma única fila
• Múltiplos protocolos de mensagens como gRPC, MQTT, JMS e OpenMessaging
• Arquitetura de implantação flexível distribuída e escalável
• Sistema de troca de mensagens em lote extremamente rápido
• Vários mecanismos de filtro de mensagens, como SQL e Tag
• Imagens Docker para testes isolados e clusters isolados na nuvem
• Painel administrativo rico em recursos para configuração, métricas e monitoramento
• Autenticação e autorização
• Conectores de código aberto gratuitos, tanto para origens quanto para destinos
• Computação leve em tempo real

---

Início Rápido

Este parágrafo guia você pelas etapas de instalação do RocketMQ de diferentes maneiras. Para desenvolvimento e testes locais, apenas uma instância será criada para cada componente.

Executar RocketMQ localmente

O RocketMQ é executado em todos os principais sistemas operacionais e requer apenas a instalação do Java JDK versão 8 ou superior. Para verificar, execute java -version:

$ java -version
java version "1.8.0_121"

Para usuários do Windows, clique aqui para baixar a versão binária 4.9.3 do RocketMQ, descompacte-a em seu disco local, como D:\rocketmq. Para usuários de macOS e Linux, execute os seguintes comandos:

# Download release from the Apache mirror
$ wget https://archive.apache.org/dist/rocketmq/4.9.3/rocketmq-all-4.9.3-bin-release.zip

# Unpack the release
$ unzip rocketmq-all-4.9.3-bin-release.zip

Prepare um terminal e vá para o diretório bin extraído:

$ cd rocketmq-4.9.3/bin

1) Iniciar NameServer

O NameServer escutará em 0.0.0.0:9876, certifique-se de que a porta não está sendo usada por outros na máquina local e, em seguida, faça o seguinte.

Para usuários de macOS e 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 usuários do Windows, você precisa definir as variáveis de ambiente primeiro:

• Na área de trabalho, clique com o botão direito no ícone Computador.
• Escolha Propriedades no menu de contexto.
• Clique no link Configurações avançadas do sistema.
• Clique em Variáveis de Ambiente.
• Adicione a variável de ambiente ROCKETMQ_HOME="D:\rocketmq".

Em seguida, mude o diretório para rocketmq, digite e execute:

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

2) Iniciar Broker

Para usuários de macOS e 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 usuários do Windows:

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

Executar RocketMQ no Docker

Você pode executar o RocketMQ em sua própria máquina dentro de contêineres Docker, a rede host será usada para expor a porta de escuta no contêiner.

1) Iniciar NameServer

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

2) Iniciar Broker

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

Executar RocketMQ no Kubernetes

Você também pode executar um cluster RocketMQ dentro de um cluster Kubernetes usando o RocketMQ Operator. Antes de suas operações, certifique-se de que o kubectl e o arquivo kubeconfig relacionado estejam instalados em sua máquina.

1) Instalar 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) Criar Instância do Cluster

### 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