java远程调用shell脚本

系统管理员 2022-07-16 02:29 298阅读 0赞

需要下载一个包：http://101.110.118.74/www.ganymed.ethz.ch/ssh2/ganymed-ssh2-build210.zip

import java.io.IOException;
    import java.io.InputStream;
    import java.io.UnsupportedEncodingException;
    import java.nio.charset.Charset;
    
    import ch.ethz.ssh2.ChannelCondition;
    import ch.ethz.ssh2.Connection;
    import ch.ethz.ssh2.Session;
    import ch.ethz.ssh2.StreamGobbler;
    
    public class RemoteShellExecutor {
    
         private Connection conn;
         /** 远程机器IP */
         private String ip;
         /** 用户名 */
         private String osUsername;
         /** 密码 */
         private String password;
         private String charset = Charset.defaultCharset().toString();
    
         private static final int TIME_OUT = 1000 * 5 * 60;
    
         public RemoteShellExecutor(String ip, String usr, String pasword) {
              this.ip = ip;
             this.osUsername = usr;
             this.password = pasword;
         }
    
         /**
         * 登录
         */
         private boolean login() throws IOException {
             conn = new Connection(ip);
             conn.connect();
             return conn.authenticateWithPassword(osUsername, password);
         }
    
         /**
         * 执行脚本
         *
         * @param cmds
         * @return
         * @throws Exception
         */
         public int exec(String cmds) throws Exception {
             InputStream stdOut = null;
             InputStream stdErr = null;
             String outStr = "";
             String outErr = "";
             int ret = -1;
             try {
             if (login()) {
                 // Open a new {@link Session} on this connection
                 Session session = conn.openSession();
                 // Execute a command on the remote machine.
                 session.execCommand(cmds);
    
                 stdOut = new StreamGobbler(session.getStdout());
                 outStr = processStream(stdOut, charset);
    
                 stdErr = new StreamGobbler(session.getStderr());
                 outErr = processStream(stdErr, charset);
    
                 session.waitForCondition(ChannelCondition.EXIT_STATUS, TIME_OUT);
    
                 System.out.println("正确输出：" + outStr);
                 if(!"".equals(outErr)) {
                     System.out.println("错误输出：" + outErr);
                 }
                 ret = session.getExitStatus();
             } else {
                 throw new Exception("登录远程机器失败" + ip); // 自定义异常类 实现略
             }
             } finally {
                 if (conn != null) {
                     conn.close();
                 }
                 stdOut.close();
                 stdErr.close();
             }
             return ret;
         }
    
         /**
         * @param in
         * @param charset
         * @return
         * @throws IOException
         * @throws UnsupportedEncodingException
         */
         private String processStream(InputStream in, String charset) throws Exception {
             byte[] buf = new byte[1024];
             StringBuilder sb = new StringBuilder();
             while (in.read(buf) != -1) {
                 sb.append(new String(buf, charset));
             }
             return sb.toString();
         }
    
        public static void main(String args[]) throws Exception {
            RemoteShellExecutor executor = new RemoteShellExecutor("10.10.15.208", "root", "123456");
            executor.exec("export LANG=en_US && ls -lh /root");
        }
    }