java调用远程服务器的shell脚本以及停止的方法实现

<dependency>

    <groupid>org.jvnet.hudson</groupid>

    <artifactid>ganymed-ssh2</artifactid>

    <version>build210-hudson- 1 </version>

</dependency>

import java.io.ioexception;

import java.io.inputstream;

import java.io.unsupportedencodingexception;

import java.nio.charset.charset;

import org.apache测试数据mons.io.ioutils;

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 final string get_shell_pid = "ps -ef | grep '%s' | grep -v grep |awk '{print $2}'" ;

    private final string kill_shell_pid = "kill -15 %s" ;

    private static final int time_out = 1000 * 5 * 60 ;

    /**

    * 构造函数

    * @param ip

    * @param usr

    * @param pasword

    */

    public remoteshellexecutor(string ip, string usr, string pasword) {

      this .ip = ip;

      this .osusername = usr;

      this .password = pasword;

    }

    /**

    * 登录

    * @return

    * @throws ioexception

    */

    private boolean login() throws ioexception {

      conn = new connection(ip);

      conn.connect();

      return conn.authenticatewithpassword(osusername, password);

    }

    /**

    * 执行脚本

    *

    * @param cmds

    * @return

    * @throws exception

    */

    public executeresultvo exec(string cmds) throws exception {

      inputstream stdout = null ;

      inputstream stderr = null ;

      executeresultvo executeresultvo = new executeresultvo();

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

        executeresultvo.setoutstr(outstr);

       executeresultvo.setouterr(outerr);

      } else {

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

      }

      } finally {

        if (conn != null ) {

          conn.close();

        }

        ioutils.closequietly(stdout);

        ioutils.closequietly(stderr);

      }

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

      int len = 0 ;

      while ((len=in.read(buf)) != - 1 ) {

        sb.append( new string(buf, 0 ,len, charset));

      }

      return sb.tostring();

    }

   public static void main(string args[]) throws exception {

     //调远程shell

     remoteshellexecutor executor = new remoteshellexecutor( "192.168.234.123" , "root" , "beebank" );

     system.out.println(executor.exec( "sh /data/checkmysql.sh" ));

     //获取远程shell 进程 pid

     executeresultvo executeresultvo = executor.exec(string.format(get_shell_pid, "sh /data/checkmysql.sh" ));

     //杀掉shell进程

     executeresultvo executeresultvo1 = executor.exec(string.format(kill_shell_pid ,executeresultvo.getoutstr()));

   }

   public class executeresultvo<t>{

     private string outstr;

     private string outerr;

      //省略get set

  }

}