这一段时间在研究《Java编程思想》,个人认为
第550页,18.9 进程控制,OSExecute类有问题(英文版是P944)。如果用书上的代码,程序一直就会处在阻塞的状态,更不用说,打印进程的输出信息了。
以下是书上的代码:
package cn.com.newocm;
/**
* 异常处理类 处理进程在执行过程中产生的错误
*
* @author zhq
*
*/
public class OSExecuteException extends RuntimeException {
private static final long serialVersionUID = 1L;
public OSExecuteException(String why) {
super(why);
}
}
package cn.com.newocm;
import java.io.BufferedReader;
import java.io.InputStreamReader;
/**
* 进程控制
* @author zhq
*
*/
public class OSExecute {
public static void command(String command) {
boolean err = false;
try {
Process process = new ProcessBuilder(command.split(" ")).start();
BufferedReader results = new BufferedReader(new InputStreamReader(
process.getInputStream()));
String s;
while ((s = results.readLine()) != null)//如果命令输入正确,此处一直阻塞
System.out.println(s);
BufferedReader errors = new BufferedReader(new InputStreamReader(
process.getErrorStream()));
while ((s = errors.readLine()) != null) {
System.err.println(s);
err = true;
}
} catch (Exception e) {
if (!command.startsWith("CMD /C"))
command("CMD /C " + command);
else
throw new RuntimeException(e);
}
if (err)
throw new OSExecuteException("Errors executing " + command);
}
public static void main(String[] args) {
command("wmic process");
}
}
上面代码执行后,没有任何反应,因为创建的进程被阻塞。原因在于,引用Java API中的原话:“
有些本机平台仅针对标准输入和输出流提供有限的缓冲区大小,如果读写子进程的输出流或输入流迅速出现失败,则可能导致子进程阻塞,甚至产生死锁”。
为了不至于出现上述问题,个人认为,需要对代码进行改进,采用多线程机制,一个线程负责读取正确信息,一个线程负责读取错误信息;在进程信息读取完毕后,应该显式的关闭进程的OutputStream。
更改后的代码:
package cn.com.newcom.runtime.exec;
import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
/**
* 在Java内部执行Windows操作系统的程序
*
* @author zhq
*
*/
public class OSExecute {
public static void command(String command) {
try {
// 利用指定的操作系统程序和参数构造一个进程生成器
Process process = new ProcessBuilder(command.split(" ")).start();
// 错误的信息
StreamGobbler errorGobbler = new StreamGobbler(process
.getErrorStream(), "ERROR");
// 正确的信息
StreamGobbler outputGobbler = new StreamGobbler(process
.getInputStream(), "OUTPUT");
// 启动线程
errorGobbler.start();
outputGobbler.start();
// 关闭进程输出流
process.getOutputStream().close();
// 等待该进程执行完毕
int exitVal = process.waitFor();
System.out.println("ExitValue: " + exitVal);
} catch (Exception e) {
if (!command.startsWith("cmd /C")) {
// 只考虑了Windows 2000以上的操作系统,对于Windows 95应该是command.com /C
command("cmd /C " + command);
} else
throw new RuntimeException(e);
}
}
public static void main(String[] args) {
command("cmd /C wmic process");
}
}
/**
* 该线程负责读取进程输出的信息
*
* @author zhq
*
*/
class StreamGobbler extends Thread {
private InputStream is;
// 输出信息的类型,错误信息,还是正确信息
private String type;
StreamGobbler(InputStream is, String type) {
this.is = is;
this.type = type;
}
public void run() {
try {
BufferedReader br = new BufferedReader(new InputStreamReader(is));
String line = null;
while ((line = br.readLine()) != null)
System.out.println(type + ">" + line);
} catch (IOException ioe) {
ioe.printStackTrace();
}
}
}
以上只是个人的见解,有不对的地方,还请大家指教!
分享到:
相关推荐
FagooC101证卡制作系统P280e、P550、P560打印排版系统
法高Fagoo P550/P560证卡打印机P5X0制卡机驱动程序。Fagoo P560证卡打印机采用彩色热升华单色热转印技术,搭载OEE数码影像处理平台,为用户提供最优质的打印品质。特有的打印模式选择,满足你多方位需求。多处人性化...
IBM P550添加内存详细图文步骤,以及添加过程中需要注意的各种事项
文档表述的是P550小型机CPU扩容示例。
IBM+P550(AIX操作系统+HACMP+DS4300)安装
IBM_P550_vio_规划与实施
详细描述如何使用串口登录Power550小型机,如何设置波特率,使用何种串品线
大话JAVA性能优化_周明耀著_北京:电子工业出版社 , 2016.04_P550
IBM P550 rootvg 故障硬盘更换手册
更换IBM小型机P6-550的内存,有图有讲解,欢迎下载
IBM_P550_ds4700系统安装过程
IBM_P550小型机配置ASMI管理。
精雕5.5,
2015-09-12 06:59:40.262: [ CRSEVT][11046]32CAAMonitorHandler :: 0:Action Script /opt/oracle/product/10.2/db_1/bin/racgwrap(check) timed out for ora.p550b.LISTENER_P550B.lsnr! (timeout=600) 2015-09-12 ...
xxxx平台二期扩容项目数据库扩容实施方案P550扩容CPU卡.doc
用于解决IBM__P系列小型机_故障定位、故障排除的问题,对小型机的系统运维有帮助。
IBM-P更换风扇-电源过程.doc
IBM+P570主机在线更换HBA卡详细过程
AIX6.1+HACMP5.5+光纤交换机安装文档
图文并茂介绍,IBM P570更换风扇的过程。