一键启动storm集群

• 集群部署规划：

  192.168.253.100 node-01 zk-01 kafka-01 storm-01
  192.168.253.101 node-02 zk-02 kafka-02 storm-02
  192.168.253.102 node-03 zk-03 kafka-03 storm-03

• 集群配置环境：

  #set storm env
  export STORM_HOME=/export/servers/storm
  export PATH=${STORM_HOME}/bin:$PATH

• 一键启动脚本的环境变量配置

  #set onekey env
  export OK_HOME=/export/servers/oneKey
  export PATH=${OK_HOME}/storm:$PATH

• 一键启动的目录信息

  cd /export/servers/oneKey/storm
  ll
  -rwxr--r--. 1 root root  16 Dec 23 06:33 slave
  -rwxr--r--. 1 root root 322 Dec 23 06:56 startstorm.sh
  -rwxr--r--. 1 root root 375 Dec 23 07:02 stopstorm.sh

• slave.sh文件

  node-01
  node-02
  node-03

• startstorm.sh文件

  source /etc/profile
  nohup storm nimbus >/dev/null 2>&1 &
  nohup storm ui >/dev/null 2>&1 &
  cat /export/servers/oneKey/storm/slave | while read line
  do
  {
   echo $line
   ssh $line "source /etc/profile;nohup storm supervisor >/dev/null 2>&1 &"
   ssh $line "source /etc/profile;nohup storm nimbus >/dev/null 2>&1 &"
  }&
  wait
  done

• stopstorm.sh文件

  source /etc/profile
  jps | awk '{ if( $2 == "nimbus" || $2 == "supervisor" ||  $2 == "core" ) print $1 }' |xargs kill -s 9
  cat /export/servers/oneKey/storm/slave | while read line
  do
  {
   echo $line
   ssh $line "source /etc/profile;jps |grep "Supervisor" |cut -c 1-4 |xargs kill -s 9"
   ssh $line "source /etc/profile;jps |grep "nimbus" |cut -c 1-4 |xargs kill -s 9"
  }&
  wait
  done

文章出处:http://qxu2148080263.my3w.com/index.php/archives/14/

每一个成功的背后都有无数个无人知晓的黑夜。

因为

夜晚，是超越对手的最佳时机。

===================== 码农1024 =====================#蔺光岭#