java操作远程Linux服务器的工具类：如获取linux服务器上的文件等操作

向右看齐 2024-04-01 17:43 19阅读 0赞

## 导入pom依赖 ##

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

## 工具类 ##

import com.jcraft.jsch.*;
    
    import java.io.*;
    import java.util.ArrayList;
    import java.util.List;
    import java.util.Properties;
    import java.util.Vector;
    
    public class SFTPUtil {
        
    
        private ChannelSftp sftp;
    
        private Session session;
        // SFTP 登录用户名
        private String username;
        //SFTP 登录密码
        private String password;
        //私钥
        private String privateKey;
        //SFTP 服务器地址IP地址
        private String host;
        //SFTP 端口
        private int port;
    
    
        /**
         * 构造基于密码认证的sftp对象
         */
        public SFTPUtil(String username, String password, String host, int port) {
        
            this.username = username;
            this.password = password;
            this.host = host;
            this.port = port;
        }
    
        /**
         * 构造基于秘钥认证的sftp对象
         */
        public SFTPUtil(String username, String host, int port, String privateKey) {
        
            this.username = username;
            this.host = host;
            this.port = port;
            this.privateKey = privateKey;
        }
    
        public SFTPUtil() {
         }
    
    
        /**
         * 连接sftp服务器
         */
        public void login() {
        
            try {
        
                JSch jsch = new JSch();
                if (privateKey != null) {
        
                    jsch.addIdentity(privateKey);// 设置私钥
                }
    
                session = jsch.getSession(username, host, port);
    
                if (password != null) {
        
                    session.setPassword(password);
                }
                Properties config = new Properties();
                config.put("StrictHostKeyChecking", "no");
    
                session.setConfig(config);
                session.connect();
    
                Channel channel = session.openChannel("sftp");
                channel.connect();
    
                sftp = (ChannelSftp) channel;
            } catch (JSchException e) {
        
                e.printStackTrace();
            }
        }
    
        /**
         * 关闭连接 server
         */
        public void logout() {
        
            if (sftp != null) {
        
                if (sftp.isConnected()) {
        
                    sftp.disconnect();
                }
            }
            if (session != null) {
        
                if (session.isConnected()) {
        
                    session.disconnect();
                }
            }
        }
    
    
        /**
         * 将输入流的数据上传到sftp作为文件。文件完整路径=basePath+directory
         *
         * @param directory    上传到该目录
         * @param sftpFileName sftp端文件名
         */
        public boolean upload(String directory, String sftpFileName, InputStream input) throws SftpException {
        
            try {
        
                if (directory != null && !"".equals(directory)) {
        
                    sftp.cd(directory);
                }
                sftp.put(input, sftpFileName);  //上传文件
                return true;
            } catch (SftpException e) {
        
                return false;
            }
        }
    
        public void cd(String directory) throws SftpException {
        
            if (directory != null && !"".equals(directory) && !"/".equals(directory)) {
        
                sftp.cd(directory);
            }
    
        }
    
    
        /**
         * 下载文件。
         *
         * @param directory    下载目录
         * @param downloadFile 下载的文件
         * @param saveFile     存在本地的路径
         */
        public void download(String directory, String downloadFile, String saveFile) {
        
            System.out.println("download:" + directory + " downloadFile:" + downloadFile + " saveFile:" + saveFile);
    
            File file = null;
            try {
        
                if (directory != null && !"".equals(directory)) {
        
                    sftp.cd(directory);
                }
                file = new File(saveFile);
                sftp.get(downloadFile, new FileOutputStream(file));
            } catch (SftpException | FileNotFoundException e) {
        
                e.printStackTrace();
                if (file != null) {
        
                    file.delete();
                }
            }
    
        }
    
    
        /**
         * 删除文件
         *
         * @param directory  要删除文件所在目录
         * @param deleteFile 要删除的文件
         */
        public void delete(String directory, String deleteFile) throws SftpException {
        
            if (directory != null && !"".equals(directory)) {
        
                sftp.cd(directory);
            }
            sftp.rm(deleteFile);
        }
    
    
        /**
         * 列出目录下的文件
         *
         * @param directory 要列出的目录
         */
        public List<String> listFiles(String directory) throws SftpException {
        
            Vector<?> objects = sftp.ls(directory);
            List<String> list = new ArrayList<>();
            for (Object s : objects){
        
                String x = s.toString();
                String[] s1 = x.split(" ");
                System.out.println(s1[s1.length -1]);
            }
            return list;
        }
    
        public boolean isExistsFile(String directory, String fileName) {
        
    
            List<String> findFileList = new ArrayList<>();
            ChannelSftp.LsEntrySelector selector = lsEntry -> {
        
                if (lsEntry.getFilename().equals(fileName)) {
        
                    findFileList.add(fileName);
                }
                return 0;
            };
    
            try {
        
                sftp.ls(directory, selector);
            } catch (SftpException e) {
        
                e.printStackTrace();
            }
    
            return findFileList.size() > 0;
        }
    }