apache__rocketmq_CVE-2023-33246_5-1-0

Apache RocketMQ

[![Build Status][maven-build-image]][maven-build-url] [![CodeCov][codecov-image]][codecov-url] [![Maven Central][maven-central-image]][maven-central-url] [![Release][release-image]][release-url] [![License][license-image]][license-url] [![Average Time to Resolve An Issue][percentage-of-issues-still-open-image]][pencentage-of-issues-still-open-url] [![Percentage of Issues Still Open][average-time-to-resolve-an-issue-image]][average-time-to-resolve-an-issue-url] [![Twitter Follow][twitter-follow-image]][twitter-follow-url]

Apache RocketMQ est une plateforme de messagerie et de streaming distribuée avec une faible latence, des performances et une fiabilité élevées, une capacité au niveau du trillion et une évolutivité flexible.

Il offre une variété de fonctionnalités :

• Modèles de messagerie incluant publication/abonnement, requête/réponse et streaming
• Message transactionnel de qualité financière
• Options de configuration de tolérance aux pannes et de haute disponibilité intégrées basées sur DLedger Controller
• Capacité de traçage des messages intégrée, prend également en charge opentracing
• Intégration polyvalente avec les écosystèmes big data et streaming
• Rétroactivité des messages par heure ou décalage (offset)
• Messagerie FIFO fiable et strictement ordonnée dans la même file d'attente
• Modèle de consommation efficace par pull et push
• Capacité d'accumulation de messages au niveau du million dans une seule file d'attente
• Plusieurs protocoles de messagerie comme gRPC, MQTT, JMS et OpenMessaging
• Architecture de déploiement distribuée flexible à mise à l'échelle horizontale
• Système d'échange de messages par lots ultra-rapide
• Divers mécanismes de filtrage de messages tels que SQL et Tag
• Images Docker pour les tests isolés et les clusters cloud isolés
• Tableau de bord d'administration riche en fonctionnalités pour la configuration, les métriques et la surveillance
• Authentification et autorisation
• Connecteurs open source gratuits, pour les sources et les puits (sinks)
• Calcul temps réel léger

---

Démarrage rapide

Ce paragraphe vous guide à travers les étapes d'installation de RocketMQ de différentes manières. Pour le développement et les tests locaux, une seule instance sera créée pour chaque composant.

Exécuter RocketMQ localement

RocketMQ fonctionne sur tous les principaux systèmes d'exploitation et nécessite seulement l'installation d'un JDK Java version 8 ou supérieure. Pour vérifier, exécutez java -version :

$ java -version
java version "1.8.0_121"

Pour les utilisateurs Windows, cliquez ici pour télécharger la version binaire 4.9.4 de RocketMQ, décompressez-la sur votre disque local, par exemple D:\rocketmq. Pour les utilisateurs macOS et Linux, exécutez les commandes suivantes :

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

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

Préparez un terminal et placez-vous dans le répertoire bin extrait :

$ cd rocketmq-4.9.4/bin

1) Démarrer NameServer

NameServer écoutera sur 0.0.0.0:9876, assurez-vous que ce port n'est pas utilisé par d'autres sur la machine locale, puis procédez comme suit.

Pour les utilisateurs macOS et 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...

Pour les utilisateurs Windows, vous devez d'abord définir les variables d'environnement :

• Depuis le bureau, faites un clic droit sur l'icône Ordinateur.
• Choisissez Propriétés dans le menu contextuel.
• Cliquez sur le lien Paramètres système avancés.
• Cliquez sur Variables d'environnement.
• Ajoutez la variable d'environnement ROCKETMQ_HOME="D:\rocketmq".

Ensuite, changez de répertoire pour accéder à rocketmq, tapez et exécutez :

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

2) Démarrer Broker

Pour les utilisateurs macOS et 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...

Pour les utilisateurs Windows :

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

Exécuter RocketMQ dans Docker

Vous pouvez exécuter RocketMQ sur votre propre machine dans des conteneurs Docker, le réseau host sera utilisé pour exposer le port d'écoute dans le conteneur.

1) Démarrer NameServer

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

2) Démarrer Broker

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

Exécuter RocketMQ dans Kubernetes

Vous pouvez également exécuter un cluster RocketMQ dans un cluster Kubernetes en utilisant RocketMQ Operator. Avant vos opérations, assurez-vous que kubectl et le fichier kubeconfig associé sont installés sur votre machine.

1) Installer les 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) Créer une instance de 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