java在本地远程执行服务器的操作以及工具类 jsch

迷南。 2022-12-19 11:55 77阅读 0赞

首先是连接远程服务器，通过pom.xml 引入相关工具类

<dependency>
                <groupId>com.jcraft</groupId>
                <artifactId>jsch</artifactId>
                <version>0.1.54</version>
            </dependency>

然后调用工具类通过以下方式可以实现可以对类进行封装使更易用

import java.io.BufferedReader;
    import java.io.IOException;
    import java.io.InputStream;
    import java.io.InputStreamReader;
    import com.jcraft.jsch.ChannelExec;
    import com.jcraft.jsch.JSch;
    import com.jcraft.jsch.JSchException;
    import com.jcraft.jsch.Session;
    /**
     * @author ：zhaofuh
     * @date ：Created in 2020/11/6 15:57
     * @description：本地调用服务器的命令
     * @modified By：
     * @version: 0.1$
     */
    public class SSHHelper {
        /**
         * 远程 执行命令并返回结果调用过程 是同步的（执行完才会返回）
         * @param host  主机名
         * @param user  用户名
         * @param psw   密码
         * @param port  端口
         * @param command   命令
         * @return
         */
        public static String exec(String host,String user,String psw,int port,String command){
            StringBuffer sb= new StringBuffer();
            Session session =null;
            ChannelExec openChannel =null;
            try {
                JSch jsch=new JSch();
                session = jsch.getSession(user, host, port);
                java.util.Properties config = new java.util.Properties();
                config.put("StrictHostKeyChecking", "no");//跳过公钥的询问
                session.setConfig(config);
                session.setPassword(psw);
                session.connect(5000);//设置连接的超时时间
                openChannel = (ChannelExec) session.openChannel("exec");
                openChannel.setCommand(command); //执行命令
                int exitStatus = openChannel.getExitStatus(); //退出状态为-1，直到通道关闭
                System.out.println(exitStatus);
    
                // 下面是得到输出的内容
                openChannel.connect();
                InputStream in = openChannel.getInputStream();
                BufferedReader reader = new BufferedReader(new InputStreamReader(in));
                String buf = null;
                while ((buf = reader.readLine()) != null) {
                    sb.append(buf+"\n");
                }
            } catch (JSchException | IOException e) {
                sb.append(e.getMessage()+"\n");
            }finally{
                if(openChannel!=null&&!openChannel.isClosed()){
                    openChannel.disconnect();
                }
                if(session!=null&&session.isConnected()){
                    session.disconnect();
                }
            }
            return sb.toString();
        }
    
        /**解压jar包到指定目录下
         * cd axs  && unzip clauser_service-0.0.1-SNAPSHOT.jar -d temp3/
         * 解压的文件替换后重新打包
         * jar -cfM0 new-classes.jar ./* 必须在解压的目录下
         * 组合解压命令
         * cd test && jar -cfM0 test.jar ./* && mv test.jar ../ && cd .. && java -noverify -jar test.jar
         * @param args
         */
        public static void main(String args[]){
            String exec = exec("IP", "用户", "密码", 22, "cd axs  && unzip clauser_service-0.0.1-SNAPSHOT.jar -d temp3/");
            System.out.println(exec);
        }
    }