JAVA远程执行Shell脚本类

1、java远程执行shell脚本类

 package com.test.common.utility;

 import java.io.IOException;

 import java.io.InputStream;

 import java.io.UnsupportedEncodingException;

 import java.nio.charset.Charset;

 import org.apache.commons.io.IOUtils;

 import org.apache.commons.logging.Log;

 import org.apache.commons.logging.LogFactory;

 import ch.ethz.ssh2.ChannelCondition;

 import ch.ethz.ssh2.Connection;

 import ch.ethz.ssh2.Session;

 import ch.ethz.ssh2.StreamGobbler;

 public class RmtShellExecutor {

     /** 远程机器IP */

     private final String ip;

     /** 用户名 */

     private final String usr;

     /** 密码 */

     private final String psword;

    /**

      * 构造函数

      *

      * @param ip

      * @param usr

      * @param ps

     */

     public RmtShellExecutor(String ip, String usr, String ps) {

         this.ip = ip;

         this.usr = usr;

         this.psword = ps;

     }

     /**

      * 执行脚本

      *

      * @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=" + outStr);

                 System.out.println("outErr=" + outErr);

                 ret = session.getExitStatus();

             } else {

                 logger.info("登录远程机器失败" + ip);

                 throw new AppException("登录远程机器失败" + ip); // 自定义异常类 实现略

             }

         } finally {

             if (conn != null) {

                 conn.close();

             }

             IOUtils.closeQuietly(stdOut);

             IOUtils.closeQuietly(stdErr);

         }

         return ret;

     }

     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();

     }

 }

2、调用测试

         RmtShellExecutor exe = new RmtShellExecutor("10.190.1.123", "root", "root");

         try {

             int i = exe.exec("sh /dcdata/etl/runjobinfo/cscscs.sh");

             System.out.println(i);

         } catch (Exception e) {

             e.printStackTrace();

             logger.info("执行dsjob错误" + e.getMessage());

         }

更新中。。。