Java調(diào)用shell命令涉及管道、重定向時(shí)不生效問題及解決
Java調(diào)用shell命令涉及管道、重定向時(shí)不生效
近日，因項(xiàng)目需求需要用java調(diào)用shell命令實(shí)現(xiàn)清理過時(shí)圖片任務(wù)，發(fā)現(xiàn)代碼生成出來的shell命令在linux系統(tǒng)后臺直接執(zhí)行，可以實(shí)現(xiàn)效果，但是，經(jīng)過java代碼運(yùn)行，則達(dá)不到預(yù)期效果。
經(jīng)研究發(fā)現(xiàn)，因?yàn)樵搒hell命令涉及了管道，這情況就有點(diǎn)不一樣了，下面是針對Java調(diào)用shell命令涉及管道、重定向時(shí)不生效問題的解決方法
參考代碼如下：
public class Test
{
/**
* @param args
* @throws IOException
* @throws InterruptedException
*/
public static void main(String[] args) throws IOException, InterruptedException
{
Process p;
String command = "find /opt/Img/ \"2019-11-22-*.jpg\" | xargs rm -rf"};
// 必須加上sh -c
p = Runtime.getRuntime().exec(new String[]{"sh","-c",command});
if(0==p.waitFor())
{
System.out.println("Command execute result is OK!");
}
else
{
System.out.println("Command execute result is fail......");
}
}
}Java執(zhí)行shell遇到的各種問題
1、判斷子進(jìn)程是否執(zhí)行結(jié)束
有的時(shí)候我們用java調(diào)用shell之后，之后的操作要在Process子進(jìn)程正常執(zhí)行結(jié)束的情況下才可以繼續(xù)，所以我們需要判斷Process進(jìn)程什么時(shí)候終止。
Process類提供了waitFor()方法。該方法導(dǎo)致當(dāng)前線程等待，直到Process線程終止。
Process.waitFor()是有一個(gè)int類型返回值的，當(dāng)返回值為0的時(shí)候表Process進(jìn)程正常終止。否則一般是腳本執(zhí)行出錯(cuò)了（我遇到的一般是這種情況）。
2、Process.waitFor()導(dǎo)致當(dāng)前線程阻塞
有的時(shí)候我們發(fā)現(xiàn)調(diào)用waitFor（）方法后，java主線程會一直阻塞在waitFor（）處，阻塞的原因是什么呢？分析一下：
Java在執(zhí)行Runtime.getRuntime().exec(jyName)之后，Linux會創(chuàng)建一個(gè)進(jìn)程，該進(jìn)程與JVM進(jìn)程建立三個(gè)管道連接，標(biāo)準(zhǔn)輸入流、標(biāo)準(zhǔn)輸出流、標(biāo)準(zhǔn)錯(cuò)誤流，假設(shè)linux進(jìn)程不斷
向標(biāo)準(zhǔn)輸出流和標(biāo)準(zhǔn)錯(cuò)誤流寫數(shù)據(jù)，而JVM卻不讀取，數(shù)據(jù)會暫存在linux緩存區(qū)，當(dāng)緩存區(qū)存滿之后導(dǎo)致該進(jìn)程無法繼續(xù)寫數(shù)據(jù)，會僵死，導(dǎo)致java進(jìn)程會卡死在waitFor()處，
永遠(yuǎn)無法結(jié)束。
解決辦法：java進(jìn)程在waitFor()前不斷讀取標(biāo)準(zhǔn)輸出流和標(biāo)準(zhǔn)錯(cuò)誤流：
?? ??? ?//jyName ?解壓腳本路徑
?? ??? ?String fileName=fileList.get(0).toString().substring(fileList.get(0).toString().lastIndexOf(File.separator)+1);
?? ??? ?String ?jyName="/etc/zxvf.sh "+fileName;
?? ??? ?try {
?? ??? ??? ?Process p0 = Runtime.getRuntime().exec(jyName);
?? ??? ??? ?//讀取標(biāo)準(zhǔn)輸出流
?? ??? ??? ?BufferedReader bufferedReader =new BufferedReader(new InputStreamReader(p0.getInputStream()));
?? ??? ??? ?String line;
?? ??? ??? ?while ((line=bufferedReader.readLine()) != null) {
?? ??? ??? ? ? ?System.out.println(line);
?? ??? ??? ?}?? ?
?? ??? ??? ?//讀取標(biāo)準(zhǔn)錯(cuò)誤流
?? ??? ??? ?BufferedReader brError = new BufferedReader(new InputStreamReader(p0.getErrorStream(), "gb2312"));
?? ??? ??? ?String errline = null;
?? ??? ??? ?while ((errline = brError.readLine()) != null) {
?? ??? ??? ??? ? System.out.println(errline);
?? ??? ??? ?}
?? ??? ??? ?//waitFor()判斷Process進(jìn)程是否終止，通過返回值判斷是否正常終止。0代表正常終止
?? ??? ??? ?int c=p0.waitFor();
?? ??? ??? ?if(c!=0){
?? ??? ??? ??? ?baseRes.put("desc", "軟件升級失?。簣?zhí)行zxvf.sh異常終止");
?? ??? ??? ??? ?baseRes.setReturnFlag(false);
?? ??? ??? ??? ?return baseRes;
?? ??? ??? ?}
?? ??? ?} catch (IOException e1) {
?? ??? ??? ?baseRes.put("desc", "軟件升級失敗：文件解壓失敗");
?? ??? ??? ?baseRes.setReturnFlag(false);
?? ??? ??? ?return baseRes;
?? ??? ?} catch (InterruptedException e1) {
?? ??? ??? ?baseRes.put("desc", "軟件升級失?。何募鈮菏?);
?? ??? ??? ?baseRes.setReturnFlag(false);
?? ??? ??? ?return baseRes;
?? ??? ?}也可以在執(zhí)行Runtime.getRuntime().exec(jyName)之后另外再啟動兩個(gè)線程分別讀取標(biāo)準(zhǔn)錯(cuò)誤流和標(biāo)準(zhǔn)輸出流
import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
?
public class ExcuteThread extends Thread {
?? ?private String name;
?
?? ?public ExcuteThread(String name) {
?? ??? ?this.name = name;
?? ?}
?? ?@Override
?? ?public void run() {
?? ??? ?try {
?? ??? ??? ?Process p = Runtime.getRuntime().exec(name);
?? ??? ??? ?InputStream fis = p.getInputStream();
?? ??? ??? ?final BufferedReader brError = new BufferedReader(
?? ??? ??? ??? ??? ?new InputStreamReader(p.getErrorStream(), "gb2312"));
?? ??? ??? ?InputStreamReader isr = new InputStreamReader(fis, "gb2312");
?? ??? ??? ?final BufferedReader br = new BufferedReader(isr);
?? ??? ??? ?Thread t1 = new Thread() {
?? ??? ??? ??? ?public void run() {
?? ??? ??? ??? ??? ?String line = null;
?? ??? ??? ??? ??? ?try {
?? ??? ??? ??? ??? ??? ?while ((line = brError.readLine()) != null) {
?? ??? ??? ??? ??? ??? ??? ?// System.out.println(line);
?? ??? ??? ??? ??? ??? ?}
?? ??? ??? ??? ??? ?} catch (IOException e) {
?? ??? ??? ??? ??? ??? ?e.printStackTrace();
?? ??? ??? ??? ??? ?} finally {
?? ??? ??? ??? ??? ??? ?try {
?? ??? ??? ??? ??? ??? ??? ?if (brError != null)
?? ??? ??? ??? ??? ??? ??? ??? ?brError.close();
?? ??? ??? ??? ??? ??? ?} catch (IOException e) {
?? ??? ??? ??? ??? ??? ??? ?e.printStackTrace();
?? ??? ??? ??? ??? ??? ?}
?? ??? ??? ??? ??? ?}
?? ??? ??? ??? ?}
?? ??? ??? ?};
?? ??? ??? ?Thread t2 = new Thread() {
?? ??? ??? ??? ?public void run() {
?? ??? ??? ??? ??? ?String line = null;
?? ??? ??? ??? ??? ?try {
?? ??? ??? ??? ??? ??? ?while ((line = br.readLine()) != null) {
?? ??? ??? ??? ??? ??? ??? ?// System.out.println(line);
?? ??? ??? ??? ??? ??? ?}
?? ??? ??? ??? ??? ?} catch (IOException e) {
?? ??? ??? ??? ??? ??? ?e.printStackTrace();
?? ??? ??? ??? ??? ?} finally {
?? ??? ??? ??? ??? ??? ?try {
?? ??? ??? ??? ??? ??? ??? ?if (br != null)
?? ??? ??? ??? ??? ??? ??? ??? ?br.close();
?? ??? ??? ??? ??? ??? ?} catch (IOException e) {
?? ??? ??? ??? ??? ??? ??? ?// TODO Auto-generated catch block
?? ??? ??? ??? ??? ??? ??? ?e.printStackTrace();
?? ??? ??? ??? ??? ??? ?}
?? ??? ??? ??? ??? ?}
?? ??? ??? ??? ?}
?? ??? ??? ?};
?? ??? ??? ?t1.start();
?? ??? ??? ?t2.start();
?
?? ??? ?} catch (IOException e1) {
?? ??? ??? ?// TODO Auto-generated catch block
?? ??? ??? ?e1.printStackTrace();
?? ??? ?} finally {
?? ??? ?}
?
?? ?}
?
}3、shell腳本中有關(guān)聯(lián)腳本，注意路徑
就是shell腳本中還要執(zhí)行其他腳本，這時(shí)候就是注意一個(gè)路徑的問題，這個(gè)問題也是我找了好長時(shí)間的一個(gè)問題。
Process p=Runtime.getRuntime().exec(“/etc/a.sh”)
在Test.java類調(diào)用了etc目錄下的a.sh腳本， a.sh腳本中執(zhí)行etc目錄下的b.sh腳本，原來我在a.sh腳本中寫的是./b.sh。其實(shí)這樣linux是找不到b.sh的，因?yàn)槲覀儓?zhí)行是在
Test.class目錄下調(diào)用的/etc/a.sh 所以當(dāng)a.sh中執(zhí)行./b.sh的時(shí)候他會在Test.class目錄下尋找，所以找不到，所以a.sh中要寫成/etc/b.sh
4、java連續(xù)調(diào)用多個(gè)腳本
String[] cmd = { "/bin/sh", "-c", "rm -rf /installation/upgrade/ ; mkdir /installation/upgrade/" };
Process p = Runtime.getRuntime().exec(cmd);
p.waitFor();就是這種數(shù)組的方式。
5、java執(zhí)行.sh腳本文件的時(shí)候直接寫目錄就行
例如這樣：Runtime.getRuntime().exec(“/etc/a.sh”)
java 直接執(zhí)行語句的時(shí)候需要加上"/bin/sh" 例如這樣：
String name="/bin/sh cd /installation/upgrade/ip89_install_packet"; Process p = Runtime.getRuntime().exec(name);
總結(jié)
以上為個(gè)人經(jīng)驗(yàn)，希望能給大家一個(gè)參考，也希望大家多多支持腳本之家。
相關(guān)文章
這篇文章主要為大家詳細(xì)介紹了Java實(shí)現(xiàn)簡單聊天機(jī)器人，文中示例代碼介紹的非常詳細(xì)，具有一定的參考價(jià)值，感興趣的小伙伴們可以參考一下2021-07-07
SpringBoot 使用jwt進(jìn)行身份驗(yàn)證的方法示例
這篇文章主要介紹了SpringBoot 使用jwt進(jìn)行身份驗(yàn)證的方法示例，小編覺得挺不錯(cuò)的，現(xiàn)在分享給大家，也給大家做個(gè)參考。一起跟隨小編過來看看吧2018-12-12
Java設(shè)置PDF跨頁表格重復(fù)顯示表頭行的步驟詳解
這篇文章主要給大家介紹了關(guān)于Java設(shè)置PDF跨頁表格重復(fù)顯示表頭行的相關(guān)資料,這里使用的是Free Spire.PDF for Java的jar包,Spire.PDF for Java 是一款專門對 PDF 文檔進(jìn)行操作的 Java 類庫,需要的朋友可以參考下2021-07-07
springboot 在xml里讀取yml的配置信息的示例代碼
這篇文章主要介紹了springboot 在xml里讀取yml的配置信息的示例代碼,代碼簡單易懂，對大家的學(xué)習(xí)或工作具有一定的參考借鑒價(jià)值，需要的朋友可以參考下2020-09-09
本文給大家匯總介紹了幾種java實(shí)現(xiàn)http通訊的方法，非常的簡單實(shí)用，有需要的小伙伴可以參考下。2015-08-08
Mybatis中注入執(zhí)行sql查詢、更新、新增及建表語句案例代碼
這篇文章主要介紹了Mybatis中注入執(zhí)行sql查詢、更新、新增以及建表語句,主要說明一個(gè)另類的操作，注入sql，并使用mybatis執(zhí)行，結(jié)合案例代碼詳解講解，需要的朋友可以參考下2023-02-02
這篇文章主要介紹了Java拆箱與裝箱,結(jié)合實(shí)例形式詳細(xì)分析了Java拆箱與裝箱相關(guān)的數(shù)據(jù)類型轉(zhuǎn)換操作技巧,需要的朋友可以參考下2019-11-11
這篇文章主要為大家詳細(xì)介紹了java控制臺輸出版多人聊天室，文中示例代碼介紹的非常詳細(xì)，具有一定的參考價(jià)值，感興趣的小伙伴們可以參考一下2022-09-09
這篇文章主要介紹了Spring中的ConversionService源碼解析,ConversionService是類型轉(zhuǎn)換服務(wù)的接口,從名字就可以看出ConverterRegistry是要實(shí)現(xiàn)轉(zhuǎn)換器注冊表的接口,添加和移除Converter和GenericConverter,需要的朋友可以參考下2023-11-11
這篇文章主要介紹了Spring集成Redis詳解代碼示例，介紹了Eclipse工程結(jié)構(gòu)，POM依賴，Spring配置，Redis配置信息以及Java代碼等相關(guān)內(nèi)容，具有一定參考價(jià)值，需要的朋友可以了解下。2017-11-11