Schritte zum Installieren einer RocketMQ-Instanz unter Linux

Schritte zum Installieren einer RocketMQ-Instanz unter Linux

1. JDK installieren

1.1 Überprüfen Sie, ob die aktuelle virtuelle Maschinenumgebung über JDK rpm -qa|grep java verfügt

1.2 Deinstallieren Sie rpm -e --nodeps xxxxxx (Ihr eigenes OpenJDK)

1.3 JDK installieren

Erstellen Sie einen neuen Java-Ordner in /usr/local und laden Sie das Tar-Paket in den Ordner hoch

Wechseln Sie zu /usr/local/java und entpacken Sie es mit tar -zxvf xxx

Konfigurieren Sie die Datei /etc/profile und fügen Sie JDK-Umgebungsvariablen hinzu

export JAVA_HOME=/usr/local/java/jdk1.8.0_121 Ersetzen Sie Ihren eigenen Pfad

export CLASSPATH=.:$JAVA_HOME/lib/dt.jar:$JAVA_HOME/lib/tools.jar

export PATH=$JAVA_HOME/bin:$PATH

Anwendungsdateiquelle /etc/profile

Verwenden Sie java -version, um die Version zu überprüfen

2. Installieren Sie RocketMQ

2.1 Konfigurieren Sie die Datei /etc/hosts und schreiben Sie die IP-Adressen der beiden Hosts

  • 192.168.42.22 rocketmq-nameserver1
  • 192.168.42.22 rocketmq-master1
  • 192.168.42.33 rocketmq-nameserver2
  • 192.168.42.33 rocketmq-master2

2.2 Starten Sie den Netzwerkkartendienst neu Netzwerkneustart

2.3 Laden Sie das komprimierte RocketMQ-Paket nach /usr/local hoch

2.4 Wechseln Sie zu /usr/local und entpacken Sie das komprimierte RocketMQ-Paket tar -zxvf xxxxxx

2.5 Ändern Sie den Namen des Dekomprimierungsordners

mv Alibaba-RocketMQ Alibaba-RocketMQ-3.2.6

2.6 Erstellen Sie einen Softlink

ln -s alibaba-rocketmq-3.2.6 rocketmq

2.7 mkdir /usr/local/rocketmq/store

mkdir /usr/local/rocketmq/store/commitlog

mkdir /usr/local/rocketmq/store/consumequeue

mkdir /usr/local/rocketmq/store/index

2.8 Laden Sie borker-a.properties und borker-b.properties nach /usr/local/recketmq/conf/2m-noslave hoch.

2.9 master01 konfiguriert borker-a.properties

brokerName=broker-a entspricht dem Dateinamen

namesrvAddr=rocketmq-nameserver1:9876;rocketmq-nameserver2:9876

master02 konfiguriert borker-b.properties

brokerName=broker-b entspricht dem Dateinamen

namesrvAddr=rocketmq-nameserver1:9876;rocketmq-nameserver2:9876

2.10 Änderungsprotokoll

mkdir -p /usr/local/rocketmq/logs

cd /usr/local/rocketmq/conf && sed -i 's#${user.home}#/usr/local/rocketmq#g' *.xml

2.11 Konfigurieren Sie JVM-Parameter und ändern Sie sie entsprechend der tatsächlichen Größe Ihrer virtuellen Maschine

vi /usr/local/rocketmq/bin/runbroker.sh

JAVA_OPT="${JAVA_OPT} -server -Xms1g -Xmx1g -Xmn512m -XX:PermSize=128m -XX:MaxPermSize=320m"

vi /usr/local/rocketmq/bin/runserver.sh

JAVA_OPT="${JAVA_OPT} -server -Xms1g -Xmx1g -Xmn512m -XX:PermSize=128m -XX:MaxPermSize=320m"

2.12 NameServer starten

cd /usr/local/rocketmq/bin

Starten Sie: nohup sh mqnamesrv &

jps prüft, ob der JDK-Prozess NamesrvStartup hat

2.13 BrokerServer starten

cd /usr/local/rocketmq/bin

master01 startet: nohup sh mqbroker -c /usr/local/rocketmq/conf/2m-noslave/broker-a.properties >/dev/null 2>&1 &

Master02 startet: nohup sh mqbroker -c /usr/local/rocketmq/conf/2m-noslave/broker-b.properties >/dev/null 2>&1 &

jps prüft, ob der JDK-Prozess BrokerStartup hat

3. Überwachen Sie den RocketMQ-Status über die Konsole

3.1 Laden Sie das komprimierte Tomcat-Paket auf die virtuelle Maschine hoch und dekomprimieren Sie es /usr/local tar -zxvf xxxx Dekomprimierung

3.2 Laden Sie rocketmq-web-console.war in das Webapps-Verzeichnis des Tomcat-Dekomprimierungsverzeichnisses hoch

3.3 Tomcat starten

Wechseln Sie zu /usr/local/apache-tomcat-7.0.65/bin

./startup.sh startet ./shutdown.sh stoppt

3.4 Ändern Sie die entpackte RocketMQ-Web-Konsole

/usr/local/apache-tomcat-7.0.65/webapps/rocketmq-web-console/WEB-INF/classes/config.properties-Konfigurationsdatei

Konfiguration:

rocketmq.namesrv.addr=192.168.42.22:9876;192.168.42.33:9876

throwDone=true

3.5 Die Firewalls beider Rechner sind ausgeschaltet

systemctl stoppe firewalld.service

systemctl deaktivieren Sie Firewalld.service

Nach Abschluss der Konfiguration greift die Webseite auf die Konsole zu. Der Effekt ist wie folgt

Oben sind alle relevanten Wissenspunkte, die dieses Mal vorgestellt werden. Sie können ihnen folgen, um zu lernen. Vielen Dank für Ihre Unterstützung von 123WORDPRESS.COM.

Das könnte Sie auch interessieren:
  • Elegantes Spring Boot-Beispiel für die Verwendung der RocketMQ-Methode
  • Implementierung der Java RocketMQ-Routing-Registrierung und -Löschung
  • Beispielcode zur Implementierung verzögerter Nachrichten mit Kotlin+RocketMQ
  • RocketMQ-Verbrauchslastausgleich – Push-Verbrauchsdetails
  • Detaillierte Schritte zum Erstellen und Bereitstellen von RocketMQ unter Windows
  • Java RocketMQ – Schnellstart-Grundlagen
  • Detaillierte Installation und Verwendung von RocketMQ in Docker
  • SpringBoot integriert RocketMQ und Beispielcode für Fallstricke
  • Ein kurzer Vortrag über die Erfahrungen mit der Integration von Springboot in RocketMQ
  • RocketMQ-Wiederholungsmechanismus und Analyse des Message Power-Codebeispiels

<<:  Grafisches Tutorial zur Installation und Konfiguration der Dekomprimierungsversion von MySQL 8.0.17

>>:  So wechseln Sie zwischen Vue-Produktions- und Entwicklungsumgebungen und verwenden Filter

Artikel empfehlen

Tutorial zur Installation von VMware, Nmap und Burpsuite

Inhaltsverzeichnis VMware BurpSuite 1. Virtuelles...

Lösung für den MySQL-Fehlercode 1064

Wenn die Wörter in der SQL-Anweisung mit den Schl...

CocosCreator Skelettanimation Drachenknochen

CocosCreator Version 2.3.4 Drachenknochenanimatio...

Grundlegendes Nutzungs-Tutorial zur IPTABLES-Firewall unter LINUX

Vorwort Für Produktions-VPS mit öffentlicher IP w...

Details zum MySQL-Index-Pushdown

Inhaltsverzeichnis 1. Prinzip des ganz linken Prä...

So verwenden Sie das VS2022-Remote-Debugging-Tool

Manchmal müssen Sie bei der Arbeit ein Remote-Deb...

So legen Sie in Linux eine feste IP fest (getestet und effektiv)

Öffnen Sie zunächst die virtuelle Maschine Öffnen...

Detaillierte Erklärung der Docker-Datenspeichervolumes

Standardmäßig erfolgt das Lesen und Schreiben von...

Einfaches MySQL-Beispiel zum Sortieren chinesischer Schriftzeichen nach Pinyin

Wenn das Feld, in dem der Name gespeichert ist, d...

So konfigurieren Sie SSH für die Anmeldung bei Linux mit Git Bash

1. Generieren Sie zunächst die öffentlichen und p...

Eine kurze Analyse des Kimono-Memo-Problems

Heute musste ich nach dem Neustart des Spiels fes...