批处理脚本

start & stop

#! /bin/bash

# 批量操作kafka

kafka_path=/opt/local/kafka
server_list='hadoop200 hadoop201 hadoop202'

usage="Usage: $0 (start|stop)"
if [ $# -lt 1 ]; then
  echo $usage
  exit 1
fi


case $1 in
"start"){
        for i in $server_list
        do
                echo " -------- start kafka server: $i -------"
                ssh $i "source /etc/profile && $kafka_path/bin/kafka-server-start.sh -daemon $kafka_path/config/server.properties "
        done
};;
"stop"){
        for i in $server_list
        do
                echo " --------stop kafka server: $i-------"
                ssh $i "source /etc/profile && $kafka_path/bin/kafka-server-stop.sh stop"
        done
};;
esac

 

2. 批量zookeepr操作

start & stop & status

#!/bin/bash  

# 批量操作zookeeper

#服务器列表
server_list='hadoop200 hadoop201 hadoop202'
zk_path=/opt/local/zk


usage="Usage: $0 (start|stop|status)"

if [ $# -lt 1 ]; then
  echo $usage
  exit 1
fi


behave=$1

echo "$behave zkServer cluster"

for ip in $server_list  
do

    echo "----------------$behave zk server: $ip -------------------"
    ssh $ip "source /etc/profile;$zk_path/bin/zkServer.sh $behave $zk_path/conf/zoo.cfg"
    echo ""
    sleep 2s

done

exit 0

 

3. 批量查询状态

#!/bin/bash  

## 批量查询状态

server_list='hadoop200 hadoop201 hadoop202 hadoop203'


for i in $server_list
do

   echo "============================查询状态：$i ============================"
   ssh $i 'source /etc/profile;$JAVA_HOME/bin/jps '
   
done