SpringBoot項目執行腳本, 自動拉取最新代碼並重啟

gitPullThenRestart.sh

# 日期: 20191230
# 作者: 何鵬舉
# 說明: 項目部署在阿里雲上, 每次編譯打包上傳比較麻煩, 因此編寫此腳本, 用於應用內可以點擊按鈕進行自動重啟.
# 備注: 1) 阿里雲的插件也是需要每次上傳到OSS再啟動, 上傳的jar包比較大(大部分是第三方依賴), 感覺不好
#       2) 使用jenkins, 就一個項目再去搭建一套jenkins, 必要性也不是很大

# 以下代碼中 /root/hekele 為git clone的項目路徑, /root/app 為部署的路徑


# 刷新環境變量
source ~/.bashrc

# 切換到git項目目錄拉取最新代碼, 並進行mvn的打包
cd /root/hekele
git pull

cd /root/hekele/java
mvn clean install


# 殺掉當前項目的進程
ps -ef|grep hekele.jar | awk '{print $2}' | while read pid
do
  kill -9 $pid
done

# 復制jar包, 強制覆蓋(忽略提醒), 由於CentOS的.bashrc中打開cp的-i選項, 即可使用-f也不行, 所以還是先刪除再復制
rm -f /root/app/hekele.jar
cp /root/hekele/java/target/hekele.jar /root/app/

# 后台啟動項目
nohup java  -jar /root/app/hekele.jar >> /root/app/hekele.log 2>&1 &

# 查看日志(備注: kill掉之后, 其復制jar包和啟動還是執行了, 原因暫時未知... 此句話在手動啟動可用, 自動重啟實測也沒影響)
tail -f /root/app/hekele.log

 

JavaController

    @ApiOperation("拉取最新代碼然后重啟應用")
    @GetMapping("gitPullThenRestart")
    public R gitPullThenRestart() {
        // 必須開啟一個新線程, 從而返回給瀏覽器, 否則瀏覽器得不到響應, 還會再次發送
        new Thread(() -> ExecUtil.execCommand(restartShell)).start();
        return R.ok().setErrmsg("正在重新啟動, 請稍等");
    }

 

JavaExecUtil

/**
 * 執行系統命令
 * 
 * 
 * <br> 注意死鎖問題
 * <br> 解決: 只要主進程在waitfor之前，能不斷處理緩沖區中的數據就可以
 * 
 * @see <a href="https://blog.csdn.net/seapeak007/article/details/69668600">調用Process.waitfor導致的進程掛起</a>
 * 
 * @author he_pe
 *
 */
@Slf4j
public class ExecUtil {

    public static void execCommand(String command) {
        log.info("begin exec os command: " + command);
        Process process;
        try {
            process = Runtime.getRuntime().exec(command);
            
            //開啟新線程處理正常輸出 和 錯誤輸出
            newThreadLogInputStream(process.getInputStream());
            newThreadLogInputStream(process.getErrorStream());

            // 阻塞當前進程,直到命令結束
            process.waitFor();

            // 不會阻塞進程,但是調用時如果沒有完成會報錯
            if (process.exitValue() != 0) {
                log.error("exec os command failure: " + command);
            } else {
                log.info("exec os command success: " + command);
            }
        } catch (Exception e) {
            log.error(e.getMessage(), e);
        }
    }

    private static void newThreadLogInputStream(InputStream is){
        new Thread(() ->  {
            try(InputStream inputStream = is;
                BufferedReader bufr = new BufferedReader(new InputStreamReader(inputStream))){
                String out = null;
                while ((out = bufr.readLine()) != null) {
                    log.info(out);
                }
            } catch (IOException e) {
            }
        }).start();
    }

}