标签：
package base; import java.io.IOException; import java.io.InputStream; public final class ExecLocakCommand { public static final String processUseBasic(String cmd) { Process p = null; StringBuilder sb = new StringBuilder(); try { String os = System.getProperty("os.name").toLowerCase(); if (os.startsWith("win")) { String commands = "cmd /c " + cmd; p = Runtime.getRuntime().exec(commands); } else if (os.startsWith("linux")) { String[] commands = new String[] { "/bin/sh", "-c", cmd }; p = Runtime.getRuntime().exec(commands); } String error = read(p.getErrorStream()); String outInfo = read(p.getInputStream()); String resultCode = "0";// 脚本中输出0表示命令执行成功 if (error.length() != 0) { // 如果错误流中有内容，表明脚本执行有问题 resultCode = "1"; } sb.append(resultCode).append("\n"); sb.append(error).append("\n"); sb.append(outInfo); p.waitFor(); } catch (Exception e) { e.printStackTrace(); } finally { try { p.getErrorStream().close(); p.getInputStream().close(); p.getOutputStream().close(); } catch (IOException e) { e.printStackTrace(); } } return sb.toString(); } public static final String read(InputStream in) throws IOException { StringBuilder sb = new StringBuilder(); int ch; while (-1 != (ch = in.read())) sb.append((char) ch); return sb.toString(); } public static void main(String[] args) { String comands = "dir"; //String comands = "ls "; String ret = ExecLocakCommand.processUseBasic(comands); System.out.println(ret); } } package base; import java.io.FileInputStream; import java.io.FileNotFoundException; import java.io.FileOutputStream; import java.io.IOException; import java.util.Properties; public class propertyUtil { private static Properties prop = new Properties(); private static void load(String fileName) { try { prop.load(new FileInputStream(fileName)); } catch (IOException e) { e.printStackTrace(); } } public static String getProperty(String fileName, String key) { load(fileName); return prop.getProperty(key); } public static void setProper(String fileName, String key, String value) { try { load(fileName); prop.setProperty(key, value); FileOutputStream fos = new FileOutputStream(fileName); prop.store(fos, null); fos.close(); } catch (FileNotFoundException e) { e.printStackTrace(); } catch (IOException e) { e.printStackTrace(); } } public static void main(String[] args) { System.out.println(propertyUtil.getProperty("test.properties", "key")); propertyUtil.setProper("test.properties", "key", "xxxx"); System.out.println(propertyUtil.getProperty("test.properties", "key")); } } package base; import java.io.BufferedReader; import java.io.File; import java.io.IOException; import java.io.InputStream; import java.io.InputStreamReader; import com.google.common.base.Splitter; import ch.ethz.ssh2.ChannelCondition; import ch.ethz.ssh2.Connection; import ch.ethz.ssh2.SCPClient; import ch.ethz.ssh2.Session; import ch.ethz.ssh2.StreamGobbler; public class RemoteExecutionApi { private int port = 22; private String username; private String password; public RemoteExecutionApi(int port, String username, String password) { super(); this.port = port; this.username = username; this.password = password; } public RemoteExecutionApi(String username, String password) { super(); this.username = username; this.password = password; } // 下载文件，目前只能下载单个文件 public void getFile(String remoteFile, String localTargetDirectory, String ips) { Iterable<String> result = Splitter.on(‘,‘).trimResults().omitEmptyStrings().split(ips); for (String ip : result) { Connection conn = new Connection(ip, port); try { conn.connect(); boolean isAuthenticated = conn.authenticateWithPassword(username, password); if (isAuthenticated == false) { System.err.println("authentication failed"); } SCPClient client = new SCPClient(conn); client.get(remoteFile, localTargetDirectory); conn.close(); } catch (IOException ex) { ex.printStackTrace(); // Logger operator System.exit(2); } } } //上传文件或者文件夹 public void putFile(String localFile, String remoteTargetDirectory, String ips) { Iterable<String> result = Splitter.on(‘,‘).trimResults().omitEmptyStrings().split(ips); for (String ip : result) { Connection conn = new Connection(ip, port); try { conn.connect(); boolean isAuthenticated = conn.authenticateWithPassword(username, password); if (isAuthenticated == false) { System.err.println("authentication failed"); } // folder if (new File(localFile).isDirectory()) { // 先创建根目录 String dirName = new File(localFile).getName(); remoteTargetDirectory = remoteTargetDirectory + "http://www.mamicode.com/" + dirName; Session sess1 = conn.openSession(); sess1.execCommand("mkdir -p " + remoteTargetDirectory); sess1.waitForCondition(ChannelCondition.EOF, 0); sess1.close(); putDir(conn, localFile, remoteTargetDirectory); } else if (new File(localFile).isFile()) {// file SCPClient client = new SCPClient(conn); client.put(localFile, remoteTargetDirectory); } conn.close(); } catch (IOException ex) { ex.printStackTrace(); // Logger operator System.exit(2); } } } private void putDir(Connection conn, String localDirectory, String remoteTargetDirectory) throws IOException { String[] fileList = new File(localDirectory).list(); for (String file : fileList) { String fullFileName = localDirectory + new File(localDirectory).separator + file; if (new File(fullFileName).isDirectory()) { final String subDir = remoteTargetDirectory + "http://www.mamicode.com/" + file; Session sess = conn.openSession(); sess.execCommand("mkdir " + subDir); sess.waitForCondition(ChannelCondition.EOF, 0); sess.close(); putDir(conn, fullFileName, subDir); } else { SCPClient client = new SCPClient(conn); client.put(fullFileName, remoteTargetDirectory); } } } // 执行命令 public String runCommand(String command, String ips) { StringBuilder sb = new StringBuilder(); Iterable<String> result = Splitter.on(‘,‘).trimResults().omitEmptyStrings().split(ips); for (String ip : result) { Connection conn = new Connection(ip, port); try { conn.connect(); boolean isAuthenticated = conn.authenticateWithPassword(username, password); if (isAuthenticated == false) { System.err.println("authentication failed"); } Session sess = conn.openSession(); sess.execCommand(command); InputStream stdout = new StreamGobbler(sess.getStdout()); BufferedReader br = new BufferedReader(new InputStreamReader(stdout)); while (true) { String line = br.readLine(); if (line == null) break; sb.append(line).append("\n"); } System.out.println("ExitCode: " + sess.getExitStatus()); br.close(); sess.close(); conn.close(); } catch (IOException ex) { ex.printStackTrace(System.err); // Logger operator System.exit(2); } } return sb.toString(); } // 删除临时文件 public void delTempDir(String remotePath, String ips) { runCommand("rm -rf " + remotePath, ips); } // 修改配置文件 public void modfiyPropertyFile(String remoteFileName, String key, String value, String ips) { String tempDir = "tempDir"; File folder = new File(tempDir); folder.mkdirs(); Iterable<String> result = Splitter.on(‘,‘).trimResults().omitEmptyStrings().split(ips); for (String ip : result) { Connection conn = new Connection(ip, port); try { conn.connect(); boolean isAuthenticated = conn.authenticateWithPassword(username, password); if (isAuthenticated == false) { System.err.println("authentication failed"); } SCPClient client = new SCPClient(conn); client.get(remoteFileName, tempDir); String tmpFileName = tempDir + File.separator + remoteFileName.substring(remoteFileName.lastIndexOf("http://www.mamicode.com/")); propertyUtil.setProper(tmpFileName, key, value); client.put(tmpFileName, remoteFileName.substring(0, remoteFileName.lastIndexOf(‘/‘))); conn.close(); } catch (IOException ex) { ex.printStackTrace(System.err); // Logger operator System.exit(2); } } clearDir(folder); } private void clearDir(File file) { if (file.isDirectory()) { for (File f : file.listFiles()) { clearDir(f); f.delete(); } } file.delete(); } // 在配置文件后添加新行 public void propertyFileAddNewline(String remoteFileName, String newline, String ips) { runCommand("echo " + newline + " >> " + remoteFileName, ips); } // 重启机器 public void reboot(String ips) { runCommand("reboot", ips); } // 执行本地命令 public String runLoaclCommand(String command) { return ExecLocakCommand.processUseBasic(command); } public static void main(String[] args) { RemoteExecutionApi client = new RemoteExecutionApi("root", "123456"); // client.getFile("/root/test.txt","C:", "192.168.238.129"); //client.putFile("D:\\test", "/root", "192.168.238.129"); // String ret = client.runCommand("ls /", "192.168.238.129"); // System.out.println(ret); // client.putDir("D:\\test", "/root", "192.168.238.129"); // client.modfiyPropertyFile("/root/test.proprety", "key", "yyy", // "192.168.238.129"); // client.propertyFileAddNewline("/root/xx.txt", "yyyyy=xxxxx", // "192.168.238.129"); String ret = client.runLoaclCommand("dir"); System.out.println(ret); System.out.println("----"); } }Ganymed实现基本的自动化部署API
，