linux下ssh到目標機器首先需要配置免密碼登陸，才能執行如下指令碼

  hostnames伺服器列表檔案

master.hadoop
w1.hadoop
w2.hadoop
w3.hadoop
w4.hadoop

#!/bin/bash

function usage() {
   echo "Wrong arguments input..."
   echo "Usage: `basename $0` topicName handler[lookup|kill]" >&2
   echo "   eg: `basename $0` service_log lookup"
   exit 1
}

topic_array=("service_log" "service_log_nh" "service_log_agent" "service_log_flow" \
             "service_log_rec" "search_log" "user_trace" "user_trace_internal")
handler_array=("lookup" "kill")


if [ $# -lt 2 ]; then
   usage
fi

topic=$1
handler=$2

## flume agent處理方式判斷 
if echo "${handler_array[@]}" | grep -w "$handler" &>/dev/null; then
   echo "Fount process handler: $handler"
else
   echo "Not found process handler: $handler ...."
   usage
fi

## 判斷是否為需要處理的flume agent名稱
if echo "${topic_array[@]}" | grep -w "$topic" &>/dev/null; then
   echo "Fount flume agent name: $topic"
else
   echo "Not found flume agent name: $topic ...."
   usage
fi


## 根據handler名稱處理flume agent
hosts='hostnames'  # hostname列表檔案

while read line
do
  hostname=$line
  echo "================ $hostname ============="
  case $handler in
       lookup)
         ssh 
 
[email protected]$hostname -nq "ps -ef | grep flume | grep -w $topic | grep -v grep | wc -l"
       ;;
       kill)
         ssh [email protected]$hostname -nq "ps -ef | grep flume | grep -w $topic |awk '{print $2}' |xargs kill -15"
       ;;
       *)
         usage
       ;;
  esac
done  < $hosts