Java使用ssh协议链接服务器

花衰,有些事,你越是在乎,痛的就越厉害,放开了,看淡了,慢慢就淡化了。只是,我们总是事后才明白,懂生活,很难,会生活,更难。

初衷:

在每次部署项目的时候,每次都得打包,使用xshell连接linux服务器,每次在连接的时候都会很慢,还得杀死原先的进程id并删除之前的版本,很烦!!所以采用java代码的方式连接服务器实现自动上传换版本启动的过程。

首先:

使用ssh协议的jar引进工程pom依赖:

        <dependency>
            <groupId>ch.ethz.ganymed</groupId>
            <artifactId>ganymed-ssh2</artifactId>
            <version>build210</version>
        </dependency>

可能本地中远程仓库中没有改依赖包,解决方法:首先去这个网站(http://www.ganymed.ethz.ch/ssh2/)去下载,然后呢把他添加到自己的本地仓库中,具体操作方法如下:

首先下载的是一个zip文件,解压文件,里面有一个jar包,然后把该jar包加入到本地仓库中:

mvn install:install-file -Dfile=D:\software\Maven\ganymed-ssh2-build210\ganymed-ssh2-build210.jar -DgroupId=ch.ethz.ganymed -DartifactId=ganymed-ssh2 -Dversion=build210 -Dpackaging=jar

然后在添加依赖就ojbk了。

下面就是代码实现:

代码实现: 

1、实体类

public class RemoteConnect {
    private String ip;
    private String userName;
    private String password;
//省略 set
get
|

2、业务代码

import ch.ethz.ssh2.Connection;
import ch.ethz.ssh2.SCPClient;
import ch.ethz.ssh2.Session;
import ch.ethz.ssh2.StreamGobbler;
 
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
 
import java.io.*;
 
public class RemoteSSH {
 
    private static final Logger logger = LoggerFactory.getLogger(RemoteSSH.class);
    private static String DEFAULTCHARTSET = "UTF-8";
    private static Connection conn;
    /**
     * 远程登录linux 服务器
     *
     * @param remoteConnect
     * @return
     */
    public static boolean login(RemoteConnect remoteConnect) {
        boolean flag = false;
        try {
            conn = new Connection(remoteConnect.getIp());
            conn.connect();//连接
            flag = conn.authenticateWithPassword(remoteConnect.getUserName(), remoteConnect.getPassword());
            if (flag) {
                logger.info("---认证成功-----");
            } else {
                logger.error("------认证失败-----");
                conn.close();
            }
 
        } catch (IOException e) {
            e.printStackTrace();
        }
 
        return flag;
    }
 
    /**
     * @param remoteConnect
     * @param keyFile       一个文件对象指向一个文件,该文件包含OpenSSH密钥格式的用户的DSA或RSA私钥(PEM,不能丢失"
     *                      -----BEGIN DSA PRIVATE KEY-----" or "-----BEGIN RSA PRIVATE KEY-----"标签
     * @param keyfilePass   如果秘钥文件加密 需要用该参数解密,如果没有加密可以为null
     * @return Boolean
     * @throws
     * @Title: loginByKey
     * @Description: 秘钥方式  远程登录linux服务器
     */
    public static Boolean loginByFileKey(RemoteConnect remoteConnect, File keyFile, String keyfilePass) {
        boolean flag = false;
        // 输入密钥所在路径
        // File keyfile = new File("C:\\temp\\private");
        try {
            conn = new Connection(remoteConnect.getIp());
            conn.connect();
            // 登录认证
            flag = conn.authenticateWithPublicKey(remoteConnect.getUserName(), keyFile, keyfilePass);
            if (flag) {
                logger.info("认证成功!");
            } else {
                logger.info("认证失败!");
                conn.close();
            }
        } catch (Exception e) {
            e.printStackTrace();
        }
        return flag;
    }
 
    /**
     * @param remoteConnect
     * @param keys          一个字符[],其中包含用户的DSA或RSA私钥(OpenSSH密匙格式,您不能丢失“
     *                      ----- begin DSA私钥-----”或“-----BEGIN RSA PRIVATE KEY-----“标签。char数组可以包含换行符/换行符。
     * @param keyPass       如果秘钥字符数组加密  需要用该字段解密  否则不需要可以为null
     * @return Boolean
     * @throws
     * @Title: loginByCharsKey
     * @Description: 秘钥方式  远程登录linux服务器
     */
    public static Boolean loginByCharsKey(RemoteConnect remoteConnect, char[] keys, String keyPass) {
 
        boolean flag = false;
        // 输入密钥所在路径
        // File keyfile = new File("C:\\temp\\private");
        try {
            conn = new Connection(remoteConnect.getIp());
            conn.connect();
            // 登录认证
            flag = conn.authenticateWithPublicKey(remoteConnect.getUserName(), keys, keyPass);
            if (flag) {
                logger.info("认证成功!");
            } else {
                logger.info("认证失败!");
                conn.close();
            }
        } catch (Exception e) {
            e.printStackTrace();
        }
        return flag;
    }
 
    public static String execute(String cmd) {
        String result = "";
        try {
            Session session = conn.openSession();// 打开一个会话
            session.execCommand(cmd);// 执行命令;
            result = processStdout(session.getStdout(), DEFAULTCHARTSET);
            // 如果为得到标准输出为空,说明脚本执行出错了 StringUtils.isBlank(result)
            if (result.equals("")) {
                result = processStdout(session.getStderr(), DEFAULTCHARTSET);
            }
//            conn.close();
//            session.close();
        } catch (IOException e) {
            e.printStackTrace();
        }
        return result;
 
    }
 
    /**
     * @param in      输入流对象
     * @param charset 编码
     * @return String 以纯文本的格式返回
     * @throws
     * @Title: processStdout
     * @Description: 解析脚本执行的返回结果
     */
    public static String processStdout(InputStream in, String charset) {
        InputStream stdout = new StreamGobbler(in);
        StringBuffer buffer = new StringBuffer();
        try {
            BufferedReader br = new BufferedReader(new InputStreamReader(stdout, charset));
            String line = null;
            while ((line = br.readLine()) != null) {
                buffer.append(line + "\n");
            }
        } catch (UnsupportedEncodingException e) {
            e.printStackTrace();
        } catch (IOException e) {
            e.printStackTrace();
        }
        return buffer.toString();
    }
 
    /**
     * @param cmd 脚本或者命令
     * @return String 命令执行成功后返回的结果值,如果命令执行失败,返回空字符串,不是null
     * @throws
     * @Title: executeSuccess
     * @Description: 远程执行shell脚本或者命令
     */
    public static String executeSuccess(String cmd) {
        String result = "";
        try {
            Session session = conn.openSession();// 打开一个会话
            session.execCommand(cmd);// 执行命令
            result = processStdout(session.getStdout(), DEFAULTCHARTSET);
            conn.close();
            session.close();
        } catch (IOException e) {
            e.printStackTrace();
        }
        return result;
    }
 
    /**
     * @return String
     * @throws
     * @Title: ConnectLinux
     * @Description: 通过用户名和密码关联linux服务器
     */
    public static String connectLinux(String ip, String userName,
                                      String password, String commandStr) {
 
        logger.info("ConnectLinuxCommand  scpGet===" + "ip:" + ip + "  userName:" + userName + "  commandStr:"
                + commandStr);
 
        String returnStr = "";
//        boolean result = true;
 
        RemoteConnect remoteConnect = new RemoteConnect();
        remoteConnect.setIp(ip);
        remoteConnect.setUserName(userName);
        remoteConnect.setPassword(password);
        try {
            if (login(remoteConnect)) {
                returnStr = execute(commandStr);
                System.out.println(returnStr);
            }
        } catch (Exception e) {
            e.printStackTrace();
        }
 
//        if (returnStr != null && !returnStr.equals("")) {
//            result = false;
//        }
        return returnStr;
    }
 
    /**
     * @param ip         (其他服务器)
     * @param userName   用户名(其他服务器)
     * @param password   密码(其他服务器)
     * @param remoteFile 文件位置(其他服务器)
     * @param localDir   本服务器目录
     * @return void
     * @throws IOException
     * @throws
     * @Title: scpGet
     * @Description: 从其他服务器获取文件到本服务器指定目录
     */
    public static void scpGet(String ip, String userName,
                              String password, String remoteFile, String localDir)
            throws IOException {
 
        logger.info("ConnectLinuxCommand  scpGet===" + "ip:" + ip + "  userName:" + userName + "  remoteFile:"
                + remoteFile + "  localDir:" + localDir);
        RemoteConnect remoteConnect = new RemoteConnect();
        remoteConnect.setIp(ip);
        remoteConnect.setUserName(userName);
        remoteConnect.setPassword(password);
 
        if (login(remoteConnect)) {
            SCPClient client = new SCPClient(conn);
            client.get(remoteFile, localDir);
            conn.close();
        }
    }
 
    /**
     * @param ip
     * @param userName
     * @param password
     * @param localFile
     * @param remoteDir
     * @return void
     * @throws IOException
     * @throws
     * @Title: scpPut
     * @Description: 将文件复制到其他计算机中
     */
    public static void scpPut(String ip, String userName,
                              String password, String localFile, String remoteDir)
            throws IOException {
        logger.info("ConnectLinuxCommand  scpPut===" + "ip:" + ip + "  userName:" + userName + "  localFile:"
                + localFile + "  remoteDir:" + remoteDir);
 
        RemoteConnect remoteConnect = new RemoteConnect();
        remoteConnect.setIp(ip);
        remoteConnect.setUserName(userName);
        remoteConnect.setPassword(password);
 
        if (login(remoteConnect)) {
            //检测指定路径下的jar是否存在
            SCPClient client = new SCPClient(conn);
            client.put(localFile, remoteDir);
            System.out.println("aa");
            conn.close();
        }
    }
 
    //重新打包上传启动功能
    public static String allDeploy(String ip, String userName,
                                   String password) {
        RemoteConnect connect = new RemoteConnect(ip, userName, password);
        if (login(connect)) {
            String commandLine = "ps -ef|grep dailybuild-|grep -v grep|wc -l";
            String execute = execute(commandLine);
            if (execute.equals("1\n")) {
                String str = "ps -ef|grep dailybuild-|grep -v grep |awk '{print $2}' | xargs kill -9;";
                String result = execute(str);
//                String deleteStr = "cd /export;rm -rf dailybuild-0.0.1-SNAPSHOT.jar";
                String deleteStr = "find / -name dailybuild-0.0.1-SNAPSHOT.jar | xargs rm -rf ";
                execute(deleteStr);
                SCPClient client = new SCPClient(conn);
                try {
                    client.put("D:\\Project\\dailybuildV3_New\\target\\dailybuild-0.0.1-SNAPSHOT.jar", "/export");
                    logger.info("-----上传jar包成功----开始启动----");
                    execute("nohup java -jar /export/dailybuild-0.0.1-SNAPSHOT.jar > /export/dailybuild.log &");
                    String startLog = execute("tail -f /export/dailybuild.log");
                    if (startLog.contains("Started DailyBuildApplication"))
                        logger.info("-----完成启动----");
                    conn.close();
                } catch (IOException e) {
                    e.printStackTrace();
                }
            } else {
                String isExist = "find / -name dailybuild-0.0.1-SNAPSHOT.jar";
                String result = execute(isExist);
                if (result != "") execute("nohup java -jar " + result + ">/export/dailybuild.log &");
            }
        }
        return "完成";
    }
 
}

3、测试代码类

public class RemoteTest {
    private static String ip = "10.85.153.27";
    private static String userName = "root";
    private static String password = "#TESTzdh27";
 
    public static void main(String[] args) throws IOException {
//        RemoteConnect connect = new RemoteConnect("10.85.153.27", "root", "#TESTzdh27");
//        boolean login = RemoteSSH.login(connect);
//        System.out.println(login);
 
//        String commandStr = "smtpnum = 'lsof -i:8091 | wc -l';print $smtpnum";
//        String result = RemoteSSH.connectLinux("10.85.153.27", "root", "#TESTzdh27", commandStr);
//        System.out.println(result);
        //下载
//        RemoteSSH.scpGet(ip, userName, password, "/home/shell/protect.sh", "D:\\java");
//        RemoteSSH.scpPut(ip,userName,password,"D:\\Project\\dailybuildV3_New\\target\\dailybuild-0.0.1-SNAPSHOT.jar","/home/shell");
        RemoteSSH.allDeploy(ip, userName, password);
    }
}

结论:测试没得问题,这种方法呢其实跟我们用xshell直接去连接服务器是一样的,只不过速度相对快一点,java中代码也是跟在客户端敲的代码是一样的,初步目标实现了。

转载自:https://blog.csdn.net/geng2568/article/details/107166135

本文Java使用ssh协议链接服务器到此结束。学会忍耐,往往比强势更可贵。等你羽翼丰满时,再十倍地去偿还伤害你尊严的人。小编再次感谢大家对我们的支持!

您可能有感兴趣的文章
Java 实例 - 字符串反转

Java实例--字符串替换

Java实例--删除字符串中最后一个字符

Java实例--查找字符串最后一次出现的位置

Java实例--字符串比较