rocketmq
rocketmq-all-5.3.1
Apache RocketMQ は、低遅延、高いパフォーマンスと信頼性、兆レベルの容量、柔軟な拡張性を備えた分散メッセージングおよびストリーミング プラットフォームです。
さまざまな機能を提供します。
この段落では、さまざまな方法で RocketMQ をインストールする手順を説明します。ローカルでの開発とテストの場合、コンポーネントごとにインスタンスが 1 つだけ作成されます。
RocketMQ はすべての主要なオペレーティング システムで実行され、Java JDK バージョン 8 以降のインストールのみが必要です。確認するには、 java -versionを実行します。
$ java -version
java version " 1.8.0_121 " Windows ユーザーの場合は、ここをクリックして 5.2.0 RocketMQ バイナリ リリースをダウンロードし、ローカル ディスクD:rocketmqなど) に解凍します。 macOS および Linux ユーザーの場合は、次のコマンドを実行します。
# Download release from the Apache mirror
$ wget https://dist.apache.org/repos/dist/release/rocketmq/5.2.0/rocketmq-all-5.2.0-bin-release.zip
# Unpack the release
$ unzip rocketmq-all-5.2.0-bin-release.zipターミナルを準備し、抽出したbinディレクトリに移動します。
$ cd rocketmq-all-5.2.0-bin-release/bin1) ネームサーバーを起動します
NameServer は0.0.0.0:9876でリッスンし、そのポートがローカル マシン上の他のユーザーによって使用されていないことを確認してから、次の手順を実行します。
macOS および Linux ユーザーの場合:
# ## start Name Server
$ nohup sh mqnamesrv &
# ## check whether Name Server is successfully started
$ tail -f ~ /logs/rocketmqlogs/namesrv.log
The Name Server boot success...Windows ユーザーの場合は、最初に環境変数を設定する必要があります。
ROCKETMQ_HOME="D:rocketmq"を追加します。次に、ディレクトリを rocketmq に変更し、次のように入力して実行します。
$ mqnamesrv.cmd
The Name Server boot success...2) ブローカーを開始する
macOS および Linux ユーザーの場合:
# ## start Broker
$ nohup sh bin/mqbroker -n localhost:9876 &
# ## check whether Broker is successfully started, eg: Broker's IP is 192.168.1.2, Broker's name is broker-a
$ tail -f ~ /logs/rocketmqlogs/broker.log
The broker[broker-a, 192.169.1.2:10911] boot success...Windows ユーザーの場合:
$ mqbroker.cmd -n localhost:9876
The broker[broker-a, 192.169.1.2:10911] boot success...Docker コンテナ内の独自のマシンで RocketMQ を実行できます。コンテナ内のリスニング ポートを公開するためにhostネットワークが使用されます。
1) ネームサーバーを起動します
$ docker run -it --net=host apache/rocketmq ./mqnamesrv2) ブローカーを開始する
$ docker run -it --net=host --mount source=/tmp/store,target=/home/rocketmq/store apache/rocketmq ./mqbroker -n localhost:9876RocketMQ Operator を使用して、Kubernetes クラスター内で RocketMQ クラスターを実行することもできます。操作の前に、 kubectlおよび関連する kubeconfig ファイルがマシンにインストールされていることを確認してください。
1) CRD をインストールする
# ## install CRDs
$ git clone https://github.com/apache/rocketmq-operator
$ cd rocketmq-operator && make deploy
# ## check whether CRDs is successfully installed
$ kubectl get crd | grep rocketmq.apache.org
brokers.rocketmq.apache.org 2022-05-12T09:23:18Z
consoles.rocketmq.apache.org 2022-05-12T09:23:19Z
nameservices.rocketmq.apache.org 2022-05-12T09:23:18Z
topictransfers.rocketmq.apache.org 2022-05-12T09:23:19Z
# ## check whether operator is running
$ kubectl get pods | grep rocketmq-operator
rocketmq-operator-6f65c77c49-8hwmj 1/1 Running 0 93s2) クラスターインスタンスの作成
# ## create RocketMQ cluster resource
$ cd example && kubectl create -f rocketmq_v1alpha1_rocketmq_cluster.yaml
# ## check whether cluster resources is running
$ kubectl get sts
NAME READY AGE
broker-0-master 1/1 107m
broker-0-replica-1 1/1 107m
name-service 1/1 107m些細なクリーンアップ、大きな新機能、その他の重要な報酬など、新しい貢献を常に歓迎します。詳細については、こちらをご覧ください。
Apache ライセンス、バージョン 2.0 Copyright (C) Apache Software Foundation
このディストリビューションには暗号化ソフトウェアが含まれています。現在居住している国によっては、暗号化ソフトウェアの輸入、所持、使用、および他国への再輸出が制限されている場合があります。暗号化ソフトウェアを使用する前に、暗号化ソフトウェアの輸入、所持、使用、および再輸出に関するあなたの国の法律、規制、政策を確認し、これが許可されているかどうかを確認してください。詳細については、http://www.wassenaar.org/ を参照してください。
米国政府商務省産業安全保障局 (BIS) は、このソフトウェアを輸出商品管理番号 (ECCN) 5D002.C.1 として分類しました。これには、非対称アルゴリズムによる暗号化機能を使用または実行する情報セキュリティ ソフトウェアが含まれます。この Apache Software Foundation ディストリビューションの形式と方法により、オブジェクト コードとソース コードの両方について、ライセンス例外 ENC テクノロジ ソフトウェア無制限 (TSU) 例外 (BIS 輸出管理規則、セクション 740.13 を参照) に基づいて輸出の対象となります。
以下に、含まれる暗号化ソフトウェアの詳細を示します。
このソフトウェアは、Apache Commons Crypto (https://commons.apache.org/proper/commons-crypto/) を使用して、サービス間のネットワーク上で送信されるデータの認証、暗号化および復号化をサポートします。
