java怎么执行CMD，Linux shell,redis shell，mysql shell等等shell命令

Myth丶恋晨 2021-10-18 11:48 394阅读 0赞

写这篇的起因在于，当我想用java代码实现文件的上传下载，想起curl 或者wget已经进行很好的封装，但他们都是基于C实现的命令行运行方式，暂时没有API或者好的方法可以操作，只能想到直接调用本地的CMD命令去实现。对C系列的语言没有接触过，不知道他们是否有API的概念？？或者C系列语言，Python，Java等等之间是否可以有共同的接触交流方式？？？

## 一、windows cmd ##

### 两种实现 ###

#### 1.1 Runtime.exec ####

@Test
        public void cmd1(){
            try {
                Process process = Runtime.getRuntime().exec("ping wwww.baidu.com");
    
                // Get input streams
                BufferedReader stdInput = new BufferedReader(new InputStreamReader(process.getInputStream(), Charset.forName("GBK")));
                BufferedReader stdError = new BufferedReader(new InputStreamReader(process.getErrorStream(),Charset.forName("GBK")));
    
                // Read command standard output
                String s;
                System.out.println("Standard output: ");
                while ((s = stdInput.readLine()) != null) {
                    System.out.println(s);
                }
    
                // Read command errors
                System.out.println("Standard error: ");
                while ((s = stdError.readLine()) != null) {
                    System.out.println(s);
                }
            } catch (Exception e) {
                e.printStackTrace(System.err);
            }
        }

#### 1.2 ProcessBuilder.start() ####

@Test
        public void cmd3(){
            ProcessBuilder processBuilder = new ProcessBuilder();
            // Windows
            processBuilder.command("cmd.exe", "/c", "ping wwww.baidu.com");
    //        processBuilder.command("cmd.exe","ping wwww.baidu.com");
    
            try {
    
                Process process = processBuilder.start();
    
                BufferedReader reader =
                        new BufferedReader(new InputStreamReader(process.getInputStream(),Charset.forName("GBK")));
    
                String line;
                while ((line = reader.readLine()) != null) {
                    System.out.println(line);
                }
    
                int exitCode = process.waitFor();
                System.out.println("\nExited with error code : " + exitCode);
    
            } catch (IOException e) {
                e.printStackTrace();
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }

## 二、Linux shell ##

### 一种原理，基于Jsch实现的,两种操作方式 ###

### 2.1 原生的jsch操作，[我从官网找的示例][Link 1] ###

<dependency>
        <groupId>com.jcraft</groupId>
        <artifactId>jsch</artifactId>
        <version>0.1.54</version>
    </dependency>

/* -*-mode:java; c-basic-offset:2; indent-tabs-mode:nil -*- */
    /**
     * This program will demonstrate remote exec.
     *   $ CLASSPATH=.:../build javac Exec.java 
     *   $ CLASSPATH=.:../build java Exec
     * You will be asked username, hostname, displayname, passwd and command.
     * If everything works fine, given command will be invoked 
     * on the remote side and outputs will be printed out.
     *
     */
    import com.jcraft.jsch.*;
    import java.awt.*;
    import javax.swing.*;
    import java.io.*;
    
    public class Exec{
      public static void main(String[] arg){
        try{
          JSch jsch=new JSch();  
    
          String host=null;
          if(arg.length>0){
            host=arg[0];
          }
          else{
            host=JOptionPane.showInputDialog("Enter username@hostname",
                                             System.getProperty("user.name")+
                                             "@localhost"); 
          }
          String user=host.substring(0, host.indexOf('@'));
          host=host.substring(host.indexOf('@')+1);
    
          Session session=jsch.getSession(user, host, 22);
          
          /*
          String xhost="127.0.0.1";
          int xport=0;
          String display=JOptionPane.showInputDialog("Enter display name", 
                                                     xhost+":"+xport);
          xhost=display.substring(0, display.indexOf(':'));
          xport=Integer.parseInt(display.substring(display.indexOf(':')+1));
          session.setX11Host(xhost);
          session.setX11Port(xport+6000);
          */
    
          // username and password will be given via UserInfo interface.
          UserInfo ui=new MyUserInfo();
          session.setUserInfo(ui);
          session.connect();
    
          String command=JOptionPane.showInputDialog("Enter command", 
                                                     "set|grep SSH");
    
          Channel channel=session.openChannel("exec");
          ((ChannelExec)channel).setCommand(command);
    
          // X Forwarding
          // channel.setXForwarding(true);
    
          //channel.setInputStream(System.in);
          channel.setInputStream(null);
    
          //channel.setOutputStream(System.out);
    
          //FileOutputStream fos=new FileOutputStream("/tmp/stderr");
          //((ChannelExec)channel).setErrStream(fos);
          ((ChannelExec)channel).setErrStream(System.err);
    
          InputStream in=channel.getInputStream();
    
          channel.connect();
    
          byte[] tmp=new byte[1024];
          while(true){
            while(in.available()>0){
              int i=in.read(tmp, 0, 1024);
              if(i<0)break;
              System.out.print(new String(tmp, 0, i));
            }
            if(channel.isClosed()){
              if(in.available()>0) continue; 
              System.out.println("exit-status: "+channel.getExitStatus());
              break;
            }
            try{Thread.sleep(1000);}catch(Exception ee){}
          }
          channel.disconnect();
          session.disconnect();
        }
        catch(Exception e){
          System.out.println(e);
        }
      }
    
      public static class MyUserInfo implements UserInfo, UIKeyboardInteractive{
        public String getPassword(){ return passwd; }
        public boolean promptYesNo(String str){
          Object[] options={ "yes", "no" };
          int foo=JOptionPane.showOptionDialog(null, 
                 str,
                 "Warning", 
                 JOptionPane.DEFAULT_OPTION, 
                 JOptionPane.WARNING_MESSAGE,
                 null, options, options[0]);
           return foo==0;
        }
      
        String passwd;
        JTextField passwordField=(JTextField)new JPasswordField(20);
    
        public String getPassphrase(){ return null; }
        public boolean promptPassphrase(String message){ return true; }
        public boolean promptPassword(String message){
          Object[] ob={passwordField}; 
          int result=
            JOptionPane.showConfirmDialog(null, ob, message,
                                          JOptionPane.OK_CANCEL_OPTION);
          if(result==JOptionPane.OK_OPTION){
            passwd=passwordField.getText();
            return true;
          }
          else{ 
            return false; 
          }
        }
        public void showMessage(String message){
          JOptionPane.showMessageDialog(null, message);
        }
        final GridBagConstraints gbc = 
          new GridBagConstraints(0,0,1,1,1,1,
                                 GridBagConstraints.NORTHWEST,
                                 GridBagConstraints.NONE,
                                 new Insets(0,0,0,0),0,0);
        private Container panel;
        public String[] promptKeyboardInteractive(String destination,
                                                  String name,
                                                  String instruction,
                                                  String[] prompt,
                                                  boolean[] echo){
          panel = new JPanel();
          panel.setLayout(new GridBagLayout());
    
          gbc.weightx = 1.0;
          gbc.gridwidth = GridBagConstraints.REMAINDER;
          gbc.gridx = 0;
          panel.add(new JLabel(instruction), gbc);
          gbc.gridy++;
    
          gbc.gridwidth = GridBagConstraints.RELATIVE;
    
          JTextField[] texts=new JTextField[prompt.length];
          for(int i=0; i<prompt.length; i++){
            gbc.fill = GridBagConstraints.NONE;
            gbc.gridx = 0;
            gbc.weightx = 1;
            panel.add(new JLabel(prompt[i]),gbc);
    
            gbc.gridx = 1;
            gbc.fill = GridBagConstraints.HORIZONTAL;
            gbc.weighty = 1;
            if(echo[i]){
              texts[i]=new JTextField(20);
            }
            else{
              texts[i]=new JPasswordField(20);
            }
            panel.add(texts[i], gbc);
            gbc.gridy++;
          }
    
          if(JOptionPane.showConfirmDialog(null, panel, 
                                           destination+": "+name,
                                           JOptionPane.OK_CANCEL_OPTION,
                                           JOptionPane.QUESTION_MESSAGE)
             ==JOptionPane.OK_OPTION){
            String[] response=new String[prompt.length];
            for(int i=0; i<prompt.length; i++){
              response[i]=texts[i].getText();
            }
    	return response;
          }
          else{
            return null;  // cancel
          }
        }
      }
    }

### 2.2 Hutool包实现的封装 ###

#### [这里是我之前的测试示例,这里就不演示了][Link 2] ####

## 三、redis shell ##

### 1种原理，多种操作方式吧，都是基于Jedis的实现，不同的封装方式，可以原生的Jedis,或者Spring Data Redis中Reids的集成操作，或者身边的不同的对Jedis的封装工具。 ###

先空着，有时间，我在做些示例，放在这里

## 四、Mysql/Oracle/MongoDb ##

### 都是基于Jdbc的封装，很多框架或者封装都已经实现可以简单的使用。 ###

先空着，有时间，我在做些示例，放在这里

## 五、还有一点，关于Lua脚本问题，先不讨论了 ##

[Link 1]: http://www.jcraft.com/jsch/examples/Exec.java.html
[Link 2]: https://mp.csdn.net/postedit/95055700