此程序的目的是执行远程机器上的Shell脚本。

【环境参数】

远程机器IP：192.168.234.123

用户名：root

密码：root

Shell脚本的路径：/home/IFileGenTool/BakProvisionAndOccurEntrance.sh

【具体步骤】

1、在远程机器上，准备Shell脚本。

[root@localhost IFileGenTool]# vim ./load_data.sh

1 #!/bin/sh2 source /etc/profile3 dbName=$14 tableName=$25 echo [`date +'%Y-%m-%d %H:%M:%S'`]' start loading data...'6 mysql -uroot -p123456 -P3306 ${dbName} -e "LOAD DATA LOCAL INFILE '/home/IFileGenTool/bak_data/bak_data_bak.txt' INTO TABLE ${tableName} FIELDS TERMINATED BY ';'"7 echo [`date +'%Y-%m-%d %H:%M:%S'`]' end loading data...'8 exit9 EOF

 

2、导入需要依赖的jar包。

Java远程调用Shell脚本这个程序需要ganymed-ssh2-build210.jar包。

下载地址：http://www.ganymed.ethz.ch/ssh2/

为了调试方便，可以将\ganymed-ssh2-build210\src下的代码直接拷贝到我们的工程里，

此源码的好处就是没有依赖很多其他的包，拷贝过来干干净净。

1 
     
      2     
      
       org.jvnet.hudson
      3     
      
       ganymed-ssh2
      4     
      
       build210-hudson-1
      5 
     

3、编写RemoteShellExecutor工具类。

1 import java.io.IOException;  2 import java.io.InputStream;  3 import java.io.UnsupportedEncodingException;  4 import java.nio.charset.Charset;  5   6 import org.apache.commons.io.IOUtils;  7   8 import ch.ethz.ssh2.ChannelCondition;  9 import ch.ethz.ssh2.Connection; 10 import ch.ethz.ssh2.Session; 11 import ch.ethz.ssh2.StreamGobbler; 12  13 public class RemoteShellExecutor { 14       15      private Connection conn; 16      /** 远程机器IP */ 17      private String ip; 18      /** 用户名 */ 19      private String osUsername; 20      /** 密码 */ 21      private String password; 22      private String charset = Charset.defaultCharset().toString(); 23  24      private static final int TIME_OUT = 1000 * 5 * 60; 25  26      /** 27       * 构造函数 28       * @param ip 29       * @param usr 30       * @param pasword 31       */ 32      public RemoteShellExecutor(String ip, String usr, String pasword) { 33           this.ip = ip; 34          this.osUsername = usr; 35          this.password = pasword; 36      } 37  38  39      /** 40      * 登录 41      * @return 42      * @throws IOException 43      */ 44      private boolean login() throws IOException { 45          conn = new Connection(ip); 46          conn.connect(); 47          return conn.authenticateWithPassword(osUsername, password); 48      } 49  50      /** 51      * 执行脚本 52      *  53      * @param cmds 54      * @return 55      * @throws Exception 56      */ 57      public int exec(String cmds) throws Exception { 58          InputStream stdOut = null; 59          InputStream stdErr = null; 60          String outStr = ""; 61          String outErr = ""; 62          int ret = -1; 63          try { 64          if (login()) { 65              // Open a new {@link Session} on this connection 66              Session session = conn.openSession(); 67              // Execute a command on the remote machine. 68              session.execCommand(cmds); 69               70              stdOut = new StreamGobbler(session.getStdout()); 71              outStr = processStream(stdOut, charset); 72               73              stdErr = new StreamGobbler(session.getStderr()); 74              outErr = processStream(stdErr, charset); 75               76              session.waitForCondition(ChannelCondition.EXIT_STATUS, TIME_OUT); 77               78              System.out.println("outStr=" + outStr); 79              System.out.println("outErr=" + outErr); 80               81              ret = session.getExitStatus(); 82          } else { 83              throw new Exception("登录远程机器失败" + ip); // 自定义异常类 实现略 84          } 85          } finally { 86              if (conn != null) { 87                  conn.close(); 88              } 89              IOUtils.closeQuietly(stdOut); 90              IOUtils.closeQuietly(stdErr); 91          } 92          return ret; 93      } 94  95      /** 96      * @param in 97      * @param charset 98      * @return 99      * @throws IOException100      * @throws UnsupportedEncodingException101      */102      private String processStream(InputStream in, String charset) throws Exception {103          byte[] buf = new byte[1024];104          StringBuilder sb = new StringBuilder();105          while (in.read(buf) != -1) {106              sb.append(new String(buf, charset));107          }108          return sb.toString();109      }110 111     public static void main(String args[]) throws Exception {112         RemoteShellExecutor executor = new RemoteShellExecutor("192.168.234.123", "root", "beebank");113         // 执行myTest.sh 参数为java Know dummy114         System.out.println(executor.exec("/home/IFileGenTool /load_data.sh t_users myDataBase01"));115     }116 }

 

4、Java程序调用远程Shell

private void backupAndRestoreData(String originalTableName) throws Exception {        //1. 调用远程Shell脚本，对生产库中数据进行导出和导入备份。                    LogUtil.getLogger().info("######    1. 开始对数据库中数据利用进行导出和导入备份   ######");    RemoteShellExecutor executor = new RemoteShellExecutor("192.168.234.123", "root", "root");    // 执行myTest.sh 参数为java Know dummy    System.out.println(executor.exec("/home/IFileGenTool/load_data.sh")); }

 

5、运行结果

备份数据成功。

 

6、说明：

0 // getExitStatus方法的返回值

注：一般情况下shell脚本正常执行完毕，getExitStatus方法返回0。

此方法通过远程命令取得Exit Code/status。但并不是每个server设计时都会返回这个值，如果没有则会返回null。

在调用getExitStatus时，要先调用WaitForCondition方法，通过ChannelCondition.java接口的定义可以看到每个条件的具体含义。见以下代码：

ChannelCondition.java的源代码

参考连接：http://yu.you163.blog.163.com/blog/static/339877742012117101039968/