storm一鍵腳本

1一鍵腳本

#!/bin/bash # 1 聲明 #-------------------------------------- #請在strom/bin/下執行腳本 #supervisor-hosts:配置supervisor的主機名,請自行配置 #BASH_PATH 須要自行配置 #-------------------------------------- BASH_PATH=/root/apps/storm-1.1.1 cd $BASH_PATH/bin # 2 建立啓動腳本文件 touch start-supervisor.sh touch start-storm.sh touch stop-supervisor.sh touch stop-storm.sh touch supervisor-hosts # 3 賦予執行權限 chmod +x *.sh # 4 start-supervisor.sh cat>start-supervisor.sh<<EOF #!/bin/bash $BASH_PATH/bin/storm supervisor >/dev/null 2>&1 & EOF # 5 start-storm.sh cat>start-storm.sh<<EOF #!/bin/bash $BASH_PATH/bin/storm nimbus >/dev/null 2>&1 & $BASH_PATH/bin/storm ui >/dev/null 2>&1 & cat $BASH_PATH/bin/supervisor-hosts | while read supervisor do echo "\$supervisor is start..." ssh \$supervisor $BASH_PATH/bin/start-supervisor.sh & done EOF # 6 stop-supervisor.sh cat>stop-supervisor.sh<<EOF #!/bin/bash kill -9 `ps -ef|grep daemon.supervisor| awk '{print $2}'` # 選擇是否清除工做目錄文件 #rm -rf /software/storm/workdir/* EOF # 7 stop-storm.sh cat>stop-storm.sh<<EOF #!/bin/bash kill -9 `ps -ef|grep daemon.nimbus| awk '{print $2}'` kill -9 `ps -ef|grep ui.core| awk '{print $2}'` cat $BASH_PATH/bin/supervisor-hosts | while read supervisor do echo "\$supervisor is stop ..." ssh \$supervisor $BASH_PATH/bin/stop-supervisor.sh & done EOF # 8 supervisor-hosts cat>supervisor-hosts<<EOF mini1 mini2 mini3 EOF

x

 

1

#!/bin/bash

2

3

# 1 聲明

4

#--------------------------------------

5

#請在strom/bin/下執行腳本

6

#supervisor-hosts:配置supervisor的主機名,請自行配置

7

#BASH_PATH 須要自行配置

8

#--------------------------------------

9

BASH_PATH=/root/apps/storm-1.1.1

10

cd $BASH_PATH/bin

11

# 2 建立啓動腳本文件

12

touch start-supervisor.sh

13

touch start-storm.sh

14

touch stop-supervisor.sh

15

touch stop-storm.sh

16

touch supervisor-hosts

17

18

# 3 賦予執行權限

19

chmod +x *.sh

20

21

# 4 start-supervisor.sh

22

cat>start-supervisor.sh<<EOF

23

#!/bin/bash

24

$BASH_PATH/bin/storm supervisor >/dev/null 2>&1 &

25

EOF

26

27

# 5 start-storm.sh

28

cat>start-storm.sh<<EOF

29

#!/bin/bash

30

$BASH_PATH/bin/storm nimbus >/dev/null 2>&1 &

31

$BASH_PATH/bin/storm ui >/dev/null 2>&1 &

32

cat $BASH_PATH/bin/supervisor-hosts | while read supervisor

33

do

34

    echo "\$supervisor is start..."

35

    ssh \$supervisor $BASH_PATH/bin/start-supervisor.sh &

36

done

37

EOF

38

39

# 6 stop-supervisor.sh

40

cat>stop-supervisor.sh<<EOF

41

#!/bin/bash

42

kill -9 `ps -ef|grep daemon.supervisor| awk '{print $2}'`

43

# 選擇是否清除工做目錄文件

44

#rm -rf /software/storm/workdir/*

45

EOF

46

47

# 7 stop-storm.sh

48

cat>stop-storm.sh<<EOF

49

#!/bin/bash

50

kill -9 `ps -ef|grep daemon.nimbus| awk '{print $2}'`

51

kill -9 `ps -ef|grep ui.core| awk '{print $2}'`

52

cat $BASH_PATH/bin/supervisor-hosts | while read supervisor

53

do

54

    echo "\$supervisor is stop ..."

55

    ssh \$supervisor $BASH_PATH/bin/stop-supervisor.sh &

56

done

57

EOF

58

59

# 8 supervisor-hosts

60

cat>supervisor-hosts<<EOF

61

mini1

62

mini2

63

mini3

64

EOF

2使用

# 1 將上文編輯好的start-supervisor和stop-supervisor腳本複製到全部節點相同路徑下 scp *-supervisor.sh mini2:$PWD scp *-supervisor.sh mini3:$PWD scp *-supervisor.sh mini4:$PWD # 2 配置環境變量 #vim /etc/profile STORM_HOME=/root/apps/storm-1.1.1 PATH=$PATH:$STORM_HOME/bin export STORM_PATH PATH source /etc/profile # 3 啓動集羣中全部節點supervisor進程，並在主節點上啓動nimbus和ui進程 start-storm.sh # 4 中止集羣中全部節點supervisor進程,並中止nimbus和ui進程 stop-storm.sh

17

 

1

# 1 將上文編輯好的start-supervisor和stop-supervisor腳本複製到全部節點相同路徑下

2

scp *-supervisor.sh mini2:$PWD

3

scp *-supervisor.sh mini3:$PWD

4

scp *-supervisor.sh mini4:$PWD

5

6

# 2 配置環境變量 

7

#vim /etc/profile

8

STORM_HOME=/root/apps/storm-1.1.1

9

PATH=$PATH:$STORM_HOME/bin

10

export STORM_PATH PATH

11

12

source /etc/profile

13

# 3 啓動集羣中全部節點supervisor進程，並在主節點上啓動nimbus和ui進程

14

start-storm.sh

15

16

# 4 中止集羣中全部節點supervisor進程,並中止nimbus和ui進程

17

stop-storm.sh

3添加開啓啓動

# 開機自動運行下以前的start-all腳本，設置方法以下 vi /etc/rc.d/rc.local # 添加執行腳本 #!/bin/sh # # This script will be executed *after* all the other init scripts. # You can put your own initialization stuff in here if you don't # want to do the full Sys V style init stuff. touch /var/lock/subsys/local sh /root/apps/storm-1.1.1/bin/start-storm.sh

x

 

1

# 開機自動運行下以前的start-all腳本，設置方法以下

2

vi /etc/rc.d/rc.local 

3

4

# 添加執行腳本

5

#!/bin/sh

6

#

7

# This script will be executed *after* all the other init scripts.

8

# You can put your own initialization stuff in here if you don't

9

# want to do the full Sys V style init stuff.

10

11

touch /var/lock/subsys/local

12

sh /root/apps/storm-1.1.1/bin/start-storm.sh