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

Details zum Schreiben von React in einem Vue-Projekt

Wir können jsx/tsx-Dateien direkt erstellen Die P...

So verwenden Sie den Fuser-Befehl im Linux-System

Was ist Fuser Command? Der Befehl fuser ist ein s...

Welche Bilddateiformate gibt es und wie wählt man sie aus?

1. Welche drei Formate? Dies sind: gif, jpg und pn...

So legen Sie den Produktionsumgebungsmodus process.env.NODE_ENV fest

Bevor ich anfange, möchte ich betonen, dass proce...

js zur Implementierung einer Interferenz mit Verifizierungscodes (statisch)

In diesem Artikel wird der spezifische Code von j...

CSS-Schreibstandards und -Reihenfolge teilen [für alle empfohlen]

CSS-Schreibreihenfolge 1. Positionsattribute (Pos...

Delegieren von Berechtigungen in Linux mit Sudo

Einführung in die Sudo-Autoritätsdelegierung su-S...