Java Shell
在工作过程中,大部分是Java开发,但只会Java肯定远远不够。 在文本处理过程中,主要是用脚本进行开发。脚本开发的特点就是在进行批处理的时候非常方便。比如这么一个需求场景:
有一些特殊文件需要特殊环境才能操作(比如:IOS 奔溃文件还原,Android 奔溃混淆文件还原),而部署上线后必须依赖Linux环境执行,所以需要借助Java的Process类调用shell脚本处理一些任务!
下面主要介绍两点:
- Java的Process类是什么
- 如何使用Process类操作Shell脚本指令
- Process 类操作shell脚本文件
- Process类和ProcessBuilder源码
一、Java中的 Process类
为了执行调用操作,JVM会启一个Process,Process类主要有以下几个方法:
为了执行调用操作,JVM会启一个Process,所以可以通过调用Process类的以下方法,得知调用操作是否正确执行:1.1
waitFor()//导致当前线程等待//返回值是进程的出口值。0 表示正常终止;否则,就表示异常失败。abstract int waitFor()
1.2
isAlive()
另外,调用某些Shell命令或脚本时,会有返回值,那么如果捕获这些返回值或输出呢?为了解决这个问题,Process类提供了:// 检测子进程是否存活,存活则返回 truepublic boolean isAlive()
1.3
getInputStream()//获取子进程的输入流。 最好对输入流进行缓冲。abstract InputStream getInputStream()
二、如何使用
主要实现方式有两种:Process类操作Shell脚本指令
- 直接使用
Process类处理进程 -
2.1 直接使用 Process类操作
在Linux系统查看系统当前目录

使用Java调用实现同样的功能private static void execDemo() throws IOException, InterruptedException {Process process = Runtime.getRuntime().exec("pwd");// 检查执行状态int exitValue = process.waitFor();if (0 != exitValue) {log.error("call shell failed. error code is :" + exitValue);}BufferedReader reader = new BufferedReader(new InputStreamReader(process.getInputStream()));String line = null;while ((line = reader.readLine()) != null) {System.out.println("line = " + line);}}
2.2 使用
ProcessBuilder构造一个进程生成器使用Java的
ProcessBuilder实现同样的功能private static void ProcessBuilderDemo() throws IOException, InterruptedException {ProcessBuilder processBuilder = new ProcessBuilder("pwd");// 将错误流重定向到输出流processBuilder.redirectErrorStream(true);Process start = processBuilder.start();int exitValue = start.waitFor();if (0 != exitValue) {log.error("call shell failed. error code is :" + exitValue);}BufferedReader reader = new BufferedReader(new InputStreamReader(start.getInputStream()));String line = null;while ((line = reader.readLine()) != null) {System.out.println("line = " + line);}}
2.3
Runtime方式和ProcessBuilder方式对比 Runtime方式:此为最常见的一种运行方式,历史最悠久,使应用程序能够与其运行的环境相连接,但是在读取上还存在一些不便性,正常的输出流与错误流得分开读取。其他功能基本相同。ProcessBuilder:此为jdk1.5加入的,它没有将应用程序与其运行的环境相连接。这个就需要自己设置其相关的信息。但它提供了将正常流与流程流合并在一起的解决办法,只需要设置redirectErrorStream(错误流重定向到标准数据流)属性即可,这样更有利于脚本执行过程中出现问题时排查。三、Process类操作Shell脚本文件
假如要调用的Shell脚本是文件:/root/experiment/test.sh
```bash!/usr/bin/env bash
args=1 if [ $# -eq 1 ];then args=$1 echo “The argument is: $args” fi
echo “This is a $call”
start=date +%s
sleep 3s
end=date +%s
cost=$((($end - $start) $args $val))
echo “Cost Time: $cost”
<a name="Hhtfh"></a>### Java调用代码```javapublic static void callShellScript_test() {BufferedReader bufferedReader = null;try {String shellPath = CallShellScriptDemo01.class.getResource("/").getPath() + "shell/test.sh";ProcessBuilder builder = new ProcessBuilder("/bin/sh", shellPath);// 错误流重定向到标准输出流builder.redirectErrorStream(true);Process ps = builder.start();int exitValue = ps.waitFor();if (0 != exitValue) {log.error("call shell failed. error code is :" + exitValue);}bufferedReader = new BufferedReader(new InputStreamReader(ps.getInputStream()));String line;while ((line = bufferedReader.readLine()) != null) {System.out.println("line = " + line.toString());}} catch (Exception e) {e.printStackTrace();}log.info("数据刷新完成");}
四、Process类和ProcessBuilder源码
4.1 Process类
源代码虽是英文的,但是可以通过对原注释的阅读,直接体会jdk原创作者的真实想法,这样大家对process这个类会有更深一层次的理解。
/*** The {@link ProcessBuilder#start()} and* {@link Runtime#exec(String[],String[],File) Runtime.exec}* methods create a native process and return an instance of a* subclass of {@code Process} that can be used to control the process* and obtain information about it. The class {@code Process}* provides methods for performing input from the process, performing* output to the process, waiting for the process to complete,* checking the exit status of the process, and destroying (killing)* the process.** <p>The methods that create processes may not work well for special* processes on certain native platforms, such as native windowing* processes, daemon processes, Win16/DOS processes on Microsoft* Windows, or shell scripts.** <p>By default, the created subprocess does not have its own terminal* or console. All its standard I/O (i.e. stdin, stdout, stderr)* operations will be redirected to the parent process, where they can* be accessed via the streams obtained using the methods* {@link #getOutputStream()},* {@link #getInputStream()}, and* {@link #getErrorStream()}.* The parent process uses these streams to feed input to and get output* from the subprocess. Because some native platforms only provide* limited buffer size for standard input and output streams, failure* to promptly write the input stream or read the output stream of* the subprocess may cause the subprocess to block, or even deadlock.** <p>Where desired, <a href="ProcessBuilder.html#redirect-input">* subprocess I/O can also be redirected</a>* using methods of the {@link ProcessBuilder} class.** <p>The subprocess is not killed when there are no more references to* the {@code Process} object, but rather the subprocess* continues executing asynchronously.** <p>There is no requirement that a process represented by a {@code* Process} object execute asynchronously or concurrently with respect* to the Java process that owns the {@code Process} object.** <p>As of 1.5, {@link ProcessBuilder#start()} is the preferred way* to create a {@code Process}.** @since JDK1.0*/public abstract class Process {/*** Returns the output stream connected to the normal input of the* subprocess. Output to the stream is piped into the standard* input of the process represented by this {@code Process} object.** <p>If the standard input of the subprocess has been redirected using* {@link ProcessBuilder#redirectInput(Redirect)* ProcessBuilder.redirectInput}* then this method will return a* <a href="ProcessBuilder.html#redirect-input">null output stream</a>.** <p>Implementation note: It is a good idea for the returned* output stream to be buffered.** @return the output stream connected to the normal input of the* subprocess*/public abstract OutputStream getOutputStream();/*** Returns the input stream connected to the normal output of the* subprocess. The stream obtains data piped from the standard* output of the process represented by this {@code Process} object.** <p>If the standard output of the subprocess has been redirected using* {@link ProcessBuilder#redirectOutput(Redirect)* ProcessBuilder.redirectOutput}* then this method will return a* <a href="ProcessBuilder.html#redirect-output">null input stream</a>.** <p>Otherwise, if the standard error of the subprocess has been* redirected using* {@link ProcessBuilder#redirectErrorStream(boolean)* ProcessBuilder.redirectErrorStream}* then the input stream returned by this method will receive the* merged standard output and the standard error of the subprocess.** <p>Implementation note: It is a good idea for the returned* input stream to be buffered.** @return the input stream connected to the normal output of the* subprocess*/public abstract InputStream getInputStream();/*** Returns the input stream connected to the error output of the* subprocess. The stream obtains data piped from the error output* of the process represented by this {@code Process} object.** <p>If the standard error of the subprocess has been redirected using* {@link ProcessBuilder#redirectError(Redirect)* ProcessBuilder.redirectError} or* {@link ProcessBuilder#redirectErrorStream(boolean)* ProcessBuilder.redirectErrorStream}* then this method will return a* <a href="ProcessBuilder.html#redirect-output">null input stream</a>.** <p>Implementation note: It is a good idea for the returned* input stream to be buffered.** @return the input stream connected to the error output of* the subprocess*/public abstract InputStream getErrorStream();/*** Causes the current thread to wait, if necessary, until the* process represented by this {@code Process} object has* terminated. This method returns immediately if the subprocess* has already terminated. If the subprocess has not yet* terminated, the calling thread will be blocked until the* subprocess exits.** @return the exit value of the subprocess represented by this* {@code Process} object. By convention, the value* {@code 0} indicates normal termination.* @throws InterruptedException if the current thread is* {@linkplain Thread#interrupt() interrupted} by another* thread while it is waiting, then the wait is ended and* an {@link InterruptedException} is thrown.*/public abstract int waitFor() throws InterruptedException;/*** Causes the current thread to wait, if necessary, until the* subprocess represented by this {@code Process} object has* terminated, or the specified waiting time elapses.** <p>If the subprocess has already terminated then this method returns* immediately with the value {@code true}. If the process has not* terminated and the timeout value is less than, or equal to, zero, then* this method returns immediately with the value {@code false}.** <p>The default implementation of this methods polls the {@code exitValue}* to check if the process has terminated. Concrete implementations of this* class are strongly encouraged to override this method with a more* efficient implementation.** @param timeout the maximum time to wait* @param unit the time unit of the {@code timeout} argument* @return {@code true} if the subprocess has exited and {@code false} if* the waiting time elapsed before the subprocess has exited.* @throws InterruptedException if the current thread is interrupted* while waiting.* @throws NullPointerException if unit is null* @since 1.8*/public boolean waitFor(long timeout, TimeUnit unit)()/*** Returns the exit value for the subprocess.** @return the exit value of the subprocess represented by this* {@code Process} object. By convention, the value* {@code 0} indicates normal termination.* @throws IllegalThreadStateException if the subprocess represented* by this {@code Process} object has not yet terminated*/public abstract int exitValue();/*** Kills the subprocess. Whether the subprocess represented by this* {@codeProcess} object is forcibly terminated or not is* implementation dependent.*/public abstract void destroy();/*** Kills the subprocess. The subprocess represented by this* {@code Process} object is forcibly terminated.** <p>The default implementation of this method invokes {@link #destroy}* and so may not forcibly terminate the process. Concrete implementations* of this class are strongly encouraged to override this method with a* compliant implementation. Invoking this method on {@code Process}* objects returned by {@link ProcessBuilder#start} and* {@link Runtime#exec} will forcibly terminate the process.** <p>Note: The subprocess may not terminate immediately.* i.e. {@code isAlive()} may return true for a brief period* after {@code destroyForcibly()} is called. This method* may be chained to {@code waitFor()} if needed.** @return the {@code Process} object representing the* subprocess to be forcibly destroyed.* @since 1.8*/public Process destroyForcibly(){}/*** Tests whether the subprocess represented by this {@code Process} is* alive.** @return {@code true} if the subprocess represented by this* {@code Process} object has not yet terminated.* @since 1.8*/public boolean isAlive(){}}
