私は最近 RocketMQ の使い方を学び、RocketMQ サーバーを構築する必要がありました。この記事では主に RocketMQ の構築プロセスと、このプロセスで遭遇したいくつかの落とし穴を記録します。 準備ビルドする前に、いくつか準備が必要です。ここでは、docker を使用してサービスをビルドする必要があるため、事前に docker をインストールする必要があります。なお、rocketmq ではブローカーとネームサーバーの導入が必要であり、別途導入するのは面倒であることを考慮して、ここでは docker-compose を使用します。 rocketmq のアーキテクチャ図は次のとおりです。 さらに、MQ サービスのステータスとメッセージの消費を監視するための Web 視覚化コンソールを構築する必要もあります。ここでは Rocketmq-console が使用され、プログラムも docker を使用してインストールされます。 展開プロセスまず、rocketmq docker イメージが必要です。ここでは、自分で作成することを選択できます。[email protected]:apache/rocketmq-docker.git を直接プルして、イメージを作成します。 Docker Hub の公式イメージを直接使用することもできます。イメージ名は 次に、MQ 構成ファイル ブローカークラスタ名 = デフォルトクラスタ ブローカー名 = ブローカー-a ブローカーID = 0 削除時 = 04 ファイル予約時間 = 48 ブローカーロール = ASYNC_MASTER フラッシュディスクタイプ = ASYNC_FLUSH # ローカルプログラムがクラウドホストのMQを呼び出す場合は、これをクラウドホストのIPに設定する必要があります ブローカーIP1=10.10.101.80 次のフォルダーを作成します: バージョン: '2' サービス: 名前rv: 画像: rocketmqinc/rocketmq コンテナ名: rmqnamesrv ポート: -9876:9876 ボリューム: - /opt/rocketmq/logs:/home/rocketmq/logs - /opt/rocketmq/store:/home/rocketmq/store コマンド: sh mqnamesrv ブローカ: 画像: rocketmqinc/rocketmq コンテナ名: rmqbroker ポート: - 10909:10909 - 10911:10911 - 10912:10912 ボリューム: - /opt/rocketmq/logs:/home/rocketmq/logs - /opt/rocketmq/store:/home/rocketmq/store - /opt/rocketmq/conf/broker.conf:/opt/rocketmq-4.4.0/conf/broker.conf #コマンド: sh mqbroker -n namesrv:9876 コマンド: sh mqbroker -n namesrv:9876 -c ../conf/broker.conf 依存: -名前 環境: JAVA_HOME = /usr/lib/jvm/jre コンソール: 画像: styletang/rocketmq-console-ng コンテナ名: rocketmq-console-ng ポート: -8087:8080 依存: -名前 環境: -JAVA_OPTS= -Dlogging.level.root=info -Drocketmq.namesrv.addr=rmqnamesrv:9876 - Dcom.rocketmq.sendMessageWithVIPChannel=false 注記 ここで注意すべき点は、rocketmq ブローカーと rokcetmq-console の両方が rokcetmq ネームサーバーに接続する必要があり、ネームサーバーの IP を知っておく必要があることです。 docker-compose を使用すると、上記 3 つの Docker コンテナが一緒にオーケストレーションされます。ネーム サーバ コンテナ名 rmqnamesrv など、コンテナ IP の代わりにコンテナ名を直接使用できます。 設定が完了したら、docker-compose up を実行して 3 つのコンテナを起動します。起動に成功したら、ip:8087 にアクセスして、mq 外部コンソールを確認します。次の情報が表示されれば、rocketmq サービスが正常に起動しています。 RocketMQ の初体験ここでは、Springboot を使用して MQ をすぐに使い始めるため、 <!--pom.xml に依存関係を追加する--> <依存関係> <グループ ID>org.apache.rocketmq</グループ ID> <artifactId>rocketmq-spring-boot-starter</artifactId> <バージョン>2.0.3</バージョン> </依存関係> コンシューマー サービス センダーは次のように構成されます。 ## アプリケーション.プロパティ rocketmq.name-server=ip:9876 rocketmq.producer.group=私のグループ 消費者サービス送信者の手順は次のとおりです。 @SpringBootアプリケーション パブリッククラス ProducerApplication は CommandLineRunner を実装します { @リソース プライベート RocketMQTemplate rocketMQTemplate; パブリック静的void main(String[] args){ SpringApplication.run(ProducerApplication.class、引数); } パブリック void run(String...args) 例外をスローします { rocketMQTemplate.convertAndSend("test-topic-1", "Hello, World!"); rocketMQTemplate.send("test-topic-1", MessageBuilder.withPayload("Hello, World! 私は Spring のメッセージから来ました").build()); } } メッセージ コンシューマーの構成は次のとおりです。 ## アプリケーション.プロパティ rocketmq.name-server=ip:9876 メッセージ コンシューマーは次のプログラムを実行します。 @SpringBootアプリケーション パブリッククラス ConsumerApplication{ パブリック静的void main(String[] args){ SpringApplication.run(ConsumerApplication.class、引数); } 翻訳者 @サービス @RocketMQMessageListener(トピック = "test-topic-1", コンシューマーグループ = "my-consumer_test-topic-1") パブリック静的クラス MyConsumer1 は RocketMQListener<String> を実装します { パブリックvoid onMessage(文字列メッセージ) { log.info("受信したメッセージ: {}", message); } } } 関連する質問メッセージ送信者は この例外は、brokerip が正しく設定されていないために発生します。ブローカー構成情報を表示するには、mq サービス コンソールにログインしてください。 上記の MQ コンソールでは MQ サービス情報を正常に表示できません。 この問題は主に、ネームサーバーの IP 設定が正しくないことが原因で発生します。現時点で接続されているネームサーバーのアドレス情報を確認するには、MQ コンソールの操作とメンテナンス ページを確認してください。 ここで設定されているアドレスは ここでは、Docker で環境変数を設定する必要があります。設定は次のとおりです。 -JAVA_OPTS= -Dlogging.level.root=info -Drocketmq.namesrv.addr=rmqnamesrv:9876 ヘルプドキュメントロケットMQドッカー 著者:Leo_wl 出典: http://www.cnblogs.com/Leo_wl/ Docker rocketmq デプロイメントの実装例に関するこの記事はこれで終わりです。より関連性の高い Docker rocketmq デプロイメントのコンテンツについては、123WORDPRESS.COM の以前の記事を検索するか、以下の関連記事を引き続き参照してください。今後とも 123WORDPRESS.COM をよろしくお願いいたします。 以下もご興味があるかもしれません:
|
<<: モバイル Web WAP には Bootstrap と jQuery Mobile のどちらを使用すべきか
>>: mysql-connector-java8.0.27 へのアップグレードに関する注意事項
Ubuntu 18.04の場合1. sudo apt install python 。コマンドライン...
目次1.watchは一般的なデータ(数値、文字列、ブール値)の変更を監視します。 1. 数値2. 文...
目次1. プロキシとは何ですか? 2. 使い方は? 1. プロキシを使用する簡単な例2. 対象オブジ...
html 、アドレス、引用、本文、 dd 、 div 、 dl 、 dt 、フィールドセット、フォ...
この記事では、ホイール抽選を簡単に実装するためのVueの具体的なコードを参考までに共有します。具体的...
この記事では、参考までにMYSQLログとバックアップとリストアについて紹介します。具体的な内容は以下...
最近、分散型およびビッグデータ技術について学ぶために、いくつかの仮想マシンに取り組んでいます。まず、...
まず、docker に openssh-server をインストールします。インストールが完了したら...
Microsoft は T4 テンプレートを提供していますが、使用するのが非常に難しいと思います。ス...
さまざまな色の16進コード表[パート1] 赤とピンク、およびそれらの 16 進コード。 #99003...
目次1. ステートメントを挿入する1.1 行を挿入する1.2 複数行を挿入する1.3 クエリステート...
この記事では、jQueryプラグインを使用したマインスイーパゲームの最初の記事の具体的なコードを参考...
システム環境: Windows 7 1. DockerをインストールするDocker公式サイトからd...
ネイティブJSによって開始されたネットワークリクエストは、クエリ文字列の形でサーバーに送信されるため...
序文Vue Router は、Vue.js の公式ルーティング マネージャーです。 Vue.js の...