最近學(xué)習(xí)大數(shù)據(jù) 每次到要啟動(dòng)很多東西 每次一個(gè)個(gè)啟動(dòng) 特別費(fèi)勁 于是寫了一個(gè)腳本 一起啟動(dòng)

腳本如下

腳本的原理是檢測(cè)是否 參數(shù)包含要啟動(dòng)類目

realtime-0317.sh hdfs hbase 包含hdfs hbase 于是 就去啟動(dòng) hdfs hbase

image.png

#!/bin/bash
echo -e " 歡迎使用實(shí)時(shí)項(xiàng)目配套腳本，這個(gè)腳本可以讓你直接啟動(dòng)\033[41;33m hdfs hbase zk kafka canal jartomcat \033[0m 你可以根據(jù)自己的選擇啟動(dòng) !" 

## 需要執(zhí)行的服務(wù)器 單機(jī)的話是102 
mHost=hadoop102

## 全部需要執(zhí)行
mHostList[0]=hadoop102
mHostList[1]=hadoop103
mHostList[2]=hadoop104


out_no="參數(shù)不對(duì)，大俠請(qǐng)重新來過！"

#########################################  HDFS  ######################################
# 啟動(dòng)HDFS
function hdfs_start()
{
    for host in $mHost  ; do
        echo "在 $host 啟動(dòng)hdfs集群" 
         ssh $host "source /etc/profile; start-dfs.sh"
    done
}

# 關(guān)閉HDFS
function hdfs_stop()
{
   for host in $mHost  ; do
        echo "在 $host 關(guān)閉hdfs集群"
        ssh $host "source /etc/profile; stop-dfs.sh"
    done
}

# Hdfs
function Hdfs(){
    flot=1;

while [[ $flot -eq 1 ]]; do
    read -p "請(qǐng)問是否需要啟動(dòng)或者關(guān)閉hdfs? yes/no/un " hdfs 
        echo $hdfs

        case $hdfs in
        "yes")
            hdfs_start;
             let flot++;
            ;;
        "no")
            hdfs_stop;
             let flot++;
            ;;
         "un")
            echo "不執(zhí)行任何操作"
             let flot++;
            ;;
        *)
            echo $out_no
            echo '參數(shù)只能是 yes|no|un'
            ;;
        esac

done
}

#########################################  hbase  ######################################

# 啟動(dòng)hbase
function hbase_start()
{
    for host in $mHost  ; do
        echo "在 $host 啟動(dòng)hdfs集群" 
        ssh $host "source /etc/profile; cd $HBASE_HOME; bin/start-hbase.sh"
    done
}

# 關(guān)閉hbase
function hbase_stop()
{
   for host in $mHost  ; do
        echo "在 $host 關(guān)閉hdfs集群"
       ssh $host "source /etc/profile; cd $HBASE_HOME; bin/stop-hbase.sh"
    done
}

# hbase
function Hbase(){
    flot=1;

while [[ $flot -eq 1 ]]; do
    read -p "請(qǐng)問是否需要啟動(dòng)或者關(guān)閉Hbase? yes/no/un " hbase 
        echo $hbase

        case $hbase in
        "yes")
            hbase_start;
             let flot++;
            ;;
        "no")
            hbase_stop;
             let flot++;
            ;;
         "un")
            echo "不執(zhí)行任何操作"
             let flot++;
            ;;
        *)
            echo $out_no
            echo '參數(shù)只能是 yes|no|un'
            ;;
        esac
done
}

#########################################  zk  ######################################

# 啟動(dòng)zk
function zk_start()
{
    
    for host in hadoop102 hadoop103 hadoop104   ; do
        echo "在 $host 啟動(dòng)zk服務(wù)" 
        ssh $host /opt/module/zookeeper-3.5.7/bin/zkServer.sh start  
    done
}

# 關(guān)閉zk
function zk_stop()
{
   for host in hadoop102 hadoop103 hadoop104  ; do
        echo "在 $host 關(guān)閉zk服務(wù)"
        ssh $host /opt/module/zookeeper-3.5.7/bin/zkServer.sh stop
    done
}

# ZK
function Zk(){
    flot=1;

while [[ $flot -eq 1 ]]; do
    read -p "請(qǐng)問是否需要啟動(dòng)或者關(guān)閉zk? yes/no/un " zk 
        echo $zk

        case $zk in
        "yes")
            zk_start;
             let flot++;
            ;;
        "no")
            zk_stop;
             let flot++;
            ;;
         "un")
            echo "不執(zhí)行任何操作"
             let flot++;
            ;;
        *)
            echo $out_no
            echo '參數(shù)只能是 yes|no|un'
            ;;
        esac
done
}


#########################################  kafka  ######################################

# 啟動(dòng)kafka
function kafka_start()
{
    
    for host in hadoop102 hadoop103 hadoop104   ; do
        echo "在 $host 啟動(dòng)kafka服務(wù)" 
        ssh $host /opt/module/kafka/bin/kafka-server-start.sh  -daemon /opt/module/kafka/config/server.properties 
    done
}

# 關(guān)閉kafka
function kafka_stop()
{
   for host in hadoop102 hadoop103 hadoop104  ; do
        echo "在 $host 關(guān)閉kfka服務(wù)"
        ssh $host /opt/module/kafka/bin/kafka-server-stop.sh
    done
}

# kafka
function Kafka(){
    flot=1;

while [[ $flot -eq 1 ]]; do
    read -p "請(qǐng)問是否需要啟動(dòng)或者關(guān)閉kafka? yes/no/un " kafka 
        echo $kafka

        case $kafka in
        "yes")
            kafka_start;
             let flot++;
            ;;
        "no")
            kafka_stop;
             let flot++;
            ;;
         "un")
            echo "不執(zhí)行任何操作"
             let flot++;
            ;;
        *)
            echo $out_no
            echo '參數(shù)只能是 yes|no|un'
            ;;
        esac
done
}


#########################################  canal  ######################################

# 啟動(dòng)canal
function canal_start()
{
    
   for host in $mHost  ; do
        echo "在 $host 啟動(dòng)canal服務(wù)器"
        ssh $host "source /etc/profile; cd /opt/module/canal; bin/startup.sh"
    done
}

# 關(guān)閉canal
function canal_stop()
{
   for host in $mHost  ; do
        echo "在 $host 關(guān)閉canal服務(wù)器"
        ssh $host "source /etc/profile; cd /opt/module/canal; bin/stop.sh"
    done
}

# canal
function Canal(){
    flot=1;

while [[ $flot -eq 1 ]]; do
    read -p "請(qǐng)問是否需要啟動(dòng)或者關(guān)閉canal? yes/no/un " canal 
        echo $canal

        case $canal in
        "yes")
            canal_start;
             let flot++;
            ;;
        "no")
            canal_stop;
             let flot++;
            ;;
         "un")
            echo "不執(zhí)行任何操作"
             let flot++;
            ;;
        *)
            echo $out_no
            echo '參數(shù)只能是 yes|no|un'
            ;;
        esac
done
}


# hdfs hbase zk kafka canal jartomcat

# 判斷傳遞進(jìn)來的參數(shù) 是否包含hdfs
if [[ $* =~ "hdfs" ]]; then
     Hdfs;
     echo "包含Hdfs"
fi

# 判斷傳遞進(jìn)來的參數(shù) 是否包含zk
if [[ $* =~ "zk" ]]; then
      Zk;
     echo "包含zk"
fi

# 判斷傳遞進(jìn)來的參數(shù) 是否包含hbase
if [[ $* =~ "hbase" ]]; then
     Hbase;
     echo "包含hbase"
fi


# 判斷傳遞進(jìn)來的參數(shù) 是否包含kafka
if [[ $* =~ "kafka" ]]; then
      Kafka;
     echo "包含kafka"
fi

# 判斷傳遞進(jìn)來的參數(shù) 是否包含canal
if [[ $* =~ "canal" ]]; then
     Canal;
     echo "包含canal"
fi

# 判斷傳遞進(jìn)來的參數(shù) 是否包含jartomcat
if [[ $* =~ "jartomcat" ]]; then
      Jartomcat;
     echo "包含jartomcat"
fi