Java工具类之SFTP遍历查找指定目录下包含关键字的的所有文件

迷南。 2023-09-25 17:00 57阅读 0赞

## 一、工具类代码 ##

>     public class SFTPUtil {
>         private transient Logger logger = LoggerFactory.getLogger(this.getClass());
>     
>         private ChannelSftp sftp;
>     
>         private Session session;
>         /**
>          * SFTP 登录用户名
>          */
>         private String username;
>         /**
>          * SFTP 登录密码
>          */
>         private String password;
>         /**
>          * 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;
>         }
>     
>        
>     
>         public SFTPUtil() {
>         }
>     
>     
>         /**
>          * 连接sftp服务器
>          */
>         public void login() {
>             try {
>                 JSch jsch = new JSch();
>                 if (privateKey != null) {
>                     jsch.addIdentity(privateKey);// 设置私钥
>                     jsch.addIdentity(privateKey, pripass);
>                 }
>     
>                 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();
>                 logger.info("sftp login exception:{}", e);
>             }
>         }
>     
>         /**
>          * 关闭连接 server
>          */
>         public void logout() {
>             if (sftp != null) {
>                 if (sftp.isConnected()) {
>                     sftp.disconnect();
>                 }
>             }
>             if (session != null) {
>                 if (session.isConnected()) {
>                     session.disconnect();
>                 }
>             }
>         }
>     
>       
>     
>     
>         /**
>          * 下载文件。
>          *
>          * @param directory    下载目录
>          * @param downloadFile 下载的文件
>          * @param saveFile     存在本地的路径
>          */
>         public void download(String directory, String downloadFile, String saveFile) throws SftpException, FileNotFoundException {
>             if (directory != null && !"".equals(directory)) {
>                 sftp.cd(directory);
>             }
>             File file = new File(saveFile);
>             sftp.get(downloadFile, new FileOutputStream(file));
>         }
>     
>     
>     
>     
>         /**
>          * 删除文件
>          *
>          * @param directory  要删除文件所在目录
>          * @param deleteFile 要删除的文件
>          */
>         public void delete(String directory, String deleteFile) throws SftpException {
>             sftp.cd(directory);
>             sftp.rm(deleteFile);
>         }
>     
>     
>         /**
>          * 列出目录下的文件
>          *
>          * @param directory 要列出的目录
>          */
>         public Vector<?> listFiles(String directory) throws SftpException {
>             return sftp.ls(directory);
>         }
>     
>     
>         public List<String> getdownloads(String fileName, String contains) throws SftpException {
>             List<String> list = new ArrayList<String>();
>             logger.info("下载中。。");
>             Vector vector = listFiles(fileName);
>             for (int i = 0; i < vector.size(); i++) {
>                 ChannelSftp.LsEntry entry = (LsEntry) vector.get(i);
>                 if (entry.getFilename().contains(contains)) {
>                     list.add(entry.getFilename());
>                 }
>             }
>             return list;
>         }
>     
>     }

## 二、pom文件 ##

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

## 三、核心代码示例 ##

>     public String downloadFile(String date) {
>         String comPath = null;
>         try {
>             SFTPUtil sftp = new SFTPUtil(UserName, hPassWord, Host, Integer.parseInt(port));
>             sftp.login();
>             logger.info("登录sftp");
>             TextUtil.createFile(filePath+"/"+date+"/"+iceName+"/");
>             List<String> list=sftp.getdownloads(SftpPath, date);
>             for (int i = 0; i < list.size(); i++) {
>                 String file=list.get(i);
>                 comPath = filePath+"/"+date+"/"+iceName+"/"+file;
>                 logger.info("下载文件名:" + comPath);
>                 sftp.download(SftpPath, file,comPath);
>             }
>             sftp.logout();
>             return comPath;
>         } catch (SftpException e) {
>             logger.error("下载失败：", e);
>             return null;
>         } catch (IOException e) {
>             logger.error("下载失败：", e);
>             return null;
>         }
>     }

>     public class TextUtil {
>        /**
>         * 创建目录
>         * @return
>         * @throws IOException 
>         */
>        public static void createFile(String fileName) throws IOException{
>           File file = new File(fileName); 
>           if(!file.exists()){ 
>            file.mkdirs(); 
>           }
>        }
>     }