RocketMQ の Docker インストールとインストール中に発生した問題の解決策

この記事では主にrocketMQ4.4.0のインストールについて紹介します。インストールは主に4つのステップに分かれています。
1. rocketmq イメージをプルします。
2. namesrv を作成します。
3. ブローカーノードを作成します。ここで紹介するのは、単一のブローカーを作成する方法です。
4. rocketMQ-console サービス。rocketMQ の管理インターフェイスを管理するために使用されます。

rocketmqイメージを取得する

dockerコマンドは以下のとおりです

docker pull rocketmqinc/rocketmq:4.4.0

名前rvを作成する

Docker コマンド

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

パラメータの説明

単一のブローカーノードを作成する

Docker コマンド

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

パラメータの説明

broker.conf ファイルの設定

#ノードが多数ある場合は、複数のbrokerClusterName = DefaultClusterを設定できます
#ブローカー名、マスターとスレーブは同じ名前を使用し、マスターとスレーブの関係を示します。brokerName = broker-a
#0はマスターを意味し、0より大きい値は異なるスレーブを意味します
ブローカーID = 0
#メッセージを削除する時刻を示します。デフォルトは午前 4:00 です。deleteWhen = 04
#メッセージをディスク上に保持する時間の長さ（時間単位） fileReservedTime = 48
# 値は SYNC_MASTER、ASYNC_MASTER、SLAVE の 3 つです。SYNC と ASYNC は、マスターとスレーブ間でデータを同期するメカニズムを表します。
ブローカーロール = ASYNC_MASTER
#フラッシュ戦略、値: ASYNC_FLUSH、SYNC_FLUSH は同期フラッシュと非同期フラッシュを意味します。SYNC_FLUSH メッセージは、ディスクに書き込まれた後にのみ成功ステータスを返します。ASYNC_FLUSH は必要ありません。
フラッシュディスクタイプ = ASYNC_FLUSH
# ブローカーノードが配置されているサーバーの IP アドレスを設定します namesrvAddr = ローカル IP アドレス: 9876
brokerIP1 = ローカルIPアドレス

namesrvAddr 構成が broker.conf 構成ファイルに追加されていない場合、プログラムの実行時に次のエラーが報告されます。

スレッド「main」で例外が発生しました org.apache.rocketmq.remoting.exception.RemotingTooMuchRequestException: sendDefaultImpl 呼び出しがタイムアウトしました
org.apache.rocketmq.client.impl.producer.DefaultMQProducerImpl.sendDefaultImpl(DefaultMQProducerImpl.java:588) で
org.apache.rocketmq.client.impl.producer.DefaultMQProducerImpl.send(DefaultMQProducerImpl.java:1223) で
org.apache.rocketmq.client.impl.producer.DefaultMQProducerImpl.send(DefaultMQProducerImpl.java:1173) で
org.apache.rocketmq.client.producer.DefaultMQProducer.send(DefaultMQProducer.java:214) で
com.baojian.mob.base.producer.SyncProducer.main(SyncProducer.java:41) で
15:22:31.455 [NettyClientSelector_1] INFO RocketmqRemoting - closeChannel: リモートアドレス[]への接続を閉じます。結果: true
15:22:32.049 [NettyClientSelector_1] INFO RocketmqRemoting - closeChannel: リモートアドレス[]への接続を閉じます。結果: true

rocketMQ-console サービス

Docker コマンド

イメージをプルするために docker pull コマンドを使用する代わりに、docker run コマンドを直接実行することもできます。イメージが存在しない場合は、まずイメージがプルされ、次に docker run が実行されます。

docker run -d --name rmqadmin -e "JAVA_OPTS=-Drocketmq.namesrv.addr=172.16.122.115:9876 -Dcom.rocketmq.sendMessageWithVIPChannel=false" -p 8081:8080 pangliang/rocketmq-console-ng

パラメータの説明

rocketmq-console インターフェース コンテナーが正常に実行されたら、ブラウザーを使用して http://127.0.0.1:8081 を開き、rokcetmq-console 管理インターフェースに入り、rocketmq が正常にインストールされたことを示すクラスター情報を確認します。

Rocketmq-console プロデューサー インターフェース エラー

「検索」をクリックすると、プロデューサーがプロダクション グループを作成した後に producer.shutdown() を使用してプロダクション グループを閉じるため、エラー メッセージが表示されます。次のコードを使用してログアウトできます。

これで、docker に rocketMQ をインストールし、インストール プロセス中に発生した問題を解決する方法についての記事は終了です。docker に rocketMQ をインストールする方法の詳細については、123WORDPRESS.COM の以前の記事を検索するか、次の関連記事を引き続き参照してください。今後とも 123WORDPRESS.COM をよろしくお願いいたします。