Java程序员的日常 —— 多进程开发IO阻塞问题

简介:

本篇仍旧是源于最近的工作,总结一下纪念那些年埋下的坑...

背景故事

  • 需求:“使用进程方式启动另一个程序!”
  • 开发:“OK! Runtime.getRuntime().exec("xxxx")”

  • 需求:“启动以后能看到输出消息不!”
  • 开发:“OK!”

Process process = null;
try {
    process = Runtime.getRuntime().exec("ipconfig /all");
} catch (IOException e) {
    e.printStackTrace();
}
try {
    String line;
    InputStream is = process.getInputStream();
    BufferedReader br = new BufferedReader(new InputStreamReader(is,"GBK"));
        
    while(null != (line = br.readLine())){
        System.out.println(line);
    }
    System.out.println("---------------------------------------------------------------------------------------");
    InputStream is_error = process.getErrorStream();
    BufferedReader br_error = new BufferedReader(new InputStreamReader(is_error,"GBK"));
        
    while(null != (line = br_error.readLine())){
        System.out.println(line);
    }
} catch (IOException e) {
    e.printStackTrace();
}

于是,神坑挖好了!

遇到的问题

由于运行的程序比较复杂,有可能出现错误输出。这时就不好保证是错误输出还是标准输出哪个先到。但是上面的程序中,使用了同步的方式输出子进程的消息,结果就导致了子进程阻塞。

解决方案1:使用缓冲区缓存消息

这个可以参考CSDN的帖子

解决方案2:使用ProcessBuilder合并标准输出和错误

仍然源自于上面的博客:

try{
    String[] cmds = {"ipconfig","/all"};
    ProcessBuilder builder = new ProcessBuilder(cmds);    
    
    //合并输出流和错误流
    builder.redirectErrorStream(true);    
             
    //启动进程
    Process process = builder.start();    
             
    //获得输出流
    BufferedReader br = new BufferedReader(new InputStreamReader(process.getInputStream(),"GBK"));    
    String line = null;    
    while (null != (line = br.readLine())){    
        System.out.println(line);
    }    
}catch(IOException e){
    e.printStackTrace();
}

上面的代码中builder.redirectErrorStream(true);就可以帮助你把错误合并到标准输出里面。

于是,很好奇这个ProcessBuilder到底什么东东。

阅读API —— 什么是ProcessBuilder

ProcessBuilder用于创建操作系统进程,每个ProcessBuilder实例都管理一个进程属性集合。通过调用start()方法,可以通过这些属性创建出一个进程。start()方法可以被多次调用,来创建多个独立的进程。

每个builder管理着下面的进程属性:

cmmand

命令,比如{“ipcofig”,"/all"}

environment

环境变量,子进程会直接使用当前进程的环境变量。环境变量是独立的,因此可以被修改,但是不会影响其他的进程。

directory

工作目录,如果返回的是Null,说明当前目录使用的是系统变量user.dir所在的目录。

redirectErrorStream属性

默认是false。Flase意味着标准输出和标准错误是两个独立的流,可以通过Process.getInputStream()和Process.getErrorStream()方法获得。

如果这个值设置为true,那么标准错误将会合并到标准输出中,并且发往同一个目标地址(这种特性使得错误消息可以很方便的和输出消息一起管理),此时,如果你再想要单独获取错误输出流,就会得到null。

线程安全

注意这个类不是线程安全的,因此如果多个线程使用ProcessBuilder实例,并且修改属性,那么可能会造成冲突。因此需要在外面进行线程同步。

启动

可以简单的向下面这样启动一个进程:

 Process p = new ProcessBuilder("myCommand", "myArg").start();

样例

下面是官方文档中给出的样例,样例中修改了工作目录以及环境变量,并且把标准错误和标准输出合并输出到日志文件中:

 ProcessBuilder pb = new ProcessBuilder("myCommand", "myArg1", "myArg2");
 Map<String, String> env = pb.environment();
 env.put("VAR1", "myValue");
 env.remove("OTHERVAR");
 env.put("VAR2", env.get("VAR1") + "suffix");
 pb.directory(new File("myDir"));
 File log = new File("log");
 pb.redirectErrorStream(true);
 pb.redirectOutput(Redirect.appendTo(log));
 Process p = pb.start();
 assert pb.redirectInput() == Redirect.PIPE;
 assert pb.redirectOutput().file() == log;
 assert p.getInputStream().read() == -1;
本文转自博客园xingoo的博客,原文链接:Java程序员的日常 —— 多进程开发IO阻塞问题,如需转载请自行联系原博主。
相关文章
|
10月前
|
安全 前端开发 Java
《深入理解Spring》:现代Java开发的核心框架
Spring自2003年诞生以来,已成为Java企业级开发的基石,凭借IoC、AOP、声明式编程等核心特性,极大简化了开发复杂度。本系列将深入解析Spring框架核心原理及Spring Boot、Cloud、Security等生态组件,助力开发者构建高效、可扩展的应用体系。(238字)
|
10月前
|
JSON 网络协议 安全
【Java】(10)进程与线程的关系、Tread类;讲解基本线程安全、网络编程内容;JSON序列化与反序列化
几乎所有的操作系统都支持进程的概念,进程是处于运行过程中的程序,并且具有一定的独立功能,进程是系统进行资源分配和调度的一个独立单位一般而言,进程包含如下三个特征。独立性动态性并发性。
439 1
|
10月前
|
Java Unix Go
【Java】(8)Stream流、文件File相关操作,IO的含义与运用
Java 为 I/O 提供了强大的而灵活的支持,使其更广泛地应用到文件传输和网络编程中。!但本节讲述最基本的和流与 I/O 相关的功能。我们将通过一个个例子来学习这些功能。
369 1
|
10月前
|
JSON 网络协议 安全
【Java基础】(1)进程与线程的关系、Tread类;讲解基本线程安全、网络编程内容;JSON序列化与反序列化
几乎所有的操作系统都支持进程的概念,进程是处于运行过程中的程序,并且具有一定的独立功能,进程是系统进行资源分配和调度的一个独立单位一般而言,进程包含如下三个特征。独立性动态性并发性。
407 1
|
11月前
|
消息中间件 人工智能 Java
抖音微信爆款小游戏大全:免费休闲/竞技/益智/PHP+Java全筏开源开发
本文基于2025年最新行业数据,深入解析抖音/微信爆款小游戏的开发逻辑,重点讲解PHP+Java双引擎架构实战,涵盖技术选型、架构设计、性能优化与开源生态,提供完整开源工具链,助力开发者从理论到落地打造高留存、高并发的小游戏产品。
|
12月前
|
JavaScript 安全 前端开发
Java开发:最新技术驱动的病人挂号系统实操指南与全流程操作技巧汇总
本文介绍基于Spring Boot 3.x、Vue 3等最新技术构建现代化病人挂号系统,涵盖技术选型、核心功能实现与部署方案,助力开发者快速搭建高效、安全的医疗挂号平台。
490 3
|
12月前
|
安全 Java 数据库
Java 项目实战病人挂号系统网站设计开发步骤及核心功能实现指南
本文介绍了基于Java的病人挂号系统网站的技术方案与应用实例,涵盖SSM与Spring Boot框架选型、数据库设计、功能模块划分及安全机制实现。系统支持患者在线注册、登录、挂号与预约,管理员可进行医院信息与排班管理。通过实际案例展示系统开发流程与核心代码实现,为Java Web医疗项目开发提供参考。
505 2
|
11月前
|
存储 Java 关系型数据库
Java 项目实战基于面向对象思想的汽车租赁系统开发实例 汽车租赁系统 Java 面向对象项目实战
本文介绍基于Java面向对象编程的汽车租赁系统技术方案与应用实例,涵盖系统功能需求分析、类设计、数据库设计及具体代码实现,帮助开发者掌握Java在实际项目中的应用。
400 0
|
Linux 数据库 Perl
【YashanDB 知识库】如何避免 yasdb 进程被 Linux OOM Killer 杀掉
本文来自YashanDB官网,探讨Linux系统中OOM Killer对数据库服务器的影响及解决方法。当内存接近耗尽时,OOM Killer会杀死占用最多内存的进程,这可能导致数据库主进程被误杀。为避免此问题,可采取两种方法:一是在OS层面关闭OOM Killer,通过修改`/etc/sysctl.conf`文件并重启生效;二是豁免数据库进程,由数据库实例用户借助`sudo`权限调整`oom_score_adj`值。这些措施有助于保护数据库进程免受系统内存管理机制的影响。