这里以三台结点为例
首先进入/root/bin目录下

cd /root/bin
1

---

查看所有结点的java进程（jpsall）

创建jpsal文件

vim jpsall
1

输入以下内容

#!/bin/bash
for host in master node1 node2
do
	echo =============== $host ===============
	ssh $host jps 
done

1
2
3
4
5
6
7

给jpsall文件赋权限

chmod 777 jpsall
1

使用以下命令运行

jasall
1

---

重启所有结点(reboot.sh)

创建reboot.sh文件

vim reboot.sh
1

输入以下内容

#!/bin/bash
for i in node2 node1 master
do
	echo ============== $i 重启 =============
	ssh $i "sudo reboot"
	sleep 1s;
done

1
2
3
4
5
6
7
8

给reboot.sh文件赋权限

chmod 777 reboot.sh
1

使用以下命令运行

reboot.sh
1

---

关闭所有结点(shutdown.sh)

创建shutdown.sh文件

vim shutdown.sh
1

输入以下内容

#!/bin/bash
for i in node2 node1 master
do
	echo ============= $i 关机 =============
	ssh $i "sudo shutdown -h now"
	sleep 1s;
done

1
2
3
4
5
6
7
8

给shutdown.sh文件赋权限

chmod 777 shutdown.sh
1

使用以下命令运行

shutdown.sh
1

---

同步文件到其他结点(xsync)

创建xsync文件

vim xsync
1

输入以下内容

#!/bin/bash
#1. 判断参数个数
if [ $# -lt 1 ]
then
    echo Not Enough Arguement!
    exit;
fi

#2. 遍历集群所有机器
for host in master node1 node2
do
    echo ====================  $host  ====================
    #3. 遍历所有目录，挨个发送

    for file in $@
    do
        #4. 判断文件是否存在
        if [ -e $file ]
            then
                #5. 获取父目录
                pdir=$(cd -P $(dirname $file); pwd)

                #6. 获取当前文件的名称
                fname=$(basename $file)
                ssh $host "mkdir -p $pdir"
                rsync -av $pdir/$fname $host:$pdir
            else
                echo $file does not exists!
        fi
    done
done

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32

给xsync文件赋权限

chmod 777 xsync
1

使用以下命令运行

xsync 文件路径
1

---

ZooKeeper集群的启动、关闭和状态(zk.sh)

创建zk.sh文件

vim zk.sh
1

输入以下内容

#!/bin/bash
if [ $# -lt 1 ]
 then 
   echo "NO Args Input Error!!!"
   exit     
fi
case $1 in
"start") {
	for i in master node1 node2
	do
		echo ============= zookeeper $i 启动 =============
		ssh $i "source /etc/profile;/usr/local/soft/zookeeper-3.4.6/bin/zkServer.sh start"
	done
}
;;
"stop") {
	for i in master node1 node2
	do
		echo ============= zookeeper $i 停止 =============
		ssh $i "source /etc/profile;/usr/local/soft/zookeeper-3.4.6/bin/zkServer.sh stop"
	done
}
;;
"status") {
	for i in master node1 node2
	do
		echo ============= zookeeper $i 状态 =============
		ssh $i "source /etc/profile;/usr/local/soft/zookeeper-3.4.6/bin/zkServer.sh status"
	done
}
;;
*)
echo "Input args Error!!"
;;
esac

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36

给zk.sh文件赋权限

chmod 777 zk.sh
1

使用以下命令运行

zk.sh start
zk.sh status
zk.sh stop
1
2
3

---

kafka集群的启动和关闭(kk.sh)

创建kk.sh文件

vim kk.sh
1

输入以下内容

#!/bin/bash
case $1 in
"start"){
        for i in master node1 node2
                do
                        echo ========$i 启动kafka========
                        ssh $i "source /etc/profile;/usr/local/soft/kafka_2.11-1.0.0/bin/kafka-server-start.sh -daemon /usr/local/soft/kafka_2.11-1.0.0/config/server.properties"
                done
};;
"stop"){
        for i in master node1 node2
                do
                        echo ========$i 停止kafka========
                        ssh $i "source /etc/profile;/usr/local/soft/kafka_2.11-1.0.0/bin/kafka-server-stop.sh stop"
                done
};;
esac

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18

给kk.sh文件赋权限

chmod 777 kk.sh
1

使用以下命令运行

kk.sh start
kk.sh stop
1
2

---