zoukankan      html  css  js  c++  java
  • 使用java代码连接到局域网内的Windows服务器中的软件并执行指令

    使用java代码连接到局域网内的Windows服务器中的软件并执行指令

    1、前言

    最近需要实现一个功能,编写java代码连接windows服务器并运行命令。

    使用一款叫做freeSSHd的软件进行连接。使用时,将freeSSHd安装到想要连接的目标服务器上(相当于java代码是客户端,freeSSHd是服务器)。

    1.1 freeSSHd 简介

    freeSSHd是一个SFTP服务器。它支持使用密码或SSH免密登录的方法进行上传文件或远程操作系统。

    其实就是一个远程操作的服务端,安装了SFTP服务器的操作系统就可以被支持进行远程操作。这个在Linux操作系统中使用比较常见。但是在Windows操作系统上也会有这样的需求,比如我们需要自动化地在另一台Windows的服务器上进行远程部署服务,这是就需要能远程操作该系统。而freeSSHd是提供给Windows的一个免费的SFTP服务器,搭建简单,使用效果也比较好。

    PS,相关api的使用:

    使用文档

    2、 安装freeSSHd

    2.1 下载

    软件下载地址:下载freeSSHd.exe

    image-20210707165000134

    2.2 开始安装freeSSHd:

    双击程序进行安装,选好自己的安装目录后就一路next即可

    image-20210707165546956

    image-20210707165604618

    image-20210707165729365

    image-20210707165758444

    image-20210707165845143

    image-20210707165913075

    安装过程中会提示两个选项

    1. Private keys should be created. Should I do it now?

      这是在询问现在是否创建私钥,选是。

    image-20210707170003634

    1. Do you want to run FreeSSHd as a system service?

      这是在询问是否开启freeSSHd服务,选是。

    image-20210707170023075

    2.3 freeSSHd配置

    双击桌面上的freeSSHd或者从开始菜单栏中的freeSSHd并不会打开软件,这是因为软件已经启动并隐藏在右下角处。

    在桌面右下角右击freeSSHdService,选择settings进行配置。

    image-20210707171210210

    1、首先配置Server status

    找到Server status选项卡,SSH server is running. 默认是红叉,点击下方 Click here to start it.启动服务,红叉会变成绿勾

    如果没有变成绿勾,并报错“the specified address is already in use”,这是因为服务在上面已经开启,需要关闭。win + r 输入services.msc 找到freeSShd的服务关闭,

    image-20210707173421439

    image-20210707173517962

    关闭之后重启点击Click here to start it启动服务,这时候发现服务已经启动。

    image-20210707173550798

    2、配置用户

    找到Users选项卡,点击add添加一个用户

    第二栏authorization选项选择 Password stored as SHA1 hash,接着输入用户名和密码。之后确定

    image-20210707173734760

    image-20210707173745175

    3、配置端口

    找到SSH选项卡  listen address:监听的地址  port:监听的端口  max number of connections:最大连接数,自行配置,端口号默认22尽量不要修改

    image-20210707173944863

    3、远程连接服务器(Windows和Linux)在控制台界面执行指令

    创建普通的maven项目saodisheng-freesshd

    image-20210707174440527

    不得不说idea2021.1相较于之前使用的2019.3界面更加舒适啦

    3.1 方式一

    需要借助Ganymed SSH的jar包

    <!-- https://mvnrepository.com/artifact/ch.ethz.ganymed/ganymed-ssh2 -->
    <dependency>
        <groupId>ch.ethz.ganymed</groupId>
        <artifactId>ganymed-ssh2</artifactId>
        <version>262</version>
    </dependency>
    

    代码如下

    package top.saodisheng.ganymed;
    
    import ch.ethz.ssh2.Connection;
    import ch.ethz.ssh2.Session;
    import ch.ethz.ssh2.StreamGobbler;
    import lombok.extern.slf4j.Slf4j;
    
    import java.io.BufferedReader;
    import java.io.IOException;
    import java.io.InputStream;
    import java.io.InputStreamReader;
    
    /**
     * description:
     *
     * @author 扫地生_saodisheng
     * @date 2021/7/7
     */
    @Slf4j
    public class SSH_Ganymed {
        public static void main(String[] args) {
            // 服务器ipv4地址
            String ipv4Address = "xx.xx.xx.xx";
            // freeSshd设置的连接端口
            int port = 22;
            // username
            String freeSshdUserName = "saodisheng";
            // password
            String freeSshdUserPassword = "saodisheng";
            // 在cmd中执行的命令
            String command = "java -version";
    //        String command = "E:\Environment\Navicat_Premium_12\navicat.exe";
    
            connectServer(ipv4Address, port, freeSshdUserName, freeSshdUserPassword, command);
    
        }
    
        public static void connectServer(String ipv4Address, int port, String freeSshdUserName, String freeSshdUserpassword, String command) {
            Connection conn = null;
            Session session = null;
            InputStream is = null;
            BufferedReader br = null;
            try {
                // 创建连接
                conn = new Connection(ipv4Address, port);
                conn.connect(); // 开启连接
                // login
                boolean isLogin = conn.authenticateWithPassword(freeSshdUserName, freeSshdUserpassword); // 获取登录状态
                if (isLogin) {
                    log.debug("Login success");
                    System.out.println("login success");
                } else {
                    log.debug("login failed");
                    System.out.println("login failed");
                }
                // 获取session即打开会话框(终端)
                session = conn.openSession();
                // 执行指令
                session.execCommand(command);
    
                // 获取输出的结果,用于将结果输出到控制台
                is = new StreamGobbler(session.getStdout());
                br = new BufferedReader(new InputStreamReader(is, "GBK"));
                while (true) {
                    String line = br.readLine();
                    if (line == null) {
                        break;
                    }
                    System.out.println(line);
                }
                // 查看指令执行的结果,session.getExitStatus(); 获取指令的执行结果,0表示执行成功,非0表示失败。
                System.out.println(session.getExitStatus());
            } catch (IOException e) {
                log.error("", e);
                System.out.println(e.getMessage());
                e.printStackTrace();
            } finally {
                try {
                    if (br != null) {
                        br.close();
                    }
                    if (is != null) {
                        is.close();
                    }
                    if (session != null) {
                        session.close();
                    }
                    if (conn != null) {
                        conn.close();
                    }
                } catch (IOException e) {
                    e.printStackTrace();
                }
            }
        }
    }
    

    image-20210707184120434

    3.2 方式二

    需要借助JSch的包

    <!-- https://mvnrepository.com/artifact/com.jcraft/jsch -->
    <dependency>
        <groupId>com.jcraft</groupId>
        <artifactId>jsch</artifactId>
        <version>0.1.55</version>
    </dependency>
    

    代码如下

    package saodisheng.jsch;
    
    
    import com.jcraft.jsch.*;
    import lombok.extern.slf4j.Slf4j;
    
    import java.io.BufferedReader;
    import java.io.IOException;
    import java.io.InputStream;
    import java.io.InputStreamReader;
    import java.util.Properties;
    
    /**
     * description:
     *
     * @author 扫地生_saodisheng
     * @date 2021/7/7
     */
    @Slf4j
    public class SSH_JSch {
        public static void main(String[] args) {
            // 服务器ipv4地址
            String ipv4Address = "xx.xx.xx.xx";
            // freeSshd设置的连接端口
            int port = 22;
            // username
            String freeSshdUserName = "saodisheng";
            // password
            String freeSshdUserPassword = "saodisheng";
            // 在cmd中执行的命令
            String command = "ls -al; pwd";
    
            String info = SSH_JSch.connectServer(ipv4Address, port, freeSshdUserName, freeSshdUserPassword, command);
            System.out.println(info);
    
        }
        public static String connectServer(String freesshdIpFour, int freesshdPort, String freesshdUsername, String freesshdPassword, String command) {
            // 创建JSch对象
            JSch jSch = new JSch();
            BufferedReader reader = null;
            Channel channel = null;
            Session session = null;
            try {
                // 获取会话
                session = jSch.getSession(freesshdUsername, freesshdIpFour, freesshdPort);
                if (session == null) {
                    log.debug("session 打开失败, session为空");
                    System.out.println("session 打开失败, session为空");
                }
                // 设置第一次登陆的时候提示,可选值:(ask | yes | no),不设置的话会出现连接失败的情况
                session.setConfig("StrictHostKeyChecking", "no");
                // 设置登录密码
                session.setPassword(freesshdPassword);
                Properties config = new Properties();
                session.setTimeout(1500);
                // 连接
                session.connect();
                if (command != null) {
                    // 打开通道
                    channel = session.openChannel("exec");
                    // 设置指令
                    ((ChannelExec) channel).setCommand(command);
                    // 指令提交执行
                    channel.connect();
                    InputStream in = channel.getInputStream();
                    reader = new BufferedReader(new InputStreamReader(in, "GBK"));
                    String buf;
                    StringBuffer sb = new StringBuffer();
                    while ((buf = reader.readLine()) != null) {
                        sb = sb.append(buf + "
    ");
                    }
                    // 查看指令执行状态, 0表示成功,非0表示失败
                    int exitStatus = channel.getExitStatus();
                    System.out.println(exitStatus);
                    return sb.toString();
                }
            } catch (Exception e) {
                e.printStackTrace();
            } finally {
                try {
                    if (reader != null) {
                        reader.close();
                    }
                } catch (IOException e) {
                    e.printStackTrace();
                }
                if (session != null) {
                    session.disconnect();
                }
                if (channel != null) {
                    channel.disconnect();
                }
            }
            return null;
        }
    }
    

    image-20210707185752405

    可能遇到问题:

    com.jcraft.jsch.JSchException: UnknownHostKey: x.x.x.x. RSA key fingerprint is 1b:1e:f4:0e:e7:07:e2:9a:4b:15:7d:1a:47:a9:e8:eb
    

    image-20210707185620210

    问题解决

    4、在cmd里面运行程序

    比如说我要在cmd控制台中启动Navicat软件

    1、找到Navicat所在的路径

    image-20210707193025597

    我的路径为:E:EnvironmentNavicat_Premium_12 avicat.exe

    切记:路径中不可出现空格

    2、打开cmd界面,直接将路径输入即可

    image-20210707193226293

    结合前面的程序可知,我们只要将cmd中的指令更换即可实现启动指定程序的目的。

    比如我要通过java程序远程打开指定的软件:

    image-20210707193426051

    由此也可以发现,当我们需要远程启动相应的服务时,最重要的是要连接到对应的服务器。在Linux平台上,我们也可以通过远程启动shell脚本来控制某些指定的服务。

    5、参考文章

    参考文章1

    参考文章2

    向大神看齐
  • 相关阅读:
    读《高效能人士的七个习惯》有感
    Springboot中的日志
    fastjson JSON.toJavaObject() 实体类首字母大写属性无法解析问题
    java多线程编程实例
    IDEA插件配置推荐
    Spring Boot 自定义数据源 DruidDataSource
    zookeeper环境搭建
    eureka注册中心的使用
    记事本编码
    Chrome浏览器基本操作
  • 原文地址:https://www.cnblogs.com/Liu-xing-wu/p/14983240.html
Copyright © 2011-2022 走看看