快捷導(dǎo)航

Java Process與Runtime()的使用及調(diào)用cmd命令阻塞的解決方案

更新時(shí)間：2021年06月08日 17:24:10 作者：Missmiaomiao

這篇文章主要介紹了Java Process與Runtime()的使用及調(diào)用cmd命令阻塞的解決方案，具有很好的參考價(jià)值，希望對(duì)大家有所幫助。如有錯(cuò)誤或未考慮完全的地方，望不吝賜教

Java Process與Runtime()使用

java調(diào)用cmd執(zhí)行bat文件有時(shí)會(huì)出現(xiàn)卡死的現(xiàn)象，當(dāng)時(shí)感覺(jué)很迷惑，后來(lái)查資料，本來(lái)一般都是這樣來(lái)調(diào)用程序并獲取進(jìn)程的輸出流的，但是我在windows上執(zhí)行這樣的調(diào)用的時(shí)候卻總是在while那里被堵塞了，結(jié)果造成ffmpeg程序在執(zhí)行了一會(huì)后不再執(zhí)行，這里從官方的參考文檔中我們可以看到這是由于緩沖區(qū)的問(wèn)題，由于java進(jìn)程沒(méi)有清空f(shuō)fmpeg程序?qū)懙骄彌_區(qū)的內(nèi)容，結(jié)果導(dǎo)致ffmpeg程序一直在等待。

在網(wǎng)上也查找了很多這樣的問(wèn)題，不過(guò)說(shuō)的都是使用單獨(dú)的線(xiàn)程來(lái)進(jìn)行控制，我也嘗試過(guò)很多網(wǎng)是所說(shuō)的方法，可一直沒(méi)起什么作用。

一直認(rèn)為是getInputStream的緩沖區(qū)沒(méi)有被清空，不過(guò)問(wèn)題確實(shí)是緩沖區(qū)的內(nèi)容沒(méi)有被清空，但不是getInputStream的，而是getErrorStream的緩沖區(qū)，這樣問(wèn)題就得到解決了。

所以我們?cè)谟龅絡(luò)ava調(diào)用外部程序而導(dǎo)致線(xiàn)程阻塞的時(shí)候，可以考慮使用兩個(gè)線(xiàn)程來(lái)同時(shí)清空process獲取的兩個(gè)輸入流，如下這段程序：

 public String excuteBatFile(String file, boolean isCloseWindow) 
    {
        String cmdCommand = null;
        String res = null;
        if(isCloseWindow) 
        {
            cmdCommand = "cmd.exe /c " + file;
        }else 
        {
            cmdCommand = "cmd.exe /k " + file;
        }
        StringBuilder stringBuilder = new StringBuilder();
        Process process = null;
        try {
            process = Runtime.getRuntime().exec(cmdCommand);
            final InputStream is1 = process.getInputStream();
            new Thread(new Runnable() {
                public void run() {
                    BufferedReader bufferedReader = null;
                    String line = null;
                    try {
                        bufferedReader = new BufferedReader(
                                new InputStreamReader(is1, "GBK"));
                        while((line=bufferedReader.readLine()) != null) 
                        {
                            stringBuilder.append(line+"\n");
                        }
                        is1.close();
                    } catch (Exception e) {
                        // TODO Auto-generated catch block
                        e.printStackTrace();
                    }
                }
            }).start(); // 啟動(dòng)單獨(dú)的線(xiàn)程來(lái)清空p.getInputStream()的緩沖區(qū)
            InputStream is2 = process.getErrorStream();
            BufferedReader br2 = new BufferedReader(new InputStreamReader(is2)); 
            StringBuilder buf = new StringBuilder(); // 保存輸出結(jié)果流
            String line2 = null;
            while((line2 = br2.readLine()) != null) buf.append(line2); // 
            log.info("----res:----" + stringBuilder + "&" + buf);
            return stringBuilder + "&" + buf;
        } catch (Exception e) {
            e.printStackTrace();
            return e.toString();
        }
    }

通過(guò)這樣我們使用一個(gè)線(xiàn)程來(lái)讀取process.getInputStream()的輸出流，使用另外一個(gè)線(xiàn)程來(lái)獲取process.getErrorStream()的輸出流，這樣我們就可以保證緩沖區(qū)得到及時(shí)的清空而不擔(dān)心線(xiàn)程被阻塞了。

當(dāng)然根據(jù)需要你也可以保留process.getInputStream()流中的內(nèi)容，這個(gè)就看調(diào)用的程序的處理了。

java Process執(zhí)行cmd命令流阻塞處理

代碼如下：

public static void runCmd() {
        Process process = null;
        BufferedReader bufferedReader = null;
        try {
            Logger.getLogger(SystemService.class).info("============= 開(kāi)始重啟機(jī)器 =============");
            process = Runtime.getRuntime().exec("cmd.exe /c shutdown -r -f -t 0");
            bufferedReader = new BufferedReader(new InputStreamReader(new BufferedInputStream(process.getInputStream()), Charset.forName("GB2312")));
            // 開(kāi)啟線(xiàn)程讀取錯(cuò)誤輸出，避免阻塞
            new StreamInformatonThread(process.getErrorStream(), "error").start();
            String outStr;
            while ((outStr = bufferedReader.readLine()) != null) {
                Logger.getLogger(SystemService.class).info("readLine -------> : " + outStr);
            }
            Logger.getLogger(SystemService.class).info("============= 重啟機(jī)器完成 =============");
        } catch (IOException e) {
            Logger.getLogger(SystemService.class).error("============= 重啟機(jī)器失敗 =============");
            e.printStackTrace();
        } finally {
            if (process != null) {
                process.destroy();
            }
            if (bufferedReader != null) {
                try {
                    bufferedReader.close();
                } catch (IOException e) {
                    e.printStackTrace();
                }
            }
        }
    }

import java.io.*;
/**
 * @Description:流阻塞處理
 * @Author: zhangwenchao
 * @Date: 2019/7/9 11:35
 */
public class StreamInformatonThread extends Thread {
    private InputStream is;
    private String str;
    private Logger logger = Logger.getLogger(StreamInformatonThread.class);
    public StreamInformatonThread(InputStream is, String str) {
        this.is = is;
        this.str = str;
    }
    public void run() {
        BufferedReader out = null;
        try {
            out = new BufferedReader(new InputStreamReader(is, "gbk"));
            String line;
            while ((line = out.readLine()) != null) {
                if (str.equals("error")) {
                    logger.info("ErrorStream --------> :" +line);
                } else {
                    logger.info("outLine ---------> :" + line);
                }
            }
        } catch (UnsupportedEncodingException e) {
            e.printStackTrace();
        } catch (IOException e) {
            e.printStackTrace();
        } finally {
            if (out != null) {
                try {
                    out.close();
                } catch (IOException e) {
                    e.printStackTrace();
                }
            }
        }
    }
}

以上為個(gè)人經(jīng)驗(yàn)，希望能給大家一個(gè)參考，也希望大家多多支持腳本之家。

您可能感興趣的文章: