Apache RocketMQ ist eine verteilte Messaging- und Streaming-Plattform mit geringer Latenz, hoher Leistung und Zuverlässigkeit, Kapazität auf Billionenebene und flexibler Skalierbarkeit.
Es bietet eine Vielzahl von Funktionen:
Dieser Absatz führt Sie durch die Schritte zur Installation von RocketMQ auf unterschiedliche Weise. Für die lokale Entwicklung und Tests wird für jede Komponente nur eine Instanz erstellt.
RocketMQ läuft auf allen gängigen Betriebssystemen und erfordert lediglich die Installation eines Java JDK Version 8 oder höher. Um dies zu überprüfen, führen Sie java -version
aus:
$ java -version
java version " 1.8.0_121 "
Für Windows-Benutzer klicken Sie hier, um die Binärversion 5.2.0 RocketMQ herunterzuladen und auf Ihre lokale Festplatte zu entpacken, z. B. D:rocketmq
. Führen Sie für macOS- und Linux-Benutzer die folgenden Befehle aus:
# 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
Bereiten Sie ein Terminal vor und wechseln Sie in das extrahierte bin
Verzeichnis:
$ cd rocketmq-all-5.2.0-bin-release/bin
1) NameServer starten
Der NameServer überwacht 0.0.0.0:9876
. Stellen Sie sicher, dass der Port nicht von anderen Benutzern auf dem lokalen Computer verwendet wird, und gehen Sie dann wie folgt vor.
Für macOS- und Linux-Benutzer:
# ## start Name Server
$ nohup sh mqnamesrv &
# ## check whether Name Server is successfully started
$ tail -f ~ /logs/rocketmqlogs/namesrv.log
The Name Server boot success...
Für Windows-Benutzer müssen Sie zunächst Umgebungsvariablen festlegen:
ROCKETMQ_HOME="D:rocketmq"
.Wechseln Sie dann in das Verzeichnis rocketmq, geben Sie Folgendes ein und führen Sie es aus:
$ mqnamesrv.cmd
The Name Server boot success...
2) Broker starten
Für macOS- und Linux-Benutzer:
# ## 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...
Für Windows-Benutzer:
$ mqbroker.cmd -n localhost:9876
The broker[broker-a, 192.169.1.2:10911] boot success...
Sie können RocketMQ auf Ihrem eigenen Computer in Docker-Containern ausführen. host
wird verwendet, um den Überwachungsport im Container freizugeben.
1) NameServer starten
$ docker run -it --net=host apache/rocketmq ./mqnamesrv
2) Broker starten
$ docker run -it --net=host --mount source=/tmp/store,target=/home/rocketmq/store apache/rocketmq ./mqbroker -n localhost:9876
Sie können mit dem RocketMQ-Operator auch einen RocketMQ-Cluster innerhalb eines Kubernetes-Clusters ausführen. Stellen Sie vor dem Betrieb sicher, dass kubectl
und die zugehörige kubeconfig-Datei auf Ihrem Computer installiert sind.
1) CRDs installieren
# ## 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) Cluster-Instanz erstellen
# ## 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
Wir freuen uns immer über neue Beiträge, sei es für triviale Aufräumarbeiten, große neue Funktionen oder andere materielle Belohnungen, weitere Details finden Sie hier.
Apache-Lizenz, Version 2.0 Copyright (C) Apache Software Foundation
Diese Distribution umfasst kryptografische Software. Das Land, in dem Sie sich derzeit aufhalten, unterliegt möglicherweise Beschränkungen hinsichtlich der Einfuhr, des Besitzes, der Verwendung und/oder der Wiederausfuhr von Verschlüsselungssoftware in ein anderes Land. Bevor Sie Verschlüsselungssoftware verwenden, prüfen Sie bitte die Gesetze, Vorschriften und Richtlinien Ihres Landes bezüglich der Einfuhr, des Besitzes oder der Verwendung und Wiederausfuhr von Verschlüsselungssoftware, um festzustellen, ob dies zulässig ist. Weitere Informationen finden Sie unter http://www.wassenaar.org/.
Das US-Handelsministerium, Bureau of Industry and Security (BIS), hat diese Software als Export Commodity Control Number (ECCN) 5D002.C.1 klassifiziert, was Informationssicherheitssoftware umfasst, die kryptografische Funktionen mit asymmetrischen Algorithmen verwendet oder ausführt. Die Form und Art dieser Apache Software Foundation-Distribution ermöglicht den Export im Rahmen der Lizenzausnahme ENC Technology Software Unrestricted (TSU) (siehe BIS Export Administration Regulations, Abschnitt 740.13) sowohl für Objektcode als auch für Quellcode.
Im Folgenden finden Sie weitere Einzelheiten zur mitgelieferten kryptografischen Software:
Diese Software verwendet Apache Commons Crypto (https://commons.apache.org/proper/commons-crypto/), um die Authentifizierung sowie die Ver- und Entschlüsselung von Daten zu unterstützen, die über das Netzwerk zwischen Diensten gesendet werden.