脚本之家 服务器常用软件
快捷导航
您的位置：首页 → 软件编程 → java → Java调用Linux命令

如何使用Java调用Linux系统命令

 更新时间：2021年11月03日 08:50:05   作者：DreamMakers  
这篇文章主要介绍了如何使用Java调用Linux系统命令，具有很好的参考价值，希望对大家有所帮助。如有错误或未考虑完全的地方，望不吝赐教

Java调用Linux系统命令

有时候，我们在使用Java做一些操作时，可能性能上并不能达到我们满意的效果，就拿最近工作中的遇到的一个场景来说，需要对大量的小文件进行合并成一个大文件。

最开始的想法是使用Java做文件操作，遍历所有小文件然后往一个文件写（可以做成并发写），但是发现操作过程中遇到个问题，写一千多个小文件在本机Windows下需要花费几十秒的时间，即使在Linux环境下高配置的机器也需要将近十秒，这明显对接口的响应时间产生重要影响。这块怎么优化下呢？

我们都知道在Linux下可以进行大文件的分割和合并，分别采用split和cat命令，于是做了个实验，在Linux下对相同的一个1G文件进行切割成1000个小文件，然后对这一千多个小文件进行合并。效果是惊人的！！！竟然瞬间就能合成完成了！这更加让我坚定了应该使用系统命令进行批量小文件进行合并的想法。

我们这里封装一个类，用来调用系统命令，然后得到系统调用的返回结果。

我们先封装了一个返回结果类：

package com.majing.learning.fileupload.common.process;
 
public class ProcessResult {
 private boolean success = false;
 private String errorMessage;
 private String outputMessage;
 public boolean isSuccess() {
  return success;
 }
 public void setSuccess(boolean success) {
  this.success = success;
 }
 public String getErrorMessage() {
  return errorMessage;
 }
 public void setErrorMessage(String errorMessage) {
  this.errorMessage = errorMessage;
 }
 public String getOutputMessage() {
  return outputMessage;
 }
 public void setOutputMessage(String outputMessage) {
  this.outputMessage = outputMessage;
 }
 
}

接着我们给出封装的系统调用实现类：

package com.majing.learning.fileupload.common.process;
 
import java.io.IOException;
import java.util.concurrent.CountDownLatch;
import java.util.concurrent.ExecutorService;
 
import org.apache.commons.lang3.StringUtils;
 
public class CommandUtils {
 
 public static ProcessResult runCmdTest(ExecutorService executorService, String command) throws IOException, InterruptedException {
  StringBuilder queryInputResult = new StringBuilder();
  StringBuilder queryErroInputResult = new StringBuilder();
  ProcessResult processResult = new ProcessResult();
  String[] cmd = { "/bin/sh", "-c", command};
  Process pro = Runtime.getRuntime().exec(cmd);
  CountDownLatch lock = new CountDownLatch(2);
  executorService.submit(new ProcessCheckTask(queryInputResult, lock, pro.getInputStream()));
  executorService.submit(new ProcessCheckTask(queryErroInputResult, lock, pro.getErrorStream()));
  boolean done = false;
  while (!done) {
   lock.await();
   done = true;
  }
  processResult.setOutputMessage(queryInputResult.toString());
  processResult.setErrorMessage(queryErroInputResult.toString());
  processResult.setSuccess(StringUtils.isBlank(processResult.getErrorMessage()));
  return processResult;
 }
}

其中ProcessCheckTask类如下：

package com.majing.learning.fileupload.common.process;
 
import java.io.BufferedReader;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.util.concurrent.CountDownLatch;
 
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
 
import com.majing.learning.fileupload.common.ConstValues;
 
public class ProcessCheckTask implements Runnable {
 
 private static Logger logger = LoggerFactory.getLogger(ProcessCheckTask.class);
 
 /** 锁 */
 private CountDownLatch lock;
 
 /** 执行结果输入流 */
 private InputStream inputStream;
 
 /** 字符拼接 */
 private StringBuilder queryInputResult;
 
 public ProcessCheckTask(StringBuilder queryInputResult, CountDownLatch lock, InputStream inputStream) {
  super();
  this.lock = lock;
  this.inputStream = inputStream;
  this.queryInputResult = queryInputResult;
 }
 
 @Override
 public void run() {
  try {
   BufferedReader bf = new BufferedReader(new InputStreamReader(inputStream));
   String line = null;
   while ((line = bf.readLine()) != null && line.length() > 0) {
    queryInputResult.append(line).append("\n");
   }
  } catch (Exception e) {
   logger.error(ConstValues.EXCEPTION_OCCURED, e);
  } finally {
   lock.countDown();
  }
 }
}

上面是一个简单实现，但是可能会存在一个问题，那就是执行系统命令的时间如果本身比较长，如果不想一直等待到系统命令执行完，而是在一段时间没有返回就直接认为失败，所以需要增加过期时间的考虑。这里我借助于Future框架，将上面的调用系统命令的方法封装成一个Callable对象。

package com.majing.learning.fileupload.common.process;
 
import java.util.concurrent.Callable;
import java.util.concurrent.ExecutorService;
 
public class CommandTask implements Callable<ProcessResult>{
 
 private ExecutorService executorService;
 
 private String command;
 
 public CommandTask(ExecutorService executorService, String command){
  this.executorService = executorService;
  this.command = command;
 }
 
 @Override
 public ProcessResult call() throws Exception {
  return CommandUtils.runCmdTest(executorService, command);
 }
 
}

然后在上面的CommandUtils的基础上再封装一层变成CommandHelper，具体实现如下：

package com.majing.learning.fileupload.common.process; 
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.Future;
import java.util.concurrent.TimeUnit; 
import org.slf4j.Logger;
import org.slf4j.LoggerFactory; 
import com.majing.learning.fileupload.common.ConstValues;
 
 public class CommandHelper {
 private static Logger logger = LoggerFactory.getLogger(CommandHelper.class);
 private static ExecutorService executorService=Executors.newFixedThreadPool(50);
 private static long default_timeout = 8000;
 public static ProcessResult process(String command){
  return process(command, default_timeout, TimeUnit.MILLISECONDS);
 }
 
 public static ProcessResult process(String command, long timeout, TimeUnit unit){
  CommandTask commandTask = new CommandTask(executorService, command);
  Future<ProcessResult> processResult = executorService.submit(commandTask);
  ProcessResult result = null;
  try{
   result = processResult.get(timeout, unit);
  }catch(Exception e){
   logger.error(ConstValues.EXCEPTION_OCCURED, e);
  }
  return result;
 } 
}

至此，我们在需要调用系统命令时直接调用CommandHelper.process(command)就可以了，然后拿到返回结果ProcessResult。我也是自己做个记录，有需要的朋友可以直接拿去用。

顺便说一句，采用封装的这个类在完成上面相同的任务时，时间都在相同的机器上，耗时从原来的10s瞬间减少至200ms以内，由此可见，在适当的场景调用系统命令是多么重要啊。

java执行Linux命令，支持通配符（*）

java执行linux或者windows命令，这个需求比较常见。

但是若使用 Runtime.getRuntime().exec(cmd); 会发现，若cmd中含有通配符，则无法执行，如cp /dira/*.txt /dirb

可用如下方式执行：

String[] cmdArr = new String[3];
        cmdArr[0] = "/bin/sh";
        cmdArr[1] = "-c";
        cmdArr[2] = command;
process = Runtime.getRuntime().exec(cmdArr);

以上为个人经验，希望能给大家一个参考，也希望大家多多支持脚本之家。

您可能感兴趣的文章:

相关文章

  • SpringBoot整合MyBatisPlus详解

    SpringBoot整合MyBatisPlus详解

    这篇文章详细介绍了SpringBoot整合mybatisplus的全过程，文中有详细的代码示例，具有一定的参考价值，需要的朋友可以参考一下
    2023-04-04
  • SpringBoot+docker环境变量配置详解

    SpringBoot+docker环境变量配置详解

    这篇文章主要介绍了SpringBoot+docker环境变量配置详解，文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧
    2020-10-10
  • 浅谈java泛型的作用及其基本概念

    浅谈java泛型的作用及其基本概念

    下面小编就为大家带来一篇浅谈java泛型的作用及其基本概念。小编觉得挺不错的，现在就分享给大家，也给大家做个参考。一起跟随小编过来看看吧
    2016-08-08
  • java实现上传图片尺寸修改和质量压缩

    java实现上传图片尺寸修改和质量压缩

    这篇文章主要为大家详细介绍了java实现上传图片尺寸修改和质量压缩，文中示例代码介绍的非常详细，具有一定的参考价值，感兴趣的小伙伴们可以参考一下
    2022-04-04
  • JVM处理未捕获异常的方法详解

    JVM处理未捕获异常的方法详解

    这篇文章主要给大家介绍了关于JVM处理未捕获异常的相关资料，文中通过示例代码以及图文介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧
    2019-01-01
  • SpringBoot+WebMagic实现网页爬虫的示例代码

    SpringBoot+WebMagic实现网页爬虫的示例代码

    本文是对spring boot+WebMagic+MyBatis做了整合,使用WebMagic爬取数据,然后通过MyBatis持久化爬取的数据到mysql数据库,具有一定的参考价值,感兴趣的可以了解一下
    2023-10-10
  • Java判断对象是否为空(包括null ,

    Java判断对象是否为空(包括null ,"")的方法

    这篇文章主要介绍了Java判断对象是否为空(包括null ,"")的方法，文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧
    2019-05-05
  • java实现多选批量删除功能

    java实现多选批量删除功能

    工作中批量删除可以提高我们的工作效率，今天这篇文章主要介绍了java实现多选批量删除功能，文中示例代码介绍的非常详细，具有一定的参考价值，感兴趣的小伙伴们可以参考一下
    2021-08-08
  • Eclipse项目怎么导入IDEA并运行(超详细)

    Eclipse项目怎么导入IDEA并运行(超详细)

    这篇文章主要介绍了Eclipse项目怎么导入IDEA并运行(超详细),文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧
    2020-10-10
  • springboot druid mybatis多数据源配置方式

    springboot druid mybatis多数据源配置方式

    这篇文章主要介绍了springboot druid mybatis多数据源配置方式,具有很好的参考价值,希望对大家有所帮助,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教
    2023-12-12

最新评论