Ganymed实现基本的自动化部署API

2024-09-08 07:38

本文主要是介绍Ganymed实现基本的自动化部署API,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

  • 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的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/1147510

相关文章

闲置电脑也能活出第二春?鲁大师AiNAS让你动动手指就能轻松部署

对于大多数人而言,在这个“数据爆炸”的时代或多或少都遇到过存储告急的情况,这使得“存储焦虑”不再是个别现象,而将会是随着软件的不断臃肿而越来越普遍的情况。从不少手机厂商都开始将存储上限提升至1TB可以见得,我们似乎正处在互联网信息飞速增长的阶段,对于存储的需求也将会不断扩大。对于苹果用户而言,这一问题愈发严峻,毕竟512GB和1TB版本的iPhone可不是人人都消费得起的,因此成熟的外置存储方案开

hdu1043(八数码问题,广搜 + hash(实现状态压缩) )

利用康拓展开将一个排列映射成一个自然数,然后就变成了普通的广搜题。 #include<iostream>#include<algorithm>#include<string>#include<stack>#include<queue>#include<map>#include<stdio.h>#include<stdlib.h>#include<ctype.h>#inclu

基本知识点

1、c++的输入加上ios::sync_with_stdio(false);  等价于 c的输入,读取速度会加快(但是在字符串的题里面和容易出现问题) 2、lower_bound()和upper_bound() iterator lower_bound( const key_type &key ): 返回一个迭代器,指向键值>= key的第一个元素。 iterator upper_bou

阿里开源语音识别SenseVoiceWindows环境部署

SenseVoice介绍 SenseVoice 专注于高精度多语言语音识别、情感辨识和音频事件检测多语言识别: 采用超过 40 万小时数据训练,支持超过 50 种语言,识别效果上优于 Whisper 模型。富文本识别:具备优秀的情感识别,能够在测试数据上达到和超过目前最佳情感识别模型的效果。支持声音事件检测能力,支持音乐、掌声、笑声、哭声、咳嗽、喷嚏等多种常见人机交互事件进行检测。高效推

【C++】_list常用方法解析及模拟实现

相信自己的力量,只要对自己始终保持信心,尽自己最大努力去完成任何事,就算事情最终结果是失败了,努力了也不留遗憾。💓💓💓 目录   ✨说在前面 🍋知识点一:什么是list? •🌰1.list的定义 •🌰2.list的基本特性 •🌰3.常用接口介绍 🍋知识点二:list常用接口 •🌰1.默认成员函数 🔥构造函数(⭐) 🔥析构函数 •🌰2.list对象

【Prometheus】PromQL向量匹配实现不同标签的向量数据进行运算

✨✨ 欢迎大家来到景天科技苑✨✨ 🎈🎈 养成好习惯,先赞后看哦~🎈🎈 🏆 作者简介:景天科技苑 🏆《头衔》:大厂架构师,华为云开发者社区专家博主,阿里云开发者社区专家博主,CSDN全栈领域优质创作者,掘金优秀博主,51CTO博客专家等。 🏆《博客》:Python全栈,前后端开发,小程序开发,人工智能,js逆向,App逆向,网络系统安全,数据分析,Django,fastapi

让树莓派智能语音助手实现定时提醒功能

最初的时候是想直接在rasa 的chatbot上实现,因为rasa本身是带有remindschedule模块的。不过经过一番折腾后,忽然发现,chatbot上实现的定时,语音助手不一定会有响应。因为,我目前语音助手的代码设置了长时间无应答会结束对话,这样一来,chatbot定时提醒的触发就不会被语音助手获悉。那怎么让语音助手也具有定时提醒功能呢? 我最后选择的方法是用threading.Time

Android实现任意版本设置默认的锁屏壁纸和桌面壁纸(两张壁纸可不一致)

客户有些需求需要设置默认壁纸和锁屏壁纸  在默认情况下 这两个壁纸是相同的  如果需要默认的锁屏壁纸和桌面壁纸不一样 需要额外修改 Android13实现 替换默认桌面壁纸: 将图片文件替换frameworks/base/core/res/res/drawable-nodpi/default_wallpaper.*  (注意不能是bmp格式) 替换默认锁屏壁纸: 将图片资源放入vendo

C#实战|大乐透选号器[6]:实现实时显示已选择的红蓝球数量

哈喽,你好啊,我是雷工。 关于大乐透选号器在前面已经记录了5篇笔记,这是第6篇; 接下来实现实时显示当前选中红球数量,蓝球数量; 以下为练习笔记。 01 效果演示 当选择和取消选择红球或蓝球时,在对应的位置显示实时已选择的红球、蓝球的数量; 02 标签名称 分别设置Label标签名称为:lblRedCount、lblBlueCount

Kubernetes PodSecurityPolicy:PSP能实现的5种主要安全策略

Kubernetes PodSecurityPolicy:PSP能实现的5种主要安全策略 1. 特权模式限制2. 宿主机资源隔离3. 用户和组管理4. 权限提升控制5. SELinux配置 💖The Begin💖点点关注,收藏不迷路💖 Kubernetes的PodSecurityPolicy(PSP)是一个关键的安全特性,它在Pod创建之前实施安全策略,确保P