Stormの――どのようにしてトポロジまたはJarをクラスタに包むか?

1512 ワード

転載は出典を明記してください.http://blog.csdn.net/l1028386804/article/details/79408361
Stormの開発環境において、トポロジをクラスタに提出し、主なステップは以下の通りである.
1、Storm発行版の解凍をダウンロードし、Storm環境変数を設定する.
Stormの安定したバージョンをダウンロードして解凍します.解凍後のディレクトリはSTORM_です.HOME、STORMをHOMEは環境変数に配置されています.STORM_ホームは、システム環境変数/etc/profileに配置することができ、ユーザ環境変数~/.bashrcファイルに配置することもできます.構成内容は以下の通りです.
export STORM_HOME=/opt/storm
export PATH=$PATH:$STORM_HOME/bin
のうち、STORM_HOMEは実際の状況によって修正できます.
2、設定~/.storm/storm.yamlファイルはリモートStormクラスタのTopologyを起動して停止するために、クラスタ情報を~/.storm/storm.yamlファイルに配置する必要があります.
~/.storm/storm.yamlファイルには主に次の行の内容が含まれています.
nimbus.host: "nimbusIP"
は、実際のNimbusホストのホスト名またはIPアドレスにnimbusIPを置き換える必要がある.
簡単な作成~/.storm/storm.yamlファイルの命令は以下の通りです.
mkdir -p ~/.storm; echo 'nimbus.host: "nimbusIP"' > ~/.storm/storm.yaml
3、具体例
例えばstorm-jar.jarをStormクラスタに提出する場合、まずLinux端末の下でStormのプロファイルが存在するかどうかを確認し、コマンドは以下の通りです.
cat ~/.storm/storm.yaml
ファイルが存在しない場合やNimbusの設定内容が間違っている場合は、Nimbusのホスト名またはIPアドレスをstorm.yamlプロファイルに書き込むように命令します.
rm -rf ~/.storm
mkdir -p ~/.storm
echo 'nimbus.host: "nimbusIP"' > ~/.storm/storm.yaml
では、nimbusIPがNimbusのホスト名またはIPアドレスである.
最後に以下のStormコマンドを実行して、jarにStormクラスタにパケットを提出します.
storm jar storm-jar.jar com.lyz.MyTopology mytopology
その中で、storm jarはコマンドキーで、storm-jar.jarは私達のプログラムが打ったjarカバンで、comp.lyz.MyTopologyは私達のプログラムの入り口の主な種類で、mytopologyは位相の名称です.