java如何连续执行多条cmd命令

java连续执行多条cmd命令

命令之间用&连接

例如：

Process p = Runtime.getRuntime().exec("cmd /c d: & cd bin/");

java ssh登录执行多条cmd命令

java登录ssh执行多条命令，解决出现more自动回车的问题

import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.io.UnsupportedEncodingException;
import org.apache.logging.log4j.LogManager;
import org.apache.logging.log4j.Logger;
import com.jcraft.jsch.Channel;
import com.jcraft.jsch.JSch;
import com.jcraft.jsch.JSchException;
import com.jcraft.jsch.Session;
import com.jcraft.jsch.UIKeyboardInteractive;
import com.jcraft.jsch.UserInfo;

public class JavaSsh implements Runnable {
    protected Logger logger = LogManager.getLogger();
    /**
     * 退格
     */
    private static final String BACKSPACE = new String(new byte[] { 8 });

    /**
     * ESC
     */
    private static final String ESC = new String(new byte[] { 27 });

    /**
     * 空格
     */
    private static final String BLANKSPACE = new String(new byte[] { 32 });

    /**
     * 回车
     */
    private static final String ENTER = new String(new byte[] { 13 });

    /**
     * 某些设备回显数据中的控制字符
     */
    private static final String[] PREFIX_STRS = { BACKSPACE + "+" + BLANKSPACE + "+" + BACKSPACE + "+",
            "(" + ESC + "\\[\\d+[A-Z]" + BLANKSPACE + "*)+" };

    private int sleepTime = 200;

    /**
     * 连接超时(单次命令总耗时)
     */
    private int timeout = 4000;

    /**
     * 保存当前命令的回显信息
     */
    protected StringBuffer currEcho;

    /**
     * 保存所有的回显信息
     */
    protected StringBuffer totalEcho;
    private String ip;
    private int port;
    private String endEcho = "#,?,>,:";
    private String moreEcho = "---- More ----";
    private String moreCmd = BLANKSPACE;
    private JSch jsch = null;
    private Session session;
    private Channel channel;

    @Override
    public void run() {
        InputStream is;
        try {
            is = channel.getInputStream();
            String echo = readOneEcho(is);
            while (echo != null) {
                currEcho.append(echo);
                String[] lineStr = echo.split("\\n");
                if (lineStr != null && lineStr.length > 0) {
                    String lastLineStr = lineStr[lineStr.length - 1];
                    if (lastLineStr != null && lastLineStr.indexOf(moreEcho) > 0) {
                        totalEcho.append(echo.replace(lastLineStr, ""));
                    } else {
                        totalEcho.append(echo);
                    }
                }
                echo = readOneEcho(is);
            }
        } catch (IOException e) {
            e.printStackTrace();
        }
    }

    protected String readOneEcho(InputStream instr) {
        byte[] buff = new byte[1024];
        int ret_read = 0;
        try {
            ret_read = instr.read(buff);
        } catch (IOException e) {
            return null;
        }
        if (ret_read > 0) {
            String result = new String(buff, 0, ret_read);
            for (String PREFIX_STR : PREFIX_STRS) {
                result = result.replaceFirst(PREFIX_STR, "");
            }
            try {
                return new String(result.getBytes(), "GBK");
            } catch (UnsupportedEncodingException e) {
                e.printStackTrace();
                return null;
            }
        } else {
            return null;
        }
    }

    public JavaSsh(String ip, int port, String endEcho, String moreEcho) {
        this.ip = ip;
        this.port = port;
        if (endEcho != null) {
            this.endEcho = endEcho;
        }
        if (moreEcho != null) {
            this.moreEcho = moreEcho;
        }
        totalEcho = new StringBuffer();
        currEcho = new StringBuffer();
    }

    private void close() {
        if (session != null) {
            session.disconnect();
        }
        if (channel != null) {
            channel.disconnect();
        }
    }

    private boolean login(String[] cmds) {
        String user = cmds[0];
        String passWord = cmds[1];
        jsch = new JSch();
        try {
            session = jsch.getSession(user, this.ip, this.port);
            session.setPassword(passWord);
            UserInfo ui = new SSHUserInfo() {
                public void showMessage(String message) {
                }

                public boolean promptYesNo(String message) {
                    return true;
                }
            };
            session.setUserInfo(ui);
            session.connect(30000);
            channel = session.openChannel("shell");
            channel.connect(3000);
            new Thread(this).start();
            try {
                Thread.sleep(sleepTime);
            } catch (Exception e) {
            }
            return true;
        } catch (JSchException e) {
            return false;
        }
    }

    protected void sendCommand(String command, boolean sendEnter) {
        try {
            OutputStream os = channel.getOutputStream();
            os.write(command.getBytes());
            os.flush();
            if (sendEnter) {
                currEcho = new StringBuffer();
                os.write(ENTER.getBytes());
                os.flush();
            }
        } catch (IOException e) {
            e.printStackTrace();
        }
    }

    protected boolean containsEchoEnd(String echo) {
        boolean contains = false;
        if (endEcho == null || endEcho.trim().equals("")) {
            return contains;
        }
        String[] eds = endEcho.split(",");
        for (String ed : eds) {
            if (echo.trim().endsWith(ed)) {
                contains = true;
                break;
            }
        }
        return contains;
    }

    private String runCommand(String command, boolean ifEnter) {
        currEcho = new StringBuffer();
        sendCommand(command, ifEnter);
        int time = 0;
        if (endEcho == null || endEcho.equals("")) {
            while (currEcho.toString().equals("")) {
                try {
                    Thread.sleep(sleepTime);
                    time += sleepTime;
                    if (time >= timeout) {
                        break;
                    }
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
            }
        } else {
            while (!containsEchoEnd(currEcho.toString())) {
                try {
                    Thread.sleep(sleepTime);
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
                time += sleepTime;
                if (time >= timeout) {
                    break;
                }
                String[] lineStrs = currEcho.toString().split("\\n");
                if (lineStrs != null && lineStrs.length > 0) {
                    if (moreEcho != null && lineStrs[lineStrs.length - 1] != null
                            && lineStrs[lineStrs.length - 1].contains(moreEcho)) {
                        sendCommand(moreCmd, false);
                        currEcho.append("\n");
                        time = 0;
                        continue;
                    }
                }
            }
        }
        return currEcho.toString();
    }

    private String batchCommand(String[] cmds, int[] othernEenterCmds) {
        StringBuffer sb = new StringBuffer();
        for (int i = 2; i < cmds.length; i++) {
            String cmd = cmds[i];
            if (cmd.equals("")) {
                continue;
            }
            boolean ifInputEnter = false;
            if (othernEenterCmds != null) {
                for (int c : othernEenterCmds) {
                    if (c == i) {
                        ifInputEnter = true;
                        break;
                    }
                }
            }
            cmd += (char) 10;
            String resultEcho = runCommand(cmd, ifInputEnter);
            sb.append(resultEcho);
        }
        close();
        return totalEcho.toString();
    }

    public String executive(String[] cmds, int[] othernEenterCmds) {
        if (cmds == null || cmds.length < 3) {
            logger.error("{} ssh cmds is null", this.ip);
            return null;
        }
        if (login(cmds)) {
            return batchCommand(cmds, othernEenterCmds);
        }
        logger.error("{} ssh login error", this.ip);
        return null;
    }

    private abstract class SSHUserInfo implements UserInfo, UIKeyboardInteractive {
        public String getPassword() {
            return null;
        }

        public boolean promptYesNo(String str) {
            return true;
        }

        public String getPassphrase() {
            return null;
        }

        public boolean promptPassphrase(String message) {
            return true;
        }

        public boolean promptPassword(String message) {
            return true;
        }

        public void showMessage(String message) {
        }

        public String[] promptKeyboardInteractive(String destination, String name, String instruction, String[] prompt,
                boolean[] echo) {
            return null;
        }
    }

    public static void main(String[] args) {
        String ip = "192.168.0.238";
        int port = 22;
        JavaSsh JavaSsh2 = new JavaSsh(ip, port, null, null);
        String username = "ssh";
        String password = "yzfar.com";
        String[] cmds = { username, password, "display mac-address", "display mac-address" };
        String executive = JavaSsh2.executive(cmds, null);
        System.out.println(executive);
    }
}

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

原文链接：https://blog.csdn.net/xueba8/article/details/78945954