Ganymed实现基本的自动化部署API
2024-06-04 11:10:40
- Ganymed
SSH-2 for Java是一个纯Java实现的SHH2库，官网为http://www.ganymed.ethz.ch/ssh2/，最新的更新时间为2006年10月，在用之前，请仔细看一下FAQ，真的能避免很多很多问题
在google上找到的ganymed-ssh2的官网是http://www.ganymed.ethz.ch/ssh2/，进去看官网的英文简介可以看到该网站已经不维护该项目，并已经迁移到http://www.cleondris.ch/，在这个网站点击右上角的Contact，再点击open source就可以看到这个项目的新家,http://www.cleondris.ch/opensource/ssh2/,上面简单介绍了该项目能远程连接上远程机器，支持命令模式和shell模式，本地和远程端口转发，没有任何JCE依赖等,最后特别指出这个项目是为瑞士苏黎世的一个项目所创建。下面提供了2010-08-23发布的ganymed-ssh2-build251beta1.zip可供下载使用，下面还有在线文档和FAQ供开发者参考。 - JSch
采用java编写，使用ssh来操作远程服务器。JSch 是SSH2的一个纯Java实现。它允许你连接到一个sshd 服务器，支持文件的上传和下载，支持在远程机上执行shell命令、shell脚本、重启等操作。
但是这个类库偏向底层，仅是ssh2的实现，连文件夹的上传下载都不支持，并不是针对自动化部署的，编写的代码比较长，上手和实际使用起来不太方便，所以要对其进行必要的封装，比如封装连接的获取释放、文件夹和文件的拷贝、远程命令的执行等。 sshxcute
sshxcute 框架是对JSch 的简单封装，提供了更为便捷的 API 接口，提供了更加灵活实用的功能，从而可以让开发人员更加得心应手的使用。sshxcute 是一个框架，它允许工程师利用 Java 代码通过 SSH 连接远程执行 Linux/UNIX 系统上的命令或者脚本，这种方式不管是针对软件测试还是系统部署，都简化了自动化测试与系统环境部署的步骤。
但是它的封装比较简单，功能比较弱，只有上传和执行命令或脚本的功能。包装Ganymed。实现了文件的上传下载，文件夹的上传，远程执行命令，执行本地命令等基础API：
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 operatorSystem.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");}// folderif (new File(localFile).isDirectory()) {// 先创建根目录String dirName = new File(localFile).getName();remoteTargetDirectory = remoteTargetDirectory + "/" + 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()) {// fileSCPClient client = new SCPClient(conn);client.put(localFile, remoteTargetDirectory);}conn.close();} catch (IOException ex) {ex.printStackTrace();// Logger operatorSystem.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 + "/" + 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 operatorSystem.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("/"));propertyUtil.setProper(tmpFileName, key, value);client.put(tmpFileName, remoteFileName.substring(0, remoteFileName.lastIndexOf('/')));conn.close();} catch (IOException ex) {ex.printStackTrace(System.err);// Logger operatorSystem.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相关推荐
- Azure自动化部署运维浅谈
本次来谈一谈如何在Azure中实现一些简单的自动化运维的需求,一般来讲自动化运维我们通过很多第三方的工具平台实现,比较流行的目前有很多,比如老牌的chef, puppet,新兴的PowerShell ...
- Devstack 多节点自动化部署
本文为minxihou的翻译文章,转载请注明出处Bob Hou: http://blog.csdn.net/minxihou JmilkFan:minxihou的技术博文方向是 算法&Open ...
- Python—自动化部署工具：Fabric
Fabric是python编写的一款自动化部署工具 Fabric依赖paramiko进行SSH交互,某种意义上Fabric是对paramiko的封装,封装完成后,不需要像使用paramiko一样处理S ...
- 15 - 使用 Fabric 自动化部署
在 使用 Nginx 和 Gunicorn 部署 Django 博客 中,我们通过手工方式将代码部署到了服务器.整个过程涉及到十几条命令,输了 N 个字符.一旦我们本地的代码有更新,整个过程又得重复来 ...
- 利用Jenkins实现JavaWeb项目的自动化部署
修改代码,打包,上传,重启... 大把的时间花费在这些重复无味的工作上.笔者与当前主流的价值观保持一致:我们应该把时间花费在更有意义的事情上.我们可以尝试借助一些工具,让这些重复机械的工作交给计算机去 ...
- 构建iOS持续集成平台（三）——CI服务器与自动化部署
http://www.infoq.com/cn/articles/build-ios-continuous-integration-platform-part3 CI服务器 写到这儿,对于iOS开发者 ...
- DevOps平台中的自动化部署框架设计
本文目录: 一.背景 二.我们的需求是什么? 三.概念澄清 四.概念模型 五.总体设计 六.关键点设计 七.总结 一.背景 说到自动化部署,大家肯定都会想到一些配置管理工具,像ansible,chef ...
- 开源运维管理软件排名_云上自动化部署和运维的正确姿势
导读:今天起,"凌云时刻"特别推出"阿里云玩转 ECS"系列课程,每周二.周四固定更新,欢迎关注.本期为系列第 1 讲,由阿里云资深技术专家吴君印介绍上云最正确 ...
- tomcat自动化部署(拉取\备份、部署、更新、回滚)
一.传统部署方式及优缺点 1.传统部署方式 (1)纯手工scp (2)纯手工登录git pull.svn update (3)纯手工xftp往上拉 (4)开发给打一个压缩包,rz上去:解压 2.缺点 ...
最新文章
- 《剑指offer》-左旋转字符串
- javascript高级教程
- CVPR 2018 论文解读集锦（9月26日更新）
- SDNU 1467.杨辉三角形（水题）
- 孪生三兄弟 CycleGAN, DiscoGAN, DualGAN
- PJ Naughter's Freeware Library
- php常用linux命令httpd,Linux常用的100个命令
- 递归算法和迭代算法_Java中没有递归的二进制搜索–迭代算法
- oracle修改窗口字体大小,jQuery之字体大小的设置方法
- nodejs mysql access denied_Node使用Sequlize连接Mysql报错：Access denied for user ‘xxx’@‘localhost’...
- 让模型实现“终生学习”，佐治亚理工学院提出Data-Free的增量学习
- pdo mysql连接类_PHP PDO-MYSQL：如何在不同类之间使用数据库连接
- ubuntu终端连接远程计算机
- Android11 如何将系统默认设置中文
- pd.concat实现数据合并
- tomcat安装以及部署jpress
- python解压zip_用Python处理ZIP压缩包
- 打造更完美的小程序商城
- 做一条USB A转Type C 数据线 和OTG线
- (转)唯品会订单分库分表的实践总结以及关键步骤