Docker-Installation von RocketMQ und Lösungen für während der Installation aufgetretene Probleme

In diesem Artikel wird hauptsächlich die Installation von rocketMQ4.4.0 vorgestellt, die im Wesentlichen in vier Schritte unterteilt ist:
1. Ziehen Sie das Rocketmq-Image.
2. Nameserv erstellen.
3. Erstellen Sie einen Brokerknoten. Ich zeige hier, wie man einen einzelnen Broker erstellt.
4. rocketMQ-Konsolendienst, der zum Verwalten der Verwaltungsschnittstelle von rocketMQ verwendet wird.

Ziehen Sie das Rocketmq-Image

Der Docker-Befehl lautet wie folgt

Docker-Pull Rocketmqinc/Rocketmq:4.4.0

Nameserv erstellen

Docker-Befehle

docker run -d --name rmqnamesrv -p 9876:9876 -v C:\data\rocketmq\logs:/root/logs -v C:\data\rocketmq\store:/root/store -e "MAX_POSSIBLE_HEAP=100000000" rocketmqinc/rocketmq:4.4.0 sh mqnamesrv

Parameter Erklärung

Erstellen eines einzelnen Brokerknotens

Docker-Befehle

docker run -d --name rmqbroker --link rmqnamesrv:namesrv -p 10911:10911 -p 10909:10909 --privileged=true -v C:\data\broker\logs:/root/logs -v C:\data\broker\store:/root/store -v C:\data\broker\conf\broker.conf:/opt/rocketmq-4.4.0/conf/broker.conf -e "NAMESRV_ADDR=namesrv:9876" -e "MAX_POSSIBLE_HEAP=200000000" rocketmqinc/rocketmq:4.4.0 sh mqbroker -c /opt/rocketmq-4.4.0/conf/broker.conf

Parameter Erklärung

Konfiguration der Datei broker.conf

#Wenn viele Knoten vorhanden sind, können Sie mehrere Broker konfigurierenClusterName = DefaultCluster
#Brokername, Master und Slave verwenden denselben Namen, was ihre Master-Slave-Beziehung anzeigt brokerName = broker-a
#0 bedeutet Master, und Werte größer als 0 bedeuten verschiedene Slaves
Broker-ID = 0
#Gibt die Zeit an, zu der die Nachricht gelöscht werden soll. Der Standardwert ist 4:00 Uhr. deleteWhen = 04
#Die Zeitspanne in Stunden, in der Nachrichten auf der Festplatte gespeichert werden sollen. fileReservedTime = 48
#Es gibt drei Werte: SYNC_MASTER, ASYNC_MASTER, SLAVE; SYNC und ASYNC stellen den Mechanismus zur Synchronisierung von Daten zwischen Master und Slave dar;
Brokerrolle = ASYNC_MASTER
#Flushing-Strategie, der Wert ist: ASYNC_FLUSH, SYNC_FLUSH bedeutet synchrones Flushing und asynchrones Flushing; die SYNC_FLUSH-Nachricht gibt erst dann einen Erfolgsstatus zurück, wenn sie auf die Festplatte geschrieben wurde, ASYNC_FLUSH wird nicht benötigt;
FlushDiskType = ASYNC_FLUSH
# Legen Sie die IP-Adresse des Servers fest, auf dem sich der Broker-Knoten befindet. namesrvAddr = lokale IP-Adresse: 9876
brokerIP1 = lokale IP-Adresse

Wenn die NamesrvAddr-Konfiguration nicht zur Konfigurationsdatei broker.conf hinzugefügt wird, wird beim Ausführen des Programms der folgende Fehler gemeldet:

Ausnahme im Thread „main“ org.apache.rocketmq.remoting.exception.RemotingTooMuchRequestException: sendDefaultImpl-Aufruf-Timeout
bei org.apache.rocketmq.client.impl.producer.DefaultMQProducerImpl.sendDefaultImpl(DefaultMQProducerImpl.java:588)
bei org.apache.rocketmq.client.impl.producer.DefaultMQProducerImpl.send(DefaultMQProducerImpl.java:1223)
bei org.apache.rocketmq.client.impl.producer.DefaultMQProducerImpl.send(DefaultMQProducerImpl.java:1173)
bei org.apache.rocketmq.client.producer.DefaultMQProducer.send(DefaultMQProducer.java:214)
bei com.baojian.mob.base.producer.SyncProducer.main(SyncProducer.java:41)
15:22:31.455 [NettyClientSelector_1] INFO RocketmqRemoting - closeChannel: schließe die Verbindung zur Remote-Adresse[] Ergebnis: true
15:22:32.049 [NettyClientSelector_1] INFO RocketmqRemoting - closeChannel: schließe die Verbindung zur Remote-Adresse[] Ergebnis: true

rocketMQ-Konsolendienst

Docker-Befehle

Sie können den Befehl „docker run“ direkt ausführen, anstatt den Befehl „docker pull“ zum Abrufen des Images zu verwenden. Wenn das Image nicht vorhanden ist, wird zuerst das Image abgerufen und dann „docker run“ ausgeführt.

docker run -d --name rmqadmin -e "JAVA_OPTS=-Drocketmq.namesrv.addr=172.16.122.115:9876 -Dcom.rocketmq.sendMessageWithVIPChannel=false" -p 8081:8080 Server/RocketMQ-Konsole-NG

Parameter Beschreibung

Nachdem der RocketMQ-Konsolenschnittstellencontainer erfolgreich ausgeführt wurde, öffnen Sie http://127.0.0.1:8081 in einem Browser, um die rokcetmq-Konsolenverwaltungsschnittstelle aufzurufen und die Clusterinformationen anzuzeigen, die darauf hinweisen, dass RocketMQ erfolgreich installiert wurde.

Fehler in der Rocketmq-Konsolenproduzentenschnittstelle

Klicken Sie auf „Suchen“ und es wird eine Fehlermeldung angezeigt, weil der Produzent nach dem Erstellen die Produktionsgruppe mit „producer.shutdown()“ schließt. Sie können sich mit dem folgenden Code abmelden.

Dies ist das Ende dieses Artikels über die Installation von rocketMQ in Docker und das Lösen von Problemen während des Installationsvorgangs. Weitere Informationen zur Installation von rocketMQ in Docker finden Sie in früheren Artikeln auf 123WORDPRESS.COM oder in den folgenden verwandten Artikeln. Ich hoffe, Sie werden 123WORDPRESS.COM auch in Zukunft unterstützen!